Transaction/TransactionScope.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using PWMIS.DataProvider.Adapter;
using PWMIS.DataProvider.Data;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Text;

namespace OrmTransaction
{
    public class TransactionScope:IDisposable
    {
        private static AdoHelper  db = MyDB.GetDBHelper();

        private Transaction transaction = Transaction.Current;


        public bool Completed { get; private set; }


        public TransactionScope(IsolationLevel isolationLevel = IsolationLevel.ReadCommitted)
        {
            if (null == transaction)
            {
                IDbConnection connection = db.GetDbConnection();
                connection.Open();
                IDbTransaction dbTransaction = connection.BeginTransaction(isolationLevel);
                Transaction.Current = new CommittableTransaction(dbTransaction);
            }
            else
            {
                Transaction.Current = transaction.DependentClone();
            }           
        }

        public void Complete()
        {
            this.Completed = true;
        }

        public void Dispose()
        {
            try
            {
                Transaction current = Transaction.Current;

                if (!this.Completed)
                {
                    current.Rollback();
                }
                CommittableTransaction committableTransaction = current as CommittableTransaction;
                if (null != committableTransaction)
                {
                    if (this.Completed)
                    {
                        committableTransaction.Commit();
                    }
                    committableTransaction.Dispose();

                }