事务(Transaction)
事务:是逻辑上的一组操作由一系列对系统中数据进行访问与更新的操作所组成的一个 程序执行逻辑单元(Unit) 特点是:要么都执行,要么都不执行 目的:是保证数据的完整性
简单来说:事务中的语句执行中如果没有出现错误,就将所有SQL语句执行,如果中间有任一语句出现错误,之前执行的所有SQL语句都会进行逆操作即回滚过来
begin tran;
update bank set money = money-100 where name = '张三';
update bank set money = money+100 where name = '李四';
commit tran;
注释:
tran 是 Transaction 的简写,可通用
事务回滚:
1)假设张三卡里只有30,转账100就会出错,整个事务中的语句都不会执行
2)假设李四没有收到或转账来的数额不对,之前张三的转换语句就会回滚相当于没有转账事务的4大特性:
原子性:事务必须是原子工作单元,对于其数据修改,要么全都执行,要么全都不执行
一致性:事务完成时,必须使所有的数据都保持一致状态,执行前后数据还是一样
如:张三向李四转100元,转账前和转账后的数据是正确的状态,这就叫一致性;如果出现张三转出100元,李四账号没有增加100元这就出现了数据错误,就没有达到一致性
隔离性:一个事务的执行不能被其他事务干扰即多个用户并发访问数据库时数据不受影响
持久性:事务完成之后,它对于系统的影响是永久性的,该修改即使出现系统故障也会一直保持
事务的应用格式
begin tran
--声明一个变量,用于下面语句的判断
--确定事务中的SQL语句最终是执行还是回滚
--要执行的SQL语句
if 判断变量的结果
commit tran --结果为真 执行
else
rollback tran --结果为假 回滚示例:张三向李四转账(默认各有1000块钱)
1 创建示例表 bank,字段 BId(卡号) BName(用户名) BMoney(金额)
--1创建示例表 bank
USE School;
CREATE TABLE Bank
(
BId INT IDENTITY(1,1) PRIMARY KEY,--卡号
BName VARCHAR(10), --用户名
BMoney INT DEFAULT(1000) --金额
)
--添加检查约束,相当于每个账户必须预留10块钱
alter table dbo.Bank ADD CONSTRAINT CH_bank check(BMoney >=10)
--插入数据
INSERT INTO Bank(BName)
SELECT N'张三' UNION
SELECT N'李四'
SELECT * FROM Bank2 创建/测试事务应用
--查看执行事务之前的数据
SELECT * FROM Bank
--创建/测试事务应用
BEGIN TRAN
DECLARE @rmb INT=100
DECLARE @errorTimes INT --错误次数
SET @errorTimes=0 --设置错误次数为0
--编写要执行转账的SQL语句
UPDATE Bank SET BMoney=BMoney-@rmb WHERE BName=N'张三'
--@@ERROR如果执行上面SQL语句有错误
--@@ERROR就会大于 0
SET @errorTimes=@errorTimes+@@ERROR
UPDATE Bank SET BMoney=BMoney+@rmb WHERE BName=N'李四'
SET @errorTimes=@errorTimes+@@ERROR
--判断@errorTimes是否等于0
IF @errorTimes=0 --没有错误
COMMIT TRAN --执行事务中的SQL语句
ELSE
ROLLBACK TRAN --回滚事务中的SQL语句
--查看执行事务后的数据
SELECT * FROM Bank
将变量值变为 @rmb=2000 自行测试结果注意事项:这里使用了全局变量@@error,具体用法之前说过不再赘述
存储过程加事务
1 创建转账事务的存储过程
CREATE PROC usp_bank_transfer
@outname VARCHAR(10),--转出账户
@inname VARCHAR(10),--转入账户
@tranmoney INT,--转账金额
@isSuccese BIT OUTPUT --输出参数
--标示符,表示转账是否成功:0 失败 1 成功
AS
BEGIN
DECLARE @errortimes INT
SET @errortimes=0 --默认没有错误
SET @isSuccese=0 --默认返回 false
BEGIN TRAN
BEGIN TRY
UPDATE Bank SET BMoney=BMoney-@tranmoney WHERE BName=@outname
SET @errorTimes=@errorTimes+@@ERROR
UPDATE Bank SET BMoney=BMoney+@tranmoney WHERE BName=@inname
SET @errorTimes=@errorTimes+@@ERROR
IF @errortimes=0
BEGIN
COMMIT TRAN --执行上面的转账SQL语句
SET @isSuccese=1 --返回转账成功的标示符
END
ELSE
ROLLBACK TRAN
END TRY
BEGIN CATCH
ROLLBACK TRAN
END CATCH
END
注释:以上SQL语句只为演示存储过程加事务是用法
实际开发中会在执行SQL语句前将所有参数数据进行检查
如转账预留金额不能少于 10 2 添加引用,编写配置文件信息,编写窗体的加载事件,将数据实时显示
//提取在方法中,dt 最好声明在方法内部
DataTable dt = null;
private void Form1_Load(object sender, EventArgs e)
{
//调用加载数据的方法
LoadData();
}
//提取为一个方法方便重用
private void LoadData()
{
string sql = "select * from bank";
dt = Helper.SQLHelper.ExecuteDataTable(sql);
dataGridView1.DataSource = dt;
}3 为"转账"按钮添加单击事件,每次转账后重新查询数据显示
private void btnTran_Click(object sender, EventArgs e)
{
//自行编写检测三个文本框中值是否符合具体需要
//设置存储过程的参数信息
SqlParameter[] ps = {
new SqlParameter("@outname",txtTranOut.Text),
new SqlParameter("@inname",txtTranIn.Text),
new SqlParameter("@tranmoney",txtRMB.Text),
new SqlParameter("@isSuccese",SqlDbType.Bit)
};
//设置输出参数
ps[3].Direction = ParameterDirection.Output;
//调用存储过程方法
Helper.SQLHelper.SP_ExecuteNonQuery("usp_bank_transfer",ps);
//获取并判断输出参数的值 0 失败 1 成功
bool b = Convert.ToBoolean(ps[3].Value);
if (b)
{
MessageBox.Show("转账成功");
}
else
{
MessageBox.Show("转账失败");
}
//转账不论成功/失败都重新查询绑定数据显示当前各个账户中的金额
LoadData();
}