原子性、一致性、分离性、持久性
(1) 原子性
事务的原子性指的是,事务中包含的程序作为数据库的逻辑工作单位,它所做的对数据修改 *** 作要么全部执行,要么完全不执行。这种特性称为原子性。
事务的原子性要求,如果把一个事务可看作是一个程序,它要么完整的被执行,要么完全不执行。就是说事务的 *** 纵序列或者完全应用到数据库或者完全不影响数据库。这种特性称为原子性。
假如用户在一个事务内完成了对数据库的更新,这时所有的更新对外部世界必须是可见的,或者完全没有更新。前者称事务已提交,后者称丛明事务撤消(或流产)。DBMS必须确保由成功提交的事务完成的所有 *** 纵在数据库内有完全的反映,而失败的事务对数据库完全没有影响。
(2) 一致性
事务的一致性指的是在一个事务执行之前和执行之后数据库都必须处于一致性状态。这种特性称为事务的一致性。假如数据库的状态满足所有的完整性约束,就说该数据库是一致的。
一致性处理数据库中对所有语义约束的保护。假如数据库的状态满足所有的完整性约束,就说该数据库是一致的。例如,当数据库处于一致性状态S1时,对数据库执行一个事务,在事务执行期间假定数据库的状态是不一致的,当事务执行结束时,数据培郑蚂库处在一致性状态S2。
(3) 分离性
分离性指并发的事务是相互隔离的。即一个事务内部的 *** 作及正在 *** 作的数据必须封锁起来,不被其它企图进行修改的事务看到。
分离性是DBMS针对并发事务间的冲突提供的安全保证。DBMS可以通过加锁在并发执行的事务间提供不同级别的分离。假如并发交叉执行的事务没有任何控制, *** 纵相同的共享对象的多个并发事务的执行可能引起异常情况。
DBMS可以在并发执行的事务间提供不同级别的分离。分离的级别和并发事务的吞吐量之间存在反比关系。较多事务的可分离性可能会带来较高的冲突和较多的事务流产。流产的事务要消耗资源,这些资源必须要重新被访问。因此,确保高分离级别的DBMS需要更多的开销。
(4)持久性
持久性意味着当系统或介质发生故障时,确保已提交事务的更新不能丢失。即一旦一个事务提交,DBMS保证它对数据库中数据的改变应该是永久性的,耐得住任何系统故障。持久性通过数据库备份和恢复来保证。
持久性意味着当系统或介质发生故障时,确保已提交事务的更新不能丢失。即对已提交事务的更新能恢复。一旦一个事务被提交,DBMS必须保证提供适当的冗余,使其耐得住系统的故障。所以,持久性主要在于DBMS的恢复性能。
事务处理是在针对数据库 *** 作时一个重要环节,它可以保证执行多条记录的一致性,实现数据库中表与表之间的关联,同时提高了对数据 *** 作的准确性、安全性。本文主要一起来学习在Java程序中如何使用JDBC来实现数据间的事务处理。一、什么是事务处理
事务处理就是当执行多个SQL指令时,如果因为某个原因使其中一条指令执行有错误,则取消先前执行过的所有指令。它的作用吵埋是保证各项 *** 作的一致性和完宽碰乎整性。
二、JDBC中的事务控制
JDBC API中的JDBC事务是通过Connection对象进行控制的。Connection对象提供了两种事务模式:自动提交模式和手工提交模式。系统默认为自动提交模式,即,对数据库进行 *** 作的每一条记录,都被看作是一项事务。 *** 作成功后,系统会自动提交,否则自动取消事务。 如果想对多个SQL进行统一的事务处理,就必须先取消自动提交模式,通过使用Connection 的setAutoCommit(false) 方法来取消自动提交事务。Connection类中还提供了如下其他控制事务的方法:
1)public boolean getAutoCommit():判断当前事务模式是否为自动提交,如果是则返回ture,否则返回false;
2)public void commit():提交事务;
3)public void rollback():回滚事务;
注意:
Java中使用JDBC事务处理,一个JDBC不能跨越多个数据库而且需要判断当前使用的数据库是否支持事务。这时可以使用 DatabaseMedaData 的supportTranslations() 方法进行检查数据库是否支持事务处理,若返回 true 则说明支持事务处理,否则返回 false 。如使用MySQL 的事务功能,就要求MySQL里的表的类型为Innodb才支持事务控制处理,否则,在Java程序中做了 commit 或 rollback ,但数据库中是不生效的。
三、JDBC 事务处理基本流程
实现事务处理的基本流程如下:
1)判断当前使用的JDBC驱动程序和数据库是否支持事务处理;
2)在支持事务处理的前提下,取消系统自动提交模式;
3)添加需要进行的事务信息;
4)将事务处理提交到数据库;
5)在处理事务时,若某条信息发生错误,则执行事务回滚 *** 作,并回滚到事务提交前的状态。
四、事务处理的实例
利用JDBC实现事务处理的实例,将4条SQL语句加在同一个事务里,当其中一条语句发生错误时,则执行事务回滚,取消所有的 *** 作。所以在最后的运行结果中,并没有发现有数据更新。
1、具体的代码如下:
[java] view plaincopy
package chp07
import java.sql.Connection
import java.sql.DatabaseMetaData
import java.sql.DriverManager
import java.sql.ResultSet
import java.sql.SQLException
import java.sql.Statement
public class Java_Transa {
// 数慎悉据库连接
public static Connection getConnection() {
Connection con = null
try {
Class.forName("com.mysql.jdbc.Driver")// 加载Mysql数据驱动
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/myuser", "root", "root")// 创建数据连接
} catch (Exception e) {
System.out.println("数据库连接失败")
}
return con
}
// 判断数据库是否支持事务
public static boolean JudgeTransaction(Connection con) {
try {
// 获取数据库的元数据
DatabaseMetaData md = con.getMetaData()
// 获取事务处理支持情况
return md.supportsTransactions()
} catch (SQLException e) {
e.printStackTrace()
}
return false
}
// 将一组SQL语句放在一个事务里执行,要么全部执行通过,要么全部不执行
public static void StartTransaction(Connection con, String[] sqls) throws Exception {
if (sqls == null) {
return
}
Statement sm = null
try {
// 事务开始
System.out.println("事务处理开始!")
con.setAutoCommit(false) // 设置连接不自动提交,即用该连接进行的 *** 作都不更新到数据库
sm = con.createStatement()// 创建Statement对象
//依次执行传入的SQL语句
for (int i = 0i <sqls.lengthi++) {
sm.execute(sqls[i])// 执行添加事物的语句
}
System.out.println("提交事务处理!")
con.commit() // 提交给数据库处理
System.out.println("事务处理结束!")
// 事务结束
//捕获执行SQL语句组中的异常
} catch (SQLException e) {
try {
System.out.println("事务执行失败,进行回滚!\n")
con.rollback()// 若前面某条语句出现异常时,进行回滚,取消前面执行的所有 *** 作
} catch (SQLException e1) {
e1.printStackTrace()
}
} finally {
sm.close()
}
}
// 查询表 staff
public static void query_student() throws Exception {
Connection conect = getConnection()// 获取连接
System.out.println("执行事物处理后,表 staff 的全部记录为:\n")
try {
String sql = "select * from staff"// 查询数据的sql语句
Statement st = (Statement) conect.createStatement() // 创建Statement对象
ResultSet rs = st.executeQuery(sql) // 执行SQL语句并返回查询数据的结果集
//打印输出查询结果
while (rs.next()) { // 判断是否还有下一个数据
// 根据字段名获取相应的值
String name = charset(rs.getString("name"))
int age = rs.getInt("age")
String sex = charset(rs.getString("sex"))
String depart = charset(rs.getString("depart"))
String address = charset(rs.getString("address"))
int worklen = rs.getInt("worklen")
int wage = rs.getInt("wage")
System.out.println(name + " " + age + " " + sex + " "
+ address + " " + depart + " " + worklen + " " + wage)
}
System.out.println()
} catch (SQLException e) {
System.out.println("查询数据失败")
}
}
// 字符集的设定,解决中文乱码
public static String charset(String str) throws Exception {
String newStr = new String(str.getBytes("ISO8859-1"), "UTF-8")
return newStr
}
public static void main(String[] args) throws Exception {
String[] arry = new String[4] // 定义一组事物处理语句
arry[0] = "delete from staff where name='Serein'" //删除staff表格中 name 字段值为 "Serein" 的员工记录
arry[1] = "UPDATE staff SET address='Shenzhen' where name=lili"// 执行这条语句会引起错误,因为表 staff 中name='lili'不存在
arry[2] = "INSERT INTO student (name,age,sex,address,depart,worklen,wage)" //SQL插入记录语句
+ "values ('Allen',19,'M','Beijing','Engine',4,4800)"
arry[3] = "select * from staff" //SQL查询表 staff 语句
Connection con = null
try {
con = getConnection()// 获得数据库连接
boolean judge = JudgeTransaction(con) // 判断是否支持批处理
System.out.print("支持事务处理吗? ")
System.out.println(judge ? "支持" : "不支持")
if (judge) {
StartTransaction(con, arry) // 如果支持则开始执行事务
}
} catch (Exception e) {
e.printStackTrace()
} finally {
con.close() // 关闭数据库连接
}
query_student()
}
}
说明:该Java程序中数据库 *** 作涉及的数据库为 “myuser ” ,并使用其中的 “staff” 表格,也就是我之前的文章《JDBC连接MySQL数据库及示例》里所创建的数据库和表。如果需要跟着去实现并运行这个例子的话,可以前去参考创建,或者根据你自己的数据库情况去修改其中有关连接MySQL的代码以及SQL语句。
附上程序运行前的“staff”表格中的数据:
注意观察里面的第三条记录,即 name 字段值为“Seren”的记录。即将运行的 Java 程序的第113代码中的 SQL 语句表示要删除该条记录,但是由于后面的事务出错,所以全部的事务不执行,并回滚,所以最后的结果是name为“Serein”这条记录依旧存在于数据表中。
>>启动事务 conn.setAutoCommit()这个不是启动事务,而是设置事务是否自动提交,默认是自动提交,如果要手动控的话,写成conn.setAutoCommit(false)
if(rs.next){
>>> ...执行更新
conn.commit()
}
这个也不对,RS不可能执更新 *** 作。只能是查询。
如果你进行了锁表 *** 作,那么如果没有commit()或rollbak()方法,是不会进行解锁 *** 作的。
下面给你些代码段以做参考。
public class SQLCondition{
public ResultSet execuQuery(Connection conn) throws SQLException{
检索 *** 作.......
}
public int execuUpdate(Connection conn) throws SQLException{
更新 *** 作.......
}
}
public class DBAccess(){
public void execute(){
SQLCondition condition = .....
Connection conn = .....
try{
conn.setAutoCommit(false)//设成非自动提交
condition.execuQuery(conn)
condition.execuUpdate(conn)
//如果 *** 作成功会走到这一步,进行提交,可以解锁
conn.commit()
}catch(SQLException){
//出现任何的SQL异常都可以捕捉到,纤陪派进行事务回滚,毁贺也可以解锁。
conn.rollbak()
}
}
}
>>自乱唤动默认是回滚事务?
默认的话,是执行一条就进行提交,如果错了会回滚。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)