在很多情况下，事务是个很有用的东西，可以把一系列的操作组合成一个原子粒度的操作，一旦组合中某个地方出错，可以整个干净的进行滚回，不会留下脏数据；除此之外，事务还能提高批量操作的效率，如在本地SQLite数据库里面，批量插入1万条数据，那么使用事务和没有使用事务，速度上至少差别几十到上百倍的差异。既然事务有完整性和速度性的差异，因此，基于上述原因，我们在很多情况下最好使用事务进行操作。本文主要介绍在开发框架中如何整合事务的操作，并介绍在各个分层中的事务使用案例。
由于我介绍的相关框架，主要是采用了微软的Enterprise Library的数据库访问模块，因此它能够很好抽象各种数据库的事务，以适应各种不同数据库的事务处理。使用微软的Enterprise Library模块，可以很好支持SQLSever、Oracle、Mysql、Access、SQLite等数据库。
1、数据访问层中的事务操作
1.1 数据访问层的事务接口定义
由于使用事务操作，因此在底层的模块里面，也就是这里的数据访问层，一般需要一个事务对象的参数。如下代码是一个数据访问层的接口定义。
/// <summary>
/// 数据访问层的接口
/// </summary>
public interface IBaseDAL<T> where T : BaseEntity
{
/// <summary>
/// 插入指定对象到数据库中
/// </summary>
/// <param name="obj">指定的对象</param>
/// <param name="trans">事务对象</param>
/// <returns>执行成功返回True</returns>
bool Insert(T obj, DbTransaction trans = null);
/// <summary>
/// 根据指定对象的ID,从数据库中删除指定对象
/// </summary>
/// <param name="key">指定对象的ID</param>
/// <param name="trans">事务对象</param>
/// <returns>执行成功返回<c>true</c>，否则为<c>false</c>。</returns>
bool Delete(object key, DbTransaction trans = null);
/// <summary>
/// 更新对象属性到数据库中
/// </summary>
/// <param name="obj">指定的对象</param>
/// <param name="primaryKeyValue">主键的值</param>
/// <param name="trans">事务对象</param>
/// <returns>执行成功返回<c>true</c>，否则为<c>false</c>。</returns>
bool Update(T obj, object primaryKeyValue, DbTransaction trans = null);
/// <summary>
/// 查询数据库,检查是否存在指定ID的对象
/// </summary>
/// <param name="key">对象的ID值</param>
/// <param name="trans">事务对象</param>
/// <returns>存在则返回指定的对象,否则返回Null</returns>
T FindByID(object key, DbTransaction trans = null);
.....................//其他操作
}
从上面的代码上，我们可以看到，里面的增删改查等操作，最后都带一个trans的事务对象参数，这个参数默认为null，也就是可选参数的做法，这个方法就提供了两个重载的方法供我们使用。
看到这里，可能有些人提出疑问，为什么查找方法也传入事务对象，这个因为事务是一个排斥性操作，一旦启动了事务，可能这个表的其他操作会被锁定，但在这个事务内操作确实可以允许的，如果你使用SQLite这种单机版的数据库，在一个地方采用事务操作一个表，在事务内部接着不使用事务进行表的任何操作将不会被允许，数据库提示出错信息的。
基于这个原因，所有表操作的接口，都应该提供事务性的操作接口，也就是提供一个事务性的对象参数。在接口的实现里面，判断事务对象是否为空，然后进行相应的处理即可。
1.2 在DAL层自定义函数的事务操作
由于在IBaseDAL里面已经定义了很多事务性的接口，因此数据访问层的基类里面也已经实现了很多相关的基础操作。
因此数据访问层DAL层里面，如自己定义的实现函数，调用这些基础函数进行处理就可以了。自定义函数对事务的操作处理，代码如下所示。
/// <summary>
/// 调整客户的组别
/// </summary>
/// <param name="customerId">客户ID</param>
/// <param name="groupIdList">客户分组Id集合</param>
/// <returns></returns>
public bool ModifyCustomerGroup(string customerId, List<string> groupIdList)
{
bool result = false;
DbTransaction trans = base.CreateTransaction();
if (trans != null)
{
string sql = string.Format("Delete from T_CRM_CustomerGroup_Customer where Customer_ID='{0}' ", customerId);
base.SqlExecute(sql, trans);
foreach (string groupId in groupIdList)
{
sql = string.Format("Insert into T_CRM_CustomerGroup_Customer(Customer_ID,CustomerGroup_ID) values('{0}', '{1}') ", customerId, groupId);
base.SqlExecute(sql, trans);
}
try
{
trans.Commit();
result = true;
}
catch
{
trans.Rollback();
throw;
}
}
return result;
}
2、业务逻辑层的事务操作
业务逻辑层BLL层是对数据访问层的更高一层的封装，它也相应提供相应的事务对象接口，以方便外部的调用。
它的业务类里面，自定义函数对事务的调用操作如下所示。
/// <summary>
/// 把报价单转换为销售订单
/// </summary>
/// <param name="quotationNo">报价单编号</param>
/// <returns></returns>
public bool ConvertToOrder(string orderNo, int userId)
{
bool result = false;
DbTransaction trans = baseDal.CreateTransaction();
if (trans != null)
{
SellInfo sellInfo = ConvertSellInfo(orderNo, userId, trans);
List<OrderDetailInfo> detailList = new List<OrderDetailInfo>();
if (sellInfo != null)
{
detailList = ConvertOrderDetal(sellInfo, orderNo, trans);
}
bool success = BLLFactory<Sell>.Instance.Insert(sellInfo, trans);
if (success)
{
foreach (OrderDetailInfo info in detailList)
{
BLLFactory<OrderDetail>.Instance.Insert(info, trans);
}
}
try
{
trans.Commit();
result = true;
}
catch
{
trans.Rollback();
throw;//重新抛出异常
}
}
return result;
}
另一例子如下所示。
/// <summary>
/// 删除报价单及明细信息
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public bool DeleteQuotationRelated(string id)
{
bool result = false;
DbTransaction trans = CreateTransaction();
if (trans != null)
{
QuotationInfo info = baseDal.FindByID(id, trans);
if (info != null)
{
List<QuotationDetailInfo> detailList = BLLFactory<QuotationDetail>.Instance.FindByOrderNo(info.HandNo, trans);
foreach (QuotationDetailInfo detailInfo in detailList)
{
BLLFactory<QuotationDetail>.Instance.Delete(detailInfo.ID, trans);
}
//最后删除主表订单数据
baseDal.Delete(id, trans);
try
{
trans.Commit();
result = true;
}
catch (Exception ex)
{
trans.Rollback();
LogTextHelper.Error(ex);
throw;
}
}
}
return result;
}
}
3、Winform界面层对事务的调用
由于Winform界面层，直接调用BLL层的相应接口，进行数据的操作的，因此我们也可以在界面层创建相应的事务对象，然后在界面层操作事务。
界面层调用事务处理，操作代码如下所示。
using (DbTransaction trans = BLLFactory<Function>.Instance.CreateTransaction())
{
try
{
if (trans != null)
{
bool sucess = BLLFactory<Function>.Instance.Insert(mainInfo, trans);
if (sucess)
{
FunctionInfo subInfo = null;
int sortCodeIndex = 1;
#region 子功能操作
if (chkAdd.Checked)
{
subInfo = CreateSubFunction(mainInfo);
subInfo.SortCode = (sortCodeIndex++).ToString("D2");
subInfo.ControlID = string.Format("{0}/Add", mainInfo.ControlID);
subInfo.Name = string.Format("添加{0}", mainInfo.Name);
BLLFactory<Function>.Instance.Insert(subInfo, trans);
}
if (chkDelete.Checked)
{
subInfo = CreateSubFunction(mainInfo);
subInfo.SortCode = (sortCodeIndex++).ToString("D2");
subInfo.ControlID = string.Format("{0}/Delete", mainInfo.ControlID);
subInfo.Name = string.Format("删除{0}", mainInfo.Name);
BLLFactory<Function>.Instance.Insert(subInfo, trans);
}
......................//其他事务操作
#endregion
trans.Commit();
ProcessDataSaved(this.btnSave, new EventArgs());
//this.DialogResult = System.Windows.Forms.DialogResult.OK;
MessageDxUtil.ShowTips("保存成功");
}
else
{
MessageDxUtil.ShowTips("保存失败");
}
}
}
catch (Exception ex)
{
if (trans != null)
{
trans.Rollback();
}
LogTextHelper.Error(ex);
MessageDxUtil.ShowError(ex.Message);
}
}
以上就是我对不同分层中使用事务对象进行各种操作的处理，由于事务对象会对表进行某种锁定操作，因此数据库的整体性能可能有所降低，但是在保证某种组合操作的原子性，以及批量数据库操作这两种方式，该出手时还是要出手，这样能更好提高完整性和处理的高效性。
