欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

通过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。