Dapper 帮助类


Dapper 帮助类

    /// <summary>
    /// Dapper 工具类
    /// </summary>
    public static class DapperHelper
    {

        static string sqlconnection = System.Configuration.ConfigurationManager.ConnectionStrings["sqlServer"].ToString();

        private static SqlConnection OpenConnection()
        {

            SqlConnection connection = new SqlConnection(sqlconnection);  //这里sqlconnection就是数据库连接字符串
            connection.Open();
            return connection;
        }

        #region 查询数据
        /// <summary>
        /// 查询数据
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">sql</param>
        /// <param name="entity">T</param>
        /// <returns></returns>
        public static List<T> Query<T>(string sql, T entity)
        {
            List<T> list = new List<T>();
            using (IDbConnection conn = OpenConnection())
            {

                list = conn.Query<T>(sql, entity).ToList();

            }
            return list;
        }


        /// <summary>
        /// 查询数据
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">sql</param>
        /// <param name="obj">new {}</param>
        /// <returns></returns>
        public static List<T> Query<T>(string sql, object obj)
        {
            List<T> list = new List<T>();
            using (IDbConnection conn = OpenConnection())
            {
                list = conn.Query<T>(sql, obj).ToList();
            }
            return list;
        }

        /// <summary>
        /// 查询第一行第一列的数据
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">sql</param>
        /// <param name="obj">new {}</param>
        /// <returns></returns>
        public static T QueryScalar<T>(string sql, object obj)
        {

            T result = default(T);

            using (IDbConnection conn = OpenConnection())
            {
                result = conn.ExecuteScalar<T>(sql, obj);
            }
            return result;
        }
        #endregion

        #region 执行增,删,改 
        /// <summary>
        /// 执行增,删,改 
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">sql</param>
        /// <param name="entity"></param>
        /// <returns></returns>
        public static int NonQuery<T>(string sql, T entity)
        {
            int res = 0;
            using (IDbConnection conn = OpenConnection())
            {
                res = conn.Execute(sql, entity);
            }
            return res;
        }

        /// <summary>
        /// 执行增,删,改 
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql">sql</param>
        /// <param name="entity"></param>
        /// <returns></returns>
        public static int NonQuery(string sql, object obj)
        {
            int res = 0;
            using (IDbConnection conn = OpenConnection())
            {
                res = conn.Execute(sql, obj);
            }
            return res;
        }
        #endregion

    }

调用实例1

	Role role =new Role();
	// 给role赋值ID,RoleName,Description,CreateTime
	string sql = "INSERT INTO [Role] ([ID],[RoleName],[Description],					[CreateTime]) VALUES(NEWID(),@RoleName,@Description,getdate())";

    int num = DapperHelper.NonQuery<Role>(sql, role);

调用实例2

	string sql = "INSERT INTO [Role] ([ID],[RoleName],[Description],					[CreateTime]) VALUES(NEWID(),@RoleName,@Description,getdate())";

    int num = DapperHelper.NonQuery<Role>(sql, new {ID=ID,RoleName=RoleName,Description=Description,CreateTime=CreateTime});

目前只封装了这些方法需要的话以后再写

感兴趣的可以加QQ群:765907694 一起交流,探讨技术问题


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM