事务简介
- 事务（Transaction）:数据库中保证交易可靠的机制
- JDBC支持数据库中的事务概念
- 在JDBC中，事务默认是自动提交的
- 可能存在的问题
-
事务特性ACID：
- 原子性（Atomicity）事务必须是原子工作单元；对于其数据修改，要么全都执行，要么全都不执行
- 一致性（Consisiency）:事务在完成时，必须使所有的数据都保持一致状态
- 隔离性（Isolation）:由并发事务所作的修改必须与任何其它并发事务所作的修改隔离
- 持久性（Durability）:事务完成时，必须使所有的数据都保持一致状态
事务是数据库的概念，JDBC支持事务，本质还是在数据库实现的
3
JDC事务API
-
相关API：
- Connection.getAutoCommit():获得当前事务的提交方式,默认为true
- Connection.setAutoCommit():设置事务的提交属性，参数是
true:自动提交；false:不自动提交 - Connection.commit():提交事务
- Connection.rollback():回滚事务
JDBC标准事务编程模式
try{
//1.定义用于在事务中执行的SQL语句
String sql1 = "updata account set amount = amount-“+amount+” where id = '"+from+"'";
String sql2 = "updata account set amount = amount +"+amount+" where id ='"+to+"'";
autoCommit = con.getAutoCommit();//2.获得自动提交状态
con.setAutoCommit(false);//3.关闭自动提交
stmt.executeUpdate(sql1);//4.执行SQL语句
stmt.executeUpsate(sql2);
con.commit();//5.提交
con.setAutoCommit(autoCommit);//6.将自动提交功能恢复到原来的状态
//其他语句;
}catch(){
conn.rollback();//异常时回滚
}
批量更新
批量更新的优势
- 批处理：发送到数据库作为一个单元执行的一组更新语句
- 批处理降低了应用程序与数据库之间的网络调用
- 相比单个SQL语句的处理，批处理更为有效
批量更新API
-
addBatch(String sql)
- Statement类的方法，可以将多条sql语句添加Statement对象的SQL语句列表中
-
addBatch()
- PreparedStatement类的方法，可以将多条预编译的sql语句添加到PreparedStatement对象的SQL语句列表中
-
executeBatch()
- 把Statemennt对象或PreparedStatemenn对象语句列表中的所有SQL语句发送给数据库进行处理
-
clearBatch()
- 清空当前SQL语句列表
防止OutOfMemory
如果Preparedstatement对象中的SQOL列表包含过多的待处理SQL语句，可能会产生OutOfMemory错误
-
及时处理SQL语句列表
for(int i=0;i<1000;i++){ sql = "insert into emp(empno,ename) values(emp_seq.nexttval,'name"+i+"')"; stmt.addBatch(sql);///将SQL语句加入到Batch中 if(i%500==0){ stmt.exrcteBatch(); //及时处理 stmt.clearBatch(); //清空列表 } } //最后一次列表不足500条，处理 stmt.executeBatch();
返回自动主键
关联数据插入
- 主表/从表关联关系，插入数据时需要保证数据完整性
- 关联数据插入时的流程
通过序列产生主键(Oracle)
在oracle,建议主键通过序列获得：
String sql = "insert into dept (deptno,dname,loc) values(dept_seq.nextval,?,?)";如果但表操作，不需要返回刚刚插入的主键值
如果关联操作，需要将刚刚插入的主键值返回
JDBC返回自动主键API
方法一
先通过序列的nextvali获取序列的下一个值，再作为参数插入到主表和从表
String sql = "select dept_seq.nextval as id from dual";
获得主键
String sql1 = "insert into dept(deptno,dname,loc) values(?,?,?)";
插入主键
String sql2 = "insert into emp(empno,ename,deptno) values(?,?,?)";
插入从表
简单，但需要额外多一次访问数据库，影响性能方法二
利用PreparedStatement的getGenratedKeys方法获取自增类型的数据，性能良好，只要一次SQL交互
sql = "insert into dept(deptno,dname,loc) values(dept_seq.nextval,?,?)";
stmt = con.prepareStatement(sql,new String[]{"deptno"});
stmt第二个参数是GeneratedKeys的字段名列表，字符串数组
stmt.setString(1,"Research");
stmt.setString(2,"beijing");
stmt.executeUpdate();
ResultSet rs = stmt.getGeneratedKeys();
获得主键值所在rs
while(rs.next()){
id=rs.getInt(1);
从rs中取出主键值,从表使用
}
分页查询
JDBC实现Oracle分页查询
-
利用Oracle的rownum,传入SQL语句，以获得分页结果集：
String sql = "select * from(select rownum rn,empno,ename,job,mgr,hiredate,sal,comm,deptno from(select * from emp order by empno)where rn between ? and ?)";
-
计算分页结果集的起点和终点,替代SQL中的占位i符：
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）,计算把哪些数据输出显示，将可滚动结果集的指针移到指定位置
- 只访问数据库一次，第一次取数比较慢，以后每页都从缓存中取，比较快
- 比较适合小数据量，如果数据量大，对内存压力较大
MySQL的实现方式：
select * from t limit begin,pageSize;
begin:从第几条开始显示 pageSize:每页多少条
- 在Java程序中,MySQL和Oracle分页的方式,仅限与SQL语句不同
什么是DAO
DAO封装对数据的访问
- DAO(Data Access Object)数据访问对象
- 建立在数据库和业务层之间，封装所有对数据库的访问
- 目的：数据访问逻辑和业务逻辑分开
-
为了建立一个健壮的Java应用，需将所有对数据源的访问操作抽象封装在一个公共API中，包括：
- 建立一个接口，接口中定义了应用程序中将会用到的所有事务方法
- 建立接口的实现类，实现接口对应的所有方法，和数据库直接交互
在应用程序中，当需要和数据源交互时则使用DAO接口，不设计任何数据库的具体操作
-
DAO通常包括：
- 一个DAO工厂类；
- 一个DAO接口；
- 一个实现DAO接口的具体类
- 数据传递对象（实体对象 或 值对象）.
实体对象
- DAO层需要定义对数据库中表的访问
- 对象关系映射（ORM：Object/Relation Mapping）描述对象和数据表之间的映射，将Java程序中的对象对应到关系数据库的表中
- 表和类对应
- 表中的字段和类的属性对应
- 记录和对象对应
编写DAO
查询方法
public Account findById() throws SQLException{
Connection conn = getConnection();
String sql = SELECT_BY_ID;//预先定义好的SQL查询语句
PreparedStatement ps = conn.prepareStatement(sql);
ps.setInt(1,id);//传入参数
ResuleSet rs = ps.executeQuery();
Account account = null;
while(rs.next()){//处理结果集
account = new Account();
account.setId(rs.getInt("ACCOUNT_ID"));
//设置account对象所有的属性，略
}
return account;
}
更新方法
public boolean update(Account account) throws SQLException{
Connection conn = getConnection();
String sql = UPDATE_STATUS;//预先定义好的SQL语句
PreparedStatemenet ps = conn
ps.setInt(1,account.getId());//传入参数
ps.setString(2,account.getStatus());
int flag = ps.executeUpdate();
return (flag>0 ? true:false);
}
异常处理机制
-
多层系统的异常处理原则：
- 谁抛出的异常，谁捕捉处理，因为只有异常抛出者，知道怎样捕获处理异常；
- 尽量在当前层中捕获处理抛出的异常，尽量不要抛出到上层接口；
- 尽量在每层中封装每层的异常类，这样可准确定位异常抛出的层；
- 如异常无法捕捉处理，则向上层接口抛出，直至抛给JVM
- 应尽量避免将异常抛给JVM
