Mobile Menu Will Come Here.
隐藏
柏港 asp.net(c#)

C#Dappera帮助类

发布：2023/12/7 19:20:13作者：管理员 来源：本站 浏览次数：390

 internal class DapperHelper
    {

        //使用单例模式
        private static DapperHelper _Singleton = null;
        static SqlSugar.DbType dbtype = SqlSugar.DbType.SqlServer;
         static string ConnectionString = string.Empty;
        private static object Singleton_Lock = new object();
        public static DapperHelper Init(SqlSugar.DbType dbtype = SqlSugar.DbType.SqlServer)
        {
            if (_Singleton == null) //双if +lock
            {
                lock (Singleton_Lock)
                {
                    if (_Singleton == null)
                    {
                        //创建对象
                        _Singleton = new DapperHelper(dbtype);
                    }
                }
            }
            return _Singleton;
        }
        public DapperHelper(SqlSugar.DbType dbtype)
        {
            if (dbtype == SqlSugar.DbType.SqlServer)
            {
                DapperHelper.ConnectionString = ConnTools.init().GetSqlServerConn();
            }
            else if (dbtype == SqlSugar.DbType.Oracle)
            {
                DapperHelper.ConnectionString = ConnTools.init().GetOracleConn();
            }
            DapperHelper.dbtype = dbtype;
        }

        /// <summary>
        /// 添加.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入实体类型.</param>
        /// <returns>int.</returns>
        public int Add<T>(string sql, T t)
                where T : class
        {
            return Add<T>(sql, t,ConnectionString);
        }

        /// <summary>
        /// 添加.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入实体类型.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Add<T>(string sql, T t, string ConnectionString)
                where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }
        /// <summary>
        /// 批量添加.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <returns>int.</returns>
        public int Add<T>(string sql, List<T> t)
            where T : class
        {
            return Add<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 批量添加.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Add<T>(string sql, List<T> t, string ConnectionString)
            where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }

        /// <summary>
        /// 删除.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入实体类型.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Delete<T>(string sql, T t)
                  where T : class
        {
            return Delete<T>(sql, t, ConnectionString)
;        }
        /// <summary>
        /// 删除.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入实体类型.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Delete<T>(string sql, T t, string ConnectionString)
                  where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }

        /// <summary>
        /// 批量删除.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <returns>int.</returns>
        public int Delete<T>(string sql, List<T> t)
                  where T : class
        {
            return Delete<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 批量删除.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Delete<T>(string sql, List<T> t, string ConnectionString)
                  where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }

        /// <summary>
        /// 修改.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入实体类型.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Update<T>(string sql, T t, string ConnectionString)
                  where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }
        /// <summary>
        /// 批量修改.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <returns>int.</returns>
        public int Update<T>(string sql, List<T> t)
                  where T : class
        {
            return Update<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 批量修改.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>int.</returns>
        public int Update<T>(string sql, List<T> t, string ConnectionString)
                  where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Execute(sql, t);
            }
        }

        /// <summary>
        /// 查询.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <returns>泛型类.</returns>
        public List<T> Query<T>(string sql)
                 where T : class
        {
            return Query<T>(sql, ConnectionString);
        }
        /// <summary>
        /// 查询.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>泛型类.</returns>
        public List<T> Query<T>(string sql, string ConnectionString)
                 where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Query<T>(sql).ToList();
            }
        }
        /// <summary>
        /// 查询指定数据.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <returns>类.</returns>
        public T Query<T>(string sql, T t)
                 where T : class
        {
            return Query<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 查询指定数据.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="t">传入泛型类.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>类.</returns>
        public T Query<T>(string sql, T t, string ConnectionString)
                 where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Query<T>(sql, t).SingleOrDefault();
            }
        }
        /// <summary>
        /// 查询多个数据
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql"></param>
        /// <param name="t"></param>
        /// <returns></returns>
        public List<T> QueryList<T>(string sql, T t)
             where T : class
        {
            return QueryList<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 查询多条数据
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">查询语句</param>
        /// <param name="t">模型</param>
        /// <param name="ConnectionString">数据库连接字符串</param>
        /// <returns></returns>
        public List<T> QueryList<T>(string sql, T t, string ConnectionString)
               where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Query<T>(sql, t).ToList();
            }
        }
        /// <summary>
        /// 查询数据返回datatable
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql"></param>
        /// <param name="t"></param>
        /// <returns></returns>
        public DataTable QueryDataTable<T>(string sql, T t)
               where T : class
        {
            return QueryDataTable<T>(sql, t, ConnectionString);
        }

        public DataTable QueryDataTable<T>(string sql, T t, string ConnectionString)
                 where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Query<DataTable>(sql, t).SingleOrDefault();
            }
        } /// <summary>
          /// 查询的in操作.
          /// </summary>
          /// <typeparam name="T">实体类型.</typeparam>
          /// <param name="sql">传入sql执行语句.</param>
          /// <returns>泛型类.</returns>
        public List<T> Query<T>(string sql, int[] ids)
                where T : class
        {
            return Query<T>(sql, ids, ConnectionString)
  ;        }
        /// <summary>
        /// 查询的in操作.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        /// <returns>泛型类.</returns>
        public List<T> Query<T>(string sql, int[] ids, string ConnectionString)
                where T : class
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                return connection.Query<T>(sql, new { ids }).ToList();
            }
        }
        /// <summary>
        /// 多语句操作.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        public void QueryMultiple<T>(string sql, T t)
        {
            return QueryMultiple<T>(sql, t, ConnectionString);
        }
        /// <summary>
        /// 多语句操作.
        /// </summary>
        /// <typeparam name="T">实体类型.</typeparam>
        /// <param name="sql">传入sql执行语句.</param>
        /// <param name="ConnectionString">链接字符串.</param>
        public void QueryMultiple<T>(string sql, T t, string ConnectionString)
        {
            using (IDbConnection connection = new SqlConnection(ConnectionString))
            {
                var multiReader = connection.QueryMultiple(sql);
                var userInfo = multiReader.Read<T>();

                multiReader.Dispose();
            }
        }
    }
}

代码中用到的枚举

public enum DbType
    {
        MySql = 0,
        SqlServer = 1,
        Sqlite = 2,
        Oracle = 3,
        PostgreSQL = 4,
        Dm = 5,
        Kdbndp = 6,
        Oscar = 7,
        MySqlConnector = 8,
        Access = 9,
        Custom = 900
    }


　C# Dapper：高效ORM框架的完美选择
C#Dapper 帮助类　

柏港为您推荐了一些相关资讯

C#DataTable帮助类 C#工具：ASP.net 调用MySQL 帮助类（包括存储过程调用） c# mysql 异步帮助类 c#连接MySQL/Oracle数据库的帮助类 C#写一套最全的MySQL帮助类（包括增删改查） c# mysql 帮助类 类（Class）-uni-app 教程 生成类库映射文件-ThinkPHP V5 创建类库文件-ThinkPHP V5 类库-ThinkPHP V5

© Copyright 2014 - 2024 柏港建站平台 ejk5.com. 渝ICP备16000791号-4