JDBC（二）

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

三层架构的一些基本报结构如下：

domain包：下面是一些实体bean，属性为private，提供属性相对应的set和get方法。一般对应于数据库中的一张数据表，属性对应于数据表中的列。

dao包，数据访问层的接口，控制实体bean的CRUD操作和其他的一些业务逻辑，存储的都是接口。

dao.impl包，数据访问层接口的实现。

service包，业务逻辑层，调用数据访问层。

JDBC属于数据访问层的技术，JDBC的CRUD出现异常时不能仅是try，catch，否则上层的业务逻辑层不知道已经出现了错误，所以在CRUD出错时还需要向上抛出异常。

JDBC的SQLException是编译时异常，必须要进行处理，而且和JDBC进行了耦合，Hibernate抛出的就不是SQLException。所以向上抛出的不应是SQLException，而应该是运行时异常(RuntimeException)。

public static void updateObject(String sql, String[] params) throws DaoRuntimeException {

  Connection conn = null;

  PreparedStatement pstmt = null;

  ResultSet rs = null;

  try {

   conn = DBConnectionManager.getConnection();

   pstmt = conn.prepareStatement(sql);

   for (int i = 0; params != null && i < params.length; i++) {

    pstmt.setString(i + 1, params[i]);

   }

   rs = pstmt.executeUpdate();

  } catch (Exception e) {

   logger.info("Execute sql : " + sql + " fail!!!");

   throw new DaoRuntimeException(e.getMessage(),e);

  } finally {

   DBConnectionManager.free(conn, pstmt, rs);

  }

事务的四个特性ACID：

原子性：automicity，操作要么全执行，要么全部执行，不能执行一部分。

一致性：consistency，数据库数据完整性约束。

隔离性：isolcation，一个事务对另一个事务不会产生影响。

持久性：durablity，事务的结果可以被持久的保留下来。

JDBC对事务的主要操作：

connection.setAutoCommit(false)//打开事务

//多条CRUD操作

connection.commit()//提交事务

connection.rollback()//回滚事务

还可以回滚至特定的保存点，

SavePoint sp = conection.setSavePoint();

connection.rollback(sp);

事务的操作如果跨越了多个数据源，还需要用到JTA，使用支持JTA的容器如weblogic，websphere提供的JNDI服务去完成。

脏读：一个事务读到了另一个事务未提交的数据。

不可重复读：一个事务重复读取的操作读到的数据不一致，是其他的事务修改了所读取的数据所导致的。

幻读：一个事务读到了另一个事务已提交的数据。

数据库的隔离级别又分为:读未提交，读已提交，可重复读，可串行化

读未提交可能产生：脏读，不可重复读，幻读

读已提交可能产生：不可重复读，幻读

可重复读可能产生：幻读，可以用快照技术实现，存储读取的数据。

可串行化不会有脏读，不可重复读，幻读

不同数据库的隔离级别是不同的，MySQL默认的是可重复读。隔离级别越高，占用资源越多，数据正确性越高。

connection.setTransactionIsocation(Connection.TRANSACTION_REPEATABLE_READ)。不设置时就是用数据库默认的隔离级别。

JDBC调用存储过程。

一个简单的存储过程如下:

demiliter |

drop procedure if exists addUser |

create procedure addUser(in pname varchar(40),in birthday date,out pid int)

begin

insert into user(name,birthday) values (pname,birthday);

select last_insert_id into pid;

end |

demilter;

String sql = "{ call addUser(?,?,?)}";

CallableStatement cs = conn.prepareCall(sql);

cs.registerOutParameter(3,Type.Integer);

cs.setString(1,"new user");

cs.setDate(2,new java.sql.Date(System.currentTimeMills()));

cs.executeUpdate();

int id = cs.get(3);

批量处理，大量的SQL语句时需要注意：

PreparedStatement.executeBatch();,下面是执行1000条SQL的例子。还需要考虑到一次发送的SQL语句集合包的大小，不能一次发送的数量太大，会导致内存溢出。

大量的插入语句insert into () values()()()效率很高。

public static void updateObject(String sql, String[] params) throws DaoRuntimeException {

  Connection conn = null;

  PreparedStatement pstmt = null;

  ResultSet rs = null;

  try {

   conn = DBConnectionManager.getConnection();

   pstmt = conn.prepareStatement(sql);

      
   for(int round =0;round <1000;round ++){
       for (int i = 0; params != null && i < params.length; i++) {

         pstmt.setString(i + 1, params[i]);

       }
       psmt.addBatch();//statment对应的是psmt.addBatch(String sql) 
   }

   rs = psmt.executeBatch();//rs = pstmt.executeUpdate();

  } catch (Exception e) {

   logger.info("Execute sql : " + sql + " fail!!!");

   throw new DaoRuntimeException(e.getMessage(),e);

  } finally {

   DBConnectionManager.free(conn, pstmt, rs);

  }