通过Eclipse完成事务操作
程序员文章站
2022-03-23 17:02:49
...
通过Eclipse完成事务操作
以银行账户数据库为例,如果要实现转账的过程,则需要完成事务的处理。
事务的四大特性(ACID)
原子性:数据库中原子性强调事务是一个不可分割的整体,事务开始后所有操作要么全部成功,要么全部失败,不可能停滞在中间某个环节。如果事务执行过程中出错就会回滚到事务开始前的状态,所有的操作就像没有发生一样不会对数据库有任何影响。
一致性:事务必须使数据库从一个一致性状态变换到另一个一致性状态,即一个事务执行之前和执行之后都必须处于一致性状态。
隔离性:当多个用户同时访问数据库时,比如操作同一张表时,数据库为每一个用户开启的事务,不能被其他事务的操作所干扰,多个并发事务之间要相互隔离,比如A正在从一张银行卡中取钱,在A取钱的过程结束前,B不能向这张卡转入钱。
持久性:一个事务一旦被提交,则对数据库的所有更新将被保存到数据库中,不能回滚。
数据操作语言(DML)默认的控制命令
默认情况下,每条SQL语句独立的事务,执行完SQL语句后数据便直接保存在磁盘中。本质上,数据库操纵语言(DML)之后默认有commit命令,所以直接保存在磁盘。
如果设置以下命令,可以阻止默认确认:
set autocommit=0;
其目的是,防止处理事务语言中出现错误,以下代码为例:
#事务
create table account(
id char(36) primary key,
card_id varchar(20) unique,
name varchar(8) not null,
money float(10,2) default 0
);
insert into account values('6ab71673-9502-44ba-8db0-7f625f17a67d','1234567890','张三',1000);
insert into account (id,card_id,name) values('9883a53d-9127-4a9a-bdcb-96cf87afe831','0987654321','张三');
select * from account
update account set money=money-100 where card_id= '1234567890';
update account set money=money+100 where card_id= '0987654321';
select * from account
#默认:每条SQL语句独立的事务,执行完SQL语句后直接保存在磁盘中
#数据库操纵语言(DML)之后默认有commit命令,直接保存在磁盘
#操作命令->缓存->磁盘,无commit提交,仅仅保存到磁盘,这时用rollback命令可以撤回
set autocommit=0;
update account set money=money-100 where card_id= '1234567890';
update account set money=money+100 where car_id= '0987654321';#出问题了,钱转出去了,没收到!
commit;
rollback;
select * from account;
出现了只有账号转出钱,而另一个账号未收到的情况。无默认确认的情况下,数据的流动为:操作命令->缓存->磁盘。只有确认了,才能从缓存最终到磁盘。而在这期间(处理事务语言中出现错误),我们可以使用滚回命令(rollback)命令,以阻止操作。
整合后的方法
保存在DBlink.java文件中,用它来实现事务的批量处理。
public boolean batch(String...sqls) {
Connection connection = null;
Statement statement = null;
try {
connection = getconnection();//创建连接
statement = connection.createStatement();//创建语句
connection.setAutoCommit(false);//关闭自动确认
for (String sql : sqls) {
statement.addBatch(sql);//批处理
}
statement.executeBatch();
connection.commit();//确认,提交
return true;
} catch (Exception e) {
try {
if (connection!=null) {
connection.rollback();
}
} catch (SQLException e1) {
logger.debug(e1.getMessage(), e1);
}
logger.debug(e.getMessage(), e);
} finally {//释放资源
close(statement,connection);
}
return false;
}
参数列表为所有要处理事务的SQL命令,成功处理后返回TRUE。