Top
  1. JDBC高级编程
  2. DAO

1. JDBC高级编程

1.1. JDBC高级编程

1.1.1. 事务简介

事务（Transaction）：数据库中保证交易可靠的机制。JDBC支持数据库中的事务概念，并且在JDBC中，事务默认是自动提交的。

可能存在的问题：某些业务逻辑必须在一个事务中完成。如图-1所示。

图-1事务示意图

事务特性介绍：ACID

事务是数据库的概念，JDBC支持事务，本质还是在数据库中实现的。

1.1.2. JDBC事务API

JDBC中和事务相关API：

1.1.3. JDBC标准事务编程模式

JDBC处理事务的通常模式：

try{
// 1.定义用于在事务中执行的SQL语句
String sql1 = "update account set amount = amount - " + amount + " where id = '" + from + "'";
String sql2 = "update account set amount = amount + " + amount + " where id = '" + to + "'";
autoCommit = con.getAutoCommit(); // 2.获得自动提交状态
con.setAutoCommit(false); // 3.关闭自动提交
stmt.executeUpdate(sql1); // 4.执行SQL语句
stmt.executeUpdate(sql2);
con.commit(); // 5.提交
con.setAutoCommit(autoCommit); // 6.将自动提交功能恢复到原来的状态
//其他语句;
}catch(SQLException e){
	conn.rollback();//异常时回滚
}

1.2. 批量更新

1.2.1. 批量更新的优势

批处理：发送到数据库作为一个单元执行的一组更新语句。批处理降低了应用程序和数据库之间的网络调用，相比单个SQL语句的处理，批处理更为有效。

1.2.2. 批量更新API

1.2.3. 防止OutOfMemory

如果PreparedStatement对象中的SQL列表包含过多的待处理SQL语句, 可能会产生OutOfMemory错误。所以需要及时处理SQL语句列表。

