SQLServer数据库之.NETCore Sqlserver下对Dapper的扩展支持-职坐标

SQLServer数据库之.NETCore Sqlserver下对Dapper的扩展支持

小标 2018-08-31 来源：阅读 1749 评论 0

摘要：本文主要向大家介绍了SQLServer数据库之.NETCore Sqlserver下对Dapper的扩展支持，通过具体的内容向大家展现，希望对大家学习SQLServer数据库有所帮助。

本文主要向大家介绍了SQLServer数据库之.NETCore Sqlserver下对Dapper的扩展支持，通过具体的内容向大家展现，希望对大家学习SQLServer数据库有所帮助。

这里我们自定义一个IServiceCollection的扩展，例如下面我的扩展

services.AddDapperContext(dapperoptions =>
            {
                dapperoptions.ConnectionString = "Data Source=192.168.0.42;Initial Catalog=NET.Core;User ID=sa;password=lym123!@#;Integrated Security=false";
            });

添加了对数据库连接字符串设置，当然你也可以设置更多的参数，委托等等，这里简单演示下自定义dapper下的数据库访问，下面是扩展设置

1  public static class DapperMiddlewareExtension
2     {
3
4         public static IServiceCollection AddDapperContext(this IServiceCollection serviceCollection, Action optionsAction = null, ServiceLifetime contextLifetime = ServiceLifetime.Scoped, ServiceLifetime optionsLifetime = ServiceLifetime.Scoped) where TDapperContext : DapperContext
5         {
6             serviceCollection.Configure(optionsAction);
7             serviceCollection.AddTransient();
8             serviceCollection.AddSingleton();
9             return serviceCollection;
10         }
11         ///

12 /// 添加服务
13 ///

14 ///

15 ///

16 ///

17 ///

18 ///

19 public static IServiceCollection AddDapperContext(this IServiceCollection serviceCollection, Action

optionsAction = null, ServiceLifetime contextLifetime = ServiceLifetime.Scoped, ServiceLifetime optionsLifetime = ServiceLifetime.Scoped)
20         {
21             serviceCollection.Configure(optionsAction);
22             serviceCollection.AddTransient();
23             serviceCollection.AddSingleton();
24             return serviceCollection;
25         }

这里DI相关的数据库访问类，这里最终要的一点就是我们在startup中设置的连接的字符串，在数据库DI类中怎么得到来访问数据库呢？
serviceCollection.Configure(optionsAction); 将委托Action配置到IOptions接口中下面来看下我们的DapperContext

public class DapperContext
    {
        DapperOptions _dapperOptions;
        IDataProvider _dataProvider;
        public DapperContext(IOptions options, IDataProvider dataProvider)
        {
            _dapperOptions = options.Value;
            _dataProvider = dataProvider;
        }



        #region 创建Dapper相关连接

        private IDbConnection CreateConnection(bool ensureClose = true)
        {

            var conn = _dataProvider.CreateConnection();
            conn.ConnectionString = _dapperOptions.ConnectionString;
            conn.Open();

            return conn;
        }
        private IDbConnection _connection;
        private IDbConnection Connection
        {
            get
            {
                if (_connection == null || _connection.State != ConnectionState.Open)
                {
                    _connection = CreateConnection();
                }

                return _connection;
            }
        }

        public void insertTest(string sql)
        {

            var conn = Connection;
            try
            {
                conn.Execute(sql);
            }

            finally
            {
                if (_connection != null)
                {
                    _connection.Close();
                    _connection = null;
                }
            }

        }

在写好相关的数据库访问连接类处理建立自己的业务服务，这里写的比较简单

public interface ICustomDapperContext
    {

        void Insert(string sql);

    }

public class CustomDapperContext : ICustomDapperContext
    {
        DapperContext _dapperContext;
        public CustomDapperContext(DapperContext dapperContext)
        {
            _dapperContext = dapperContext;
        }
        public void Insert(string sql)
        {
            _dapperContext.insertTest(sql);
        }
    }

然后在Controller层DI下

ICustomDapperContext _context;
        public HomeController(ICustomDapperContext context)
        {
            _context = context;
        }
        public IActionResult Index()
        {
          _context.Insert("insert into Tb_UserLogin(UserName,UserPwd,[Order],IsDelete) values (‘UserName‘,‘UserName‘,0,0)");
            return View();
        }

执行后数据库添加成功

下面是我自定义的中间件的相关类

本文由职坐标整理并发布，希望对同学们学习SQL Server有所帮助，更多内容请关注职坐标数据库SQL Server数据库频道！

软件测试数据库知识数据库设计论文数据库云

本文由 @小标发布于职坐标。未经许可，禁止转载。