public String delete(String id) {
String ID = id
db = new getConnection()
Connection con = db.getConnection()
try {
con.setAutoCommit(false)
db.executeUpdate("delete from helloworld where ID=" + ID)//更新 *** 作1
db.executeUpdate("delete from helloworld _book where ID=" + ID)//更新 *** 作2
db.executeUpdate("delete from helloworld_user where ID=" + ID)//更新 *** 作3
con.commit()//提交JDBC事务
con.setAutoCommit(true)
db.close()
return “success”
}
catch (Exception e) {
con.rollBack()//回滚JDBC事务
e.printStackTrace()
db.close()
return “fail”
}
}
Java中的事务处理一般情况下,J2EE应用服务器支持JDBC事务、JTA(Java Transaction API)事务、容器管理事务。一般情况下,最好不要在程序中同时使用上述三种事务类型,比如在JTA事务中嵌套JDBC事务。第二方面,事务要在尽可能短的时间内完成,不要在不同方法中实现事务的使用。下面我们列举两种事务处理方式。
1、JavaBean中使用JDBC方式进行事务处理
在JDBC中怎样将多个SQL语句组合成一个事务呢?在JDBC中,打开一个连接对象Connection时,缺省是auto-commit模式,每个SQL语句都被当作一个事务,即每次执行一个语句,都会自动的得到事务确认。为了能将多个SQL语句组合成一个事务,要将auto-commit模式屏蔽掉。在auto-commit模式屏蔽掉之后,如果不调用commit()方法,SQL语句不会得到事务确认。在最近一次commit()方法调用之后的所有SQL会在方法commit()调用时得到确认。
public int delete(int sID) {
dbc = new DataBaseConnection()
Connection con = dbc.getConnection()
try {
con.setAutoCommit(false)// 更改JDBC事务的默认提交方式
dbc.executeUpdate("delete from bylaw where ID=" + sID)
dbc.executeUpdate("delete from bylaw _content where ID=" + sID)
dbc.executeUpdate("delete from bylaw _affix where bylawid=" + sID)
con.commit()//提交JDBC事务
con.setAutoCommit(true)// 恢复JDBC事务的默认提交方式
dbc.close()
return 1
}
catch (Exception exc) {
con.rollBack()//回滚JDBC事务
exc.printStackTrace()
dbc.close()
return -1
}
}
2、SessionBean中的JTA事务
JTA 是事务服务的 J2EE 解决方案。本质上,它是描述事务接口(比如 UserTransaction 接口,开发人员直接使用该接口或者通过 J2EE 容器使用该接口来确保业务逻辑能够可靠地运行)的 J2EE 模型的一部分。JTA 具有的三个主要的接口分别是 UserTransaction 接口、TransactionManager 接口和 Transaction 接口。这些接口共享公共的事务 *** 作,例如 commit() 和 rollback(), 但是也包含特殊的事务 *** 作,例如 suspend(),resume() 和 enlist(),它们只出现在特定的接口上,以便在实现中允许一定程度的访问控制。例如,UserTransaction 能够执行事务划分和基本的事务 *** 作,而 TransactionManager 能够执行上下文管理。
应用程序可以调用UserTransaction.begin()方法开始一个事务,该事务与应用程序正在其中运行的当前线程相关联。底层的事务管理器实际处理线程与事务之间的关联。UserTransaction.commit()方法终止与当前线程关联的事务。UserTransaction.rollback()方法将放弃与当前线程关联的当前事务。
public int delete(int sID) {
DataBaseConnection dbc = null
dbc = new DataBaseConnection()
dbc.getConnection()
UserTransaction transaction = sessionContext.getUserTransaction()//获得JTA事务
try {
transaction.begin()//开始JTA事务
dbc.executeUpdate("delete from bylaw where ID=" + sID)
dbc.executeUpdate("delete from bylaw _content where ID=" + sID)
dbc.executeUpdate("delete from bylaw _affix where bylawid=" + sID)
transaction.commit()//提交JTA事务
dbc.close()
return 1
}
catch (Exception exc) {
try {
transaction.rollback()//JTA事务回滚
}
catch (Exception ex) {
//JTA事务回滚出错处理
ex.printStackTrace()
}
exc.printStackTrace()
dbc.close()
return -1
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)