for (inti = 0; i< 1000; i++) {
sql = “insert into emp(empno, ename) values(emp_seq.nextval, 'name" + i + "'")";
//将SQL语句加入到Batch中
stmt.addBatch(sql);
//根据需要设置及时处理的条件
if (i % 500 == 0) {  
stmt.executeBatch();  //及时处理
stmt.clearBatch();  //清空列表
}  
}
// 最后一次列表不足500条，处理
stmt.executeBatch();

1.3. 返回自动主键

1.3.1. 关联数据插入

在主表/从表关联关系下，插入数据时需要保证数据完整性。关联数据插入时的流程：

图-2 关联数据插入流程

1.3.2. 通过序列产生主键（Oracle）

不同数据库的主键自增方式不同，在oracle中，建议主键通过序列获得。在SQL语句中，指定由哪个序列为表产生主键：

String sql = 
“insert into dept (deptno, dname, loc) values(dept_seq.nextval,?,?)”；

如果仅仅是单表操作，不需要返回刚刚插入的主键值，但如果有关联关系的表操作，需要获得刚刚插入的主键值。

1.3.3. JDBC返回自动主键API

方法一：先通过序列的nextval获取序列的下一个值，再作为参数插入到主表和从表。

//1.获得主键的SQL语句
String sql = "select dept_seq.nextval as id from dual";   
//执行上条SQL语句，通过ResultSet获得主键值，省略

//2.利用刚刚得到的主键值插入主表
String sql1=“insert into dept(deptno, dname, loc) values(?,?,?)";  
//执行insert语句，省略

//3.利用刚刚得到的主键值，作为外键插入从表
String sql2 = “insert into emp(empno, ename, deptno)  values(?,?,?)”;
//执行insert语句，省略

这种方式操作简单，但需要额外多一次访问数据库，影响性能。

方法二（建议）：利用PreparedStatement的getGeneratedKeys方法获取自增类型的数据，性能良好，只要一次SQL交互。

//1.插入主表SQL，使用序列作为主键
sql = "insert into dept (deptno, dname, loc) values(dept_seq.nextval,?,?)";
//2.定义stmt时，第二个参数是GeneratedKeys的主键的字段名列表，类型是字符串数组
stmt = con.prepareStatement(sql, new String[] { "deptno" });
//3.将占位符赋值
stmt.setString(1, “Research”);
stmt.setString(2, “beijing”);
//4.执行插入主表的insert语句
stmt.executeUpdate();
//5.获得主键值
rs = stmt.getGeneratedKeys();
rs.next();
intdeptno = rs.getInt(1);
//6.将刚刚得到的主表主键值，作为外键插入到从表中。
String sql2 = “insert into emp(empno, ename, deptno)  values(?,?,?)”;

1.4. 分页查询

1.4.1. JDBC实现Oracle分页查询

利用数据库的分页SQL语句，实现在Java程序中数据表的分页。在Oracle中使用rownum，以获得分页结果集：

String sql = "select * from (select  rownumrn, empno, ename, job,mgr, hiredate, sal, comm, deptno from (select * from emp order by empno) ) where rn between ? and ?";

两个占位符分别是结果集的起点和终点，计算后，替代SQL中的占位符：

	int begin = (page - 1) * pageSize + 1;
	int end = begin + pageSize - 1;

其中：

stmt = con.prepareStatement(sql);
stmt.setInt(1, begin);
stmt.setInt(2, end);
rs = stmt.executeQuery();

这种分页方式，每次只向数据库请求一页的数据量，内存压力小适合大数据量数据表。

另一种分页策略介绍：基于缓存的分页技术（也被称作假分页），一次性把数据全部取出来放在缓存中,根据用户要看的页数(page)和每页记录数(pageSize),计算把哪些数据输出显示，将可滚动结果集的指针移动到指定位置。

这种方式只访问数据库一次 , 第一次取数比较慢 , 以后每页都从缓存中取 , 比较快，比较适合小数据量 , 如果数据量大 , 对内存压力较大。

1.4.2. JDBC实现MySQL分页查询

不同数据库获取部分结果集的SQL是有区别的，在MySQL中的实现方式：

 select * from t limit begin，pageSize;

其中：

在Java程序中，MySQL和Oracle分页的方式，仅限于SQL语句不同。

2. DAO

2.1. 什么是DAO

2.1.1. DAO封装对数据的访问

DAO (Data Access Object)：数据访问对象，是建立在数据库和业务层之间，封装所有对数据库的访问。

目的：数据访问逻辑和业务逻辑分开。

图-3 DAO在多层结构中的位置

为了建立一个健壮的Java应用，需将所有对数据源的访问操作抽象封装在一个公共API中，需要：

在应用程序中，当需要和数据源交互时则使用DAO接口，不涉及任何数据库的具体操作。DAO通常包括：

1. 一个DAO工厂类；

2. 一个DAO接口；

3. 一个实现DAO接口的具体类；

4. 数据传递对象（实体对象（Entity）或值对象（Value Object，简称VO））.

2.1.2. 实体对象

DAO层需要定义对数据库中表的访问。

对象关系映射(ORM：Object/Relation Mapping)描述对象和数据表之间的映射，将Java程序中的对象对应到关系数据库的表中：

2.2. 编写DAO

2.2.1. 查询方法

	public Account findById(Integer id) throws SQLException {
		Connection conn = getConnection();
		String sql = SELECT_BY_ID; //预先定义好的SQL查询语句
		PreparedStatementps = conn.prepareStatement(sql);
		ps.setInt(1, id);//传入参数
		ResultSetrs = ps.executeQuery();
		Account account = null;
		while(rs.next()){//处理结果集
			account = new Account();
			account.setId(rs.getInt("ACCOUNT_ID"));
			//设置account对象所有的属性，略		}
		return account;
	}

2.2.2. 更新方法

	publicboolean update(Account account) throws SQLException {
		Connection conn = getConnection();
		String sql = UPDATE_STATUS; //预先定义好的SQL语句
		PreparedStatementps = conn.prepareStatement(sql);
		ps.setInt(1,account.getId());//传入参数
ps.setString(2, account.getStatus());
		int  flag= ps.executeUpdate();
		return (flag>0 ? true : false);
	}

2.2.3. 异常处理机制

多层系统的异常处理原则：