读书人

【转】JDBC事宜

发布时间: 2012-07-26 12:01:08 作者: rapoo

【转】JDBC事务

事务(ACID)
* 原子性(atomicity):组成事务处理的语句形成了一个逻辑单元,不能只执行其中的一部分。
* 一致性(consistency):在事务处理执行前后,数据库是一致的(两个账户要么都变,或者都不变)。
* 隔离性(isolcation):一个事务处理对另一个事务处理没有影响。
* 持续性(durability):事务处理的效果能够被永久保存下来 。

JDBC事务的含义:是指对数据库操作中,由一条或多条对数据库更新的SQL语句所组成的一个不可分割的工作单元。具有原子性,要么全部执行成功,要么全部执行失败,撤销执行。
* connection.setAutoCommit(false);//打开事务。JDBCAPI中默认:每条更新语句是一个事务,是自动提交事务。该方法参数为false时是手工提交事务,需要提交事务时,应执行commit()方法;
* connection.commit();//提交事务。
* connection.rollback();//回滚事务。

TxTest.java

?
package?cn.itcast.jdbc;?
?
import?java.sql.Connection;?
import?java.sql.ResultSet;?
import?java.sql.SQLException;?
import?java.sql.Statement;?
?
public?class?TxTest?{?
?
????public?static?void?main(String[]?args)?throws?SQLException?{?
????????testIsDirty();?
????}?
?
????static?void?testIsDirty()?throws?SQLException?{?
????????Connection?conn?=?null;?
????????Statement?st?=?null;?
????????ResultSet?rs?=?null;?
????????try?{?
????????????conn?=?JdbcUtils.getConnection();?
?
????????????st?=?conn.createStatement();?
????????????String?sql?=?"update?user?set?money=money-10?where?id=1";?
????????????st.executeUpdate(sql);?
?
????????????sql?=?"select?money?from?user?where?id=2";?
????????????rs?=?st.executeQuery(sql);?
????????????float?money?=?0.0f;?
????????????if?(rs.next())?{?
????????????????money?=?rs.getFloat("money");?
????????????}?
????????????if?(money?>?400)?
????????????????throw?new?RuntimeException("已经超过最大值!");?
????????????//如果你不确定用什么异常的话,就用RuntimeException就行了?
????????????sql?=?"update?user?set?money=money+10?where?id=2";?
????????????st.executeUpdate(sql);?
????????}?finally?{?
????????????JdbcUtils.free(rs,?st,?conn);?
????????}?
????}?
}?

????这样子的话就不好了,一个少了money,另一个木有增加。

????要是想达到这个效果:如果一个钱没增加,那么之前那个也别减了。如果想达到这个效果,就要把这两个步骤放在一个事务里面去,放在一个事务里面去就能保证这两个步骤要么全做,要么一个都不做。

TxTest.java
?
package?cn.itcast.jdbc;?
?
import?java.sql.Connection;?
import?java.sql.ResultSet;?
import?java.sql.SQLException;?
import?java.sql.Statement;?
?
public?class?TxTest?{?
?
????public?static?void?main(String[]?args)?throws?SQLException?{?
????????test();?
????}?
?
????static?void?test()?throws?SQLException?{?
????????Connection?conn?=?null;?
????????Statement?st?=?null;?
????????ResultSet?rs?=?null;?
????????try?{?
????????????conn?=?JdbcUtils.getConnection();?
????????????conn.setAutoCommit(false);//打开事务?
????????????conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);?
?
????????????st?=?conn.createStatement();?
????????????String?sql?=?"update?user?set?money=money-10?where?id=1";?
????????????st.executeUpdate(sql);?
?
????????????sql?=?"select?money?from?user?where?id=2";?
????????????rs?=?st.executeQuery(sql);?
????????????float?money?=?0.0f;?
????????????if?(rs.next())?{?
????????????????money?=?rs.getFloat("money");?
????????????}?
????????????if?(money?>?400)?
????????????????throw?new?RuntimeException("已经超过最大值!");?
???????????????//如果你不确定用什么异常的话,就用RuntimeException就行了?
????????????sql?=?"update?user?set?money=money+10?where?id=2";?
????????????st.executeUpdate(sql);?
????????????conn.commit();?
????????}?catch?(SQLException?e)?{?
????????????if?(conn?!=?null)?
????????????????conn.rollback();//连接不为空的话,回滚?
????????????throw?e;?
????????}?finally?{?
????????????JdbcUtils.free(rs,?st,?conn);?
????????}?
????}?
}


????这样就木有问题了。
????另外要注意的是,如果你用的是mysql的数据库,要注意看表的引擎是什么样的,用命令show create table user; 引擎是InnoDB的话,它是支持这种事务的,包括主键外键关联它都是支持的。如果表用的引擎是那种MyIsam的话,它是不支持事务的,也不支持主外键关联的。如果在测试的时候发现事务不好用,不能回滚,那可能是你表的引擎的问题,要注意看一下。

读书人网 >其他数据库

热点推荐