source/Repid.Dapper/DapperContext.cs

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

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

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Linq;
using System.Text;
using Dapper;
using DapperExtensions;

namespace Repid.Dapper
{
    /// <summary>
    /// 数据Dapper工具
    /// </summary>
    public class DapperContext : IDisposable
    {
        /// <summary>
        /// 数据连接
        /// </summary>
        private IDbConnection _dbConnecttion { get; set; }

        /// <summary>
        /// 数据事务
        /// </summary>
        private IDbTransaction _dbTransaction { get; set; }

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="dbConnecttion">连接对象</param>
        public DapperContext(IDbConnection dbConnecttion)
        {
            _dbConnecttion = dbConnecttion;
        }

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="connString">连接字符串</param>
        /// <param name="providerName">提供商名称</param>
        public DapperContext(string connString, string providerName)
        {
            DbProviderFactory dbFactory = DbProviderFactories.GetFactory(providerName);

            _dbConnecttion = dbFactory.CreateConnection();

            _dbConnecttion.ConnectionString = connString;

            _dbConnecttion.Open();
        }

        /// <summary>
        /// 设置事务
        /// </summary>
        /// <param name="dbTransaction">事务对象</param>
        public void BeginTransaction(IDbTransaction dbTransaction)
        {
            _dbTransaction = dbTransaction;
        }