JDBC技术-数据库事务处理与隔离性了解

1.事务：一组逻辑操作单元，使数据从一种状态变换到另一种状态。

2.事务处理的原则：保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。

当在一个事务中执行多个操作时，要么所有的事务都被提交(commit），那么这些修改就永久地保存下来；

要么数据库管理系统将放弃所作的所有修改，整个事务回滚（rollback)到最初状态。

// 以下的两个操作共同构成一个数据库事务。但是在两个操作之间可能出现异常问题。

// 原则上，一旦出现问题，就需要将之前的操作“回滚”！需要对如下的操作进行完善。

@Test

public void testUpdate() {

String sql1 = “update user_table set balance = balance – 100 where user = ?”;

update(sql1, “AA”);

System.out.println(10 / 0);

String sql2 = “update user_table set balance = balance + 100 where user = ?”;

update(sql2, “BB”);

3.考虑到数据库事务的话，我们又将原来使用PreparedStatement重构的Statement的增删和改查的操作，再升级。

// 实现一个通用的UPDATE INSERT DELETE的操作的方法(version 3·0)

public void update(Connection conn,String sql, Object… args) {

PreparedStatement ps = null;

try {

ps = conn.prepareStatement(sql);

for (int i = 0; i < args·length; i++) {

ps.setObject(i + 1, args[i]);

ps.execute();

} catch (Exception e) {

e.printStackTrace();

} finally {

JDBCUtils.close(null, ps, null);

// 实现一个通用的查询操作,返回一个对象(version 3·0)

public

T getInstance(Connection conn,String sql, Class

clazz, Object… args) {

PreparedStatement ps = null;

ResultSet rs = null;

try {

ps = conn.prepareStatement(sql);

// 填充占位符

for (int i = 0; i < args·length; i++) {

ps.setObject(i + 1, args[i]);

// 4.执行并返回ResultSet的对象

rs = ps.executeQuery();

if (rs.next()) {

// 5.创建T的对象

T t = clazz.newInstance();

// 6.将结果集中的列值作为T的对象的属性，给予赋值

ResultSetMetaData rsmd = rs.getMetaData();

int columnCount = rsmd.getColumnCount();

for (int i = 0; i < columnCount; i++) {

Object columnVal = rs.getObject(i + 1);

String columnLabel = rsmd.getColumnLabel(i + 1);

PropertyUtils.setProperty(t, columnLabel, columnVal);

return t;

} catch (Exception e) {

e.printStackTrace();

} finally {

// 7.关闭相应的操作

JDBCUtils.close(rs, ps, null);

return null;

// 实现一个通用的查询操作,返回一个对象的集合(version 3·0)

public

List

getForList(Connection conn,String sql,Class

clazz,Object … args){

PreparedStatement ps = null;

ResultSet rs = null;

List

list = new ArrayList

try{

ps = conn.prepareStatement(sql);

for(int i = 0;i < args·length;i++){

ps.setObject(i + 1, args[i]);

rs = ps.executeQuery();

ResultSetMetaData rsmd = rs.getMetaData();

int columnCount = rsmd.getColumnCount();

while(rs.next()){

T t = clazz.newInstance();

for(int i = 0;i < columnCount;i++){

Object columnVal = rs.getObject(i + 1);

String columnLabel = rsmd.getColumnLabel(i + 1);

PropertyUtils.setProperty(t, columnLabel, columnVal);

list.add(t);

}catch(Exception e){

e.printStackTrace();

}finally{

JDBCUtils.close(rs, ps, null);

return list;

//考虑到数据库事务，通过java程序对数据库中表的操作的模板（掌握）

public void method(){

Connection conn = null;

try{

//1.获取数据库的连接（①conn = JDBCUtils.getConnection(); ②数据库连接池（开发者选择此））

//2.开启事务

conn.setAutoCommit(false);

//3.对数据库中表进行相应的操作(增、删、改、查)（①version 3.0 ②DBUtils工具类：update() 和query()方法）

//4.提交事务

conn.commit();

}catch(Exception e){

e.printStackTrace();

try{

//5.回滚事务

conn.rollback();

}catch(Exception e1){

e1.printStackTrace();

}finally{

//6.关闭数据库的连接（①自己实现数据库相应资源的关闭JDBCUtils.close(null,null,conn); ②使用DBUtils工具类的close()方法）

了解：

针对隔离性，我们提供了不同数据库处理的隔离级别，针对处理数据发生的问题（脏读、不可重复读、幻读）提供了多张隔离级别

隔离级别：（脏读是我们一定避免的，而不可重复读、幻读是允许存在的）

哟啊

文章转载链接：http://www.atguigu.com/jsfx/1125.html