C# 访问 SQL SERVER 数据库帮助类

写一个属于自己的数据库帮助类，温故而知新~~

数据库操作核心部分：

    /// <summary>
    /// 数据库操作基类
    /// </summary>
    public class DbServiceBase : IDisposable
    {
        #region 私有字段

        /// <summary>
        /// 自动释放数据库连接
        /// </summary>
        private bool AutoClearConnection = true;

        /// <summary>
        /// 数据库连接字符串
        /// </summary>
        private string ConnectionStrings;

        /// <summary>
        /// 数据库连接对象
        /// </summary>
        private SqlConnection conn = null;

        /// <summary>
        /// 事务对象
        /// </summary>
        private SqlTransaction tran = null;

        #endregion

        #region 私有方法

        /// <summary>
        /// 创建数据库连接
        /// </summary>
        /// <returns></returns>
        private void CreateConnection()
        {
            if (conn.IsNull())
            {
                conn = new SqlConnection(ConnectionStrings);
            }
            if (conn.State != ConnectionState.Open)
            {
                conn.Open();
            }
        }

        /// <summary>
        /// 释放数据库连接
        /// </summary>
        private void ClearConnection()
        {
            if (!tran.IsNull())
            {
                tran = null;
            }
            if (!conn.IsNull())
            {
                SqlConnection.ClearPool(conn); //用于清除每次的连接，防止已经进行的数据库连接进入sleeping而导致连接用户数增加
                conn.Close();
                conn.Dispose();
                conn = null;
            }
        }

        /// <summary>
        /// 获得表名
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <returns>表名</returns>
        private string GetTableName<T>() where T : class
        {
            string tableName = typeof(T).Name;
            return tableName;
        }

        /// <summary>
        /// 获得 where sql 语句
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="where">筛选条件</param>
        /// <param name="arrListSqlPara">SqlParameter参数</param>
        /// <returns>sql语句</returns>
        private string GetWhereSql<T>(Expression<Func<T, bool>> where, ref ArrayList arrListSqlPara) where T : class
        {
            List<SqlParaModel> listSqlParaModel = new List<SqlParaModel>();
            string whereSql = where == null ? "" : LambdaToSqlHelper.GetWhereSql(where, listSqlParaModel);
            for (var i = 0; i < listSqlParaModel.Count; i++)
            {
                var key = listSqlParaModel[i].name;
                var val = listSqlParaModel[i].value;
                arrListSqlPara.Add(new SqlParameter("@" + key, val));
            }
            return whereSql;
        }

        /// <summary>
        /// 获得查询字段列表
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="field">查询字段</param>
        /// <returns>查询字段</returns>
        private string GetQueryField<T>(Expression<Func<T, object>> field) where T : class
        {
            string queryField = field == null ? "*" : LambdaToSqlHelper.GetQueryField(field);
            return queryField;
        }

        /// <summary>
        /// 获得 order sql 语句
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="orderBy">排序</param>
        /// <returns>sql语句</returns>
        private string GetOrderBySql<T>(Expression<Func<IQueryable<T>, IOrderedQueryable<T>>> orderBy) where T : class
        {
            string orderBySql = orderBy == null ? "" : LambdaToSqlHelper.GetOrderBySql(orderBy);
            return orderBySql;
        }

        /// <summary>
        /// 获得 insert sql 语句
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="model">对象实例</param>
        /// <param name="arrSqlPara">SqlParameter参数</param>
        /// <returns>sql语句</returns>
        private string GetCreateSql<T>(object model, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            StringBuilder sbInsColName = new StringBuilder();
            StringBuilder sbInsColVal = new StringBuilder();
            string tableName = GetTableName<T>();
            var dic = ExtendMethod.Foreach(model);
            foreach (var item in dic)
            {
                var val = item.Value;
                if (!val.IsNull())
                {
                    var key = item.Key;
                    sbInsColName.Append(string.Format("{0},", key));
                    sbInsColVal.Append(string.Format("@{0},", key));
                    arrListSqlPara.Add(new SqlParameter("@" + key, val));
                }
            }
            sbInsColName.Remove(sbInsColName.Length - 1, 1);
            sbInsColVal.Remove(sbInsColVal.Length - 1, 1);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = "insert into {0} ({1}) values ({2})".FormatWith(tableName, sbInsColName.ToString(), sbInsColVal.ToString());
            return resultSql;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="model">对象实例</param>
        /// <param name="arrListSqlPara">SqlParameter参数</param>
        /// <returns>sql语句</returns>
        private string GetUpdateSqlParameter(object model, ref ArrayList arrListSqlPara)
        {
            string strUpdSql = string.Empty;
            StringBuilder sbUpdCol = new StringBuilder();
            var dic = ExtendMethod.Foreach(model);
            foreach (var item in dic)
            {
                var val = item.Value;
                var key = item.Key;
                sbUpdCol.Append(string.Format("{0} = @{1},", key, key));
                arrListSqlPara.Add(new SqlParameter("@" + key, val));
            }
            sbUpdCol.Remove(sbUpdCol.Length - 1, 1);
            strUpdSql = sbUpdCol.ToString();
            return strUpdSql;
        }

        /// <summary>
        /// 获得 update sql 语句
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="model">对象实例</param>
        /// <param name="where">筛选条件</param>
        /// <param name="arrSqlPara">SqlParameter参数</param>
        /// <returns>sql语句</returns>
        private string GetUpdateSql<T>(object model, Expression<Func<T, bool>> where, ref SqlParameter[] arrSqlPara) where T : class
        {
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = string.Empty;
            string updateSql = string.Empty;
            string whereSql = string.Empty;
            string resultSql = string.Empty;
            tableName = GetTableName<T>();
            updateSql = GetUpdateSqlParameter(model, ref arrListSqlPara);
            whereSql = GetWhereSql<T>(where, ref arrListSqlPara);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = string.Format("update {0} set {1} {2}", tableName, updateSql, whereSql);
            return resultSql;
        }

        /// <summary>
        /// 获得 delete sql 语句
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="where">筛选条件</param>
        /// <param name="arrSqlPara">SqlParameter参数</param>
        /// <returns>sql语句</returns>
        private string GetDeleteSql<T>(Expression<Func<T, bool>> where, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = GetTableName<T>();
            string whereSql = GetWhereSql<T>(where, ref arrListSqlPara); ;
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = string.Format("delete from {0} {1}", tableName, whereSql);
            return resultSql;
        }

        #region 获得 select sql 语句

        private string GetFindListSql<T>(Expression<Func<T, object>> field, Expression<Func<T, bool>> where, Expression<Func<IQueryable<T>, IOrderedQueryable<T>>> orderBy, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = GetTableName<T>();
            string queryField = GetQueryField<T>(field);
            string whereSql = GetWhereSql<T>(where, ref arrListSqlPara);
            string orderBySql = GetOrderBySql<T>(orderBy);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = "select {0} from {1} {2} {3}".FormatWith(queryField, tableName, whereSql, orderBySql);
            return resultSql;
        }

        private string GetPageListSql<T>(int pageIndex, int pageSize, Expression<Func<T, object>> field, Expression<Func<T, bool>> where, Expression<Func<IQueryable<T>, IOrderedQueryable<T>>> orderBy, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = GetTableName<T>();
            string queryField = GetQueryField<T>(field);
            string whereSql = GetWhereSql<T>(where, ref arrListSqlPara);
            string orderBySql = GetOrderBySql<T>(orderBy);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = "select top {0} {1} from (select row_number() over({2}) rownumber,{3} from {4} {5} ) tt_{6} where rownumber  > {7}".FormatWith(pageSize, queryField, orderBySql, queryField, tableName, whereSql, tableName, (pageIndex - 1) * pageSize);
            return resultSql;
        }

        private string GetFindSql<T>(Expression<Func<T, object>> field, Expression<Func<T, bool>> where, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = GetTableName<T>();
            string queryField = GetQueryField<T>(field);
            string whereSql = GetWhereSql<T>(where, ref arrListSqlPara);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = "select {0} from {1} {2}".FormatWith(queryField, tableName, whereSql);
            return resultSql;
        }

        private string GetCountSql<T>(Expression<Func<T, bool>> where, ref SqlParameter[] arrSqlPara) where T : class
        {
            string resultSql = string.Empty;
            ArrayList arrListSqlPara = new ArrayList();
            string tableName = GetTableName<T>();
            string whereSql = GetWhereSql<T>(where, ref arrListSqlPara);
            arrSqlPara = (SqlParameter[])arrListSqlPara.ToArray(typeof(SqlParameter));
            resultSql = "select count(*) from {0} {1}".FormatWith(tableName, whereSql);
            return resultSql;
        }

        #endregion

        #endregion

        #region 事务操作

        /// <summary>
        /// 创建事务
        /// </summary>
        /// <returns></returns>
        public void BeginTransaction()
        {
            tran = conn.BeginTransaction();
        }

        /// <summary>
        /// 提交事务
        /// </summary>
        public void CommitTransaction()
        {
            tran.Commit();
        }

        /// <summary>
        /// 回滚事务
        /// </summary>
        public void RollbackTransaction()
        {
            tran.Rollback();
        }

        #endregion

        #region 释放资源

        /// <summary>
        /// 
        /// </summary>
        public void Dispose()
        {
            //throw new NotImplementedException();
            ClearConnection();
        }

        #endregion

        #region 构造函数

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="_ConnectionStrings">数据库连接字符串</param>
        /// <param name="_AutoClearConnection">单个DML(增删查改)操作后是否释放资源。true释放，false不释放。默认true</param>
        public DbServiceBase(string _ConnectionStrings, bool _AutoClearConnection = true)
        {
            this.ConnectionStrings = _ConnectionStrings;
            this.AutoClearConnection = _AutoClearConnection;
        }

        #endregion

        #region 增删查改

        #region 插入数据

        /// <summary>
        /// 插入数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="model">对象实例</param>
        /// <returns></returns>
        public int Create<T>(object model) where T : class
        {
            int affectedRows = 0;
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetCreateSql<T>(model, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            affectedRows = cmd.ExecuteNonQuery();
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            return affectedRows;
        }

        #endregion

        #region 更新数据

        /// <summary>
        /// 更新数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="model">对象实例</param>
        /// <param name="where">筛选条件</param>
        /// <returns>受影响行数</returns>
        public int Update<T>(object model, Expression<Func<T, bool>> where) where T : class
        {
            int affectedRows = 0;
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetUpdateSql<T>(model, where, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            affectedRows = cmd.ExecuteNonQuery();
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            return affectedRows;
        }

        #endregion

        #region 删除数据

        /// <summary>
        /// 删除数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="where">筛选条件</param>
        /// <returns>受影响行数</returns>
        public int Delete<T>(Expression<Func<T, bool>> where) where T : class
        {
            int affectedRows = 0;
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetDeleteSql<T>(where, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            affectedRows = cmd.ExecuteNonQuery();
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            return affectedRows;
        }

        #endregion

        #region 查询数据

        #region 分页查询数据

        /// <summary>
        /// 分页查询数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="pageIndex">页码</param>
        /// <param name="pageSize">页大小</param>
        /// <param name="field">查询字段</param>
        /// <param name="where">筛选条件</param>
        /// <param name="orderBy">排序</param>
        /// <returns></returns>
        public List<T> PageList<T>(int pageIndex, int pageSize, Expression<Func<IQueryable<T>, IOrderedQueryable<T>>> orderBy, Expression<Func<T, object>> field = null, Expression<Func<T, bool>> where = null) where T : class
        {
            if (orderBy == null)
            {
                throw new Exception("分页必须设置排序方式");
            }
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetPageListSql<T>(pageIndex, pageSize, field, where, orderBy, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            da.Fill(ds);
            da.Dispose();
            da = null;
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            List<T> list = null;
            if (ds.Tables.Count > 0)
            {
                list = ds.Tables[0].DataTableToList<T>();   //DataTable转换为实体对象列表
            }
            return list;
        }

        #endregion

        #region 查询多条数据

        /// <summary>
        /// 查询多条数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="field">查询字段</param>
        /// <param name="where">筛选条件</param>
        /// <param name="orderBy">排序</param>
        /// <returns></returns>
        public List<T> FindList<T>(Expression<Func<T, object>> field = null, Expression<Func<T, bool>> where = null, Expression<Func<IQueryable<T>, IOrderedQueryable<T>>> orderBy = null) where T : class
        {
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetFindListSql<T>(field, where, orderBy, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            da.Fill(ds);
            da.Dispose();
            da = null;
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            List<T> list = null;
            if (ds.Tables.Count > 0)
            {
                list = ds.Tables[0].DataTableToList<T>();   //DataTable转换为实体对象列表
            }
            return list;
        }

        #endregion

        #region 查询单条数据

        /// <summary>
        /// 查询单条数据
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="field">查询字段</param>
        /// <param name="where">筛选条件</param>
        /// <returns></returns>
        public T Find<T>(Expression<Func<T, object>> field = null, Expression<Func<T, bool>> where = null) where T : class
        {
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetFindSql<T>(field, where, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            da.Fill(ds);
            da.Dispose();
            da = null;
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            T model = null;
            if (ds.Tables.Count > 0)
            {
                if (ds.Tables[0].Rows.Count > 0)
                {
                    model = ds.Tables[0].Rows[0].DataRowToEntity<T>();  //DataRow转换为实体对象
                }
            }
            return model;
        }

        #endregion

        #region 返回行数

        /// <summary>
        /// 返回行数
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="where">筛选条件</param>
        /// <returns></returns>
        public int Count<T>(Expression<Func<T, bool>> where = null) where T : class
        {
            var cnt = 0;
            SqlParameter[] arrSqlPara = new SqlParameter[] { };
            var sql = GetCountSql<T>(where, ref arrSqlPara);
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            da.Fill(ds);
            da.Dispose();
            da = null;
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            if (ds.Tables.Count > 0)
            {
                if (ds.Tables[0].Rows.Count > 0)
                {
                    cnt = ds.Tables[0].Rows[0][0].ToInt32();
                }
            }
            return cnt;
        }

        #endregion

        #region 是否存在数据行

        /// <summary>
        /// 是否存在数据行
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="where">筛选条件</param>
        /// <returns></returns>
        public bool Exist<T>(Expression<Func<T, bool>> where = null) where T : class
        {
            var cnt = Count(where);
            return cnt > 0;
        }

        #endregion

        #endregion

        #region ExecuteNonQuery

        /// <summary>
        /// ExecuteNonQuery
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="sql">sql语句</param>
        /// <param name="arrSqlPara">SqlParameter参数</param>
        /// <returns></returns>
        public int ExecuteNonQuery<T>(string sql, params SqlParameter[] arrSqlPara) where T : class
        {
            int affectedRows = 0;
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            affectedRows = cmd.ExecuteNonQuery();
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            return affectedRows;
        }

        #endregion

        #region ExecuteQuery

        /// <summary>
        /// ExecuteQuery
        /// </summary>
        /// <typeparam name="T">类名</typeparam>
        /// <param name="sql">sql语句</param>
        /// <param name="arrSqlPara">SqlParameter参数</param>
        /// <returns></returns>
        public DataSet ExecuteQuery<T>(string sql, params SqlParameter[] arrSqlPara) where T : class
        {
            CreateConnection();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.Parameters.AddRange(arrSqlPara);
            cmd.CommandText = sql;
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            da.Fill(ds);
            da.Dispose();
            da = null;
            if (AutoClearConnection)
            {
                ClearConnection();
            }
            return ds;
        }

        #endregion

        #endregion
    }

针对哪个数据库操作，需要在配置文件中配置连接字符串，可以配置若干个。

public static class DbConnStrKey
    {
        internal static string MaiDb
        {
            get
            {
                return "MaiDb".ValueOfConnectionStrings();
            }
        }
    }

访问数据库的公用入口

    /// <summary>
    /// 用于单个数据库操作
    /// </summary>
    public class QueryService
    {
        /// <summary>
        /// 数据库名
        /// </summary>
        public static DbServiceBase MaiDb
        {
            get
            {
                return new DbServiceBase(DbConnStrKey.MaiDb);
            }
        }
    }

    /// <summary>
    /// 用于一组数据库操作
    /// </summary>
    public class UnitService
    {
        /// <summary>
        /// 数据库名
        /// </summary>
        public static DbServiceBase MaiDb
        {
            get
            {
                return new DbServiceBase(DbConnStrKey.MaiDb, false);
            }
        }

    }

以下是Demo

增

        public static int Add(object model)
        {
            return QueryService.MaiDb.Create<SYS_Resource>(model);
        }

exec sp_executesql N'insert into SYS_Resource (ResoId,ResoParentId,ResoType,ResoName,ResoUrl,ResoDesc,ResoIsShow,ResoOrder) values (@ResoId,@ResoParentId,@ResoType,@ResoName,@ResoUrl,@ResoDesc,@ResoIsShow,@ResoOrder)',N'@ResoId nvarchar(36),@ResoParentId nvarchar(36),@ResoType nvarchar(4),@ResoName nvarchar(4),@ResoUrl nvarchar(4000),@ResoDesc nvarchar(4000),@ResoIsShow bit,@ResoOrder int',@ResoId=N'cbaf5484-cdcb-4511-afee-0abb7937d31d',@ResoParentId=N'89fa1a64-6e49-42b9-b2a7-bd5fce0ea54e',@ResoType=N'page',@ResoName=N'添加资源',@ResoUrl=N'',@ResoDesc=N'',@ResoIsShow=1,@ResoOrder=0
go

删

        public static ServiceResult Del(string ResoId)
        {
            var result = new ServiceResult();
            using (var dbs = UnitService.MaiDb)
            {
                TryCatch(()=>{
                    var hasChildren = dbs.Exist<SYS_Resource>(w => w.ResoParentId == ResoId);
                    if (hasChildren)
                    {
                        result.IsFailure("删除失败！该资源有下属资源！");
                        return;
                    }
                    else
                    {
                        dbs.Delete<SYS_Resource>(w => w.ResoId == ResoId);
                    }
                },result); 
            }
            return result;
        }

 

exec sp_executesql N'select count(*) from SYS_Resource  where (ResoParentId = @para1)',N'@para1 nvarchar(36)',@para1=N'cbaf5484-cdcb-4511-afee-0abb7937d31d'
go
exec sp_executesql N'delete from SYS_Resource  where (ResoId = @para1)',N'@para1 nvarchar(36)',@para1=N'cbaf5484-cdcb-4511-afee-0abb7937d31d'
go

查

        public static IList<SYS_Resource> FindList()
        {
            return QueryService.MaiDb.FindList<SYS_Resource>();
        }

 改

        public static int Update(object model, Expression<Func<SYS_Resource, bool>> where)
        {
            return QueryService.MaiDb.Update<SYS_Resource>(model, where);
        }

exec sp_executesql N'update SYS_Resource set ResoType = @ResoType,ResoName = @ResoName,ResoUrl = @ResoUrl,ResoDesc = @ResoDesc,ResoIsShow = @ResoIsShow,ResoOrder = @ResoOrder,ResoUpdateTime = @ResoUpdateTime  where (ResoId = @para1)',N'@ResoType nvarchar(4),@ResoName nvarchar(4),@ResoUrl nvarchar(4000),@ResoDesc nvarchar(4000),@ResoIsShow bit,@ResoOrder int,@ResoUpdateTime datetime,@para1 nvarchar(36)',@ResoType=N'page',@ResoName=N'编辑角色',@ResoUrl=N'',@ResoDesc=N'',@ResoIsShow=0,@ResoOrder=0,@ResoUpdateTime='2017-08-01 15:37:47.597',@para1=N'3e2fb3cb-92f6-44cb-80a1-3b15157d53c5'
go

一组数据库操作

        public static EditModel Find(string ResoId)
        {
            EditModel editModel = new EditModel();
            using (var dbs = UnitService.MaiDb)
            {
                editModel.model = dbs.Find<SYS_Resource>(s => s, w => w.ResoId == ResoId);
                if (!editModel.model.IsNull())
                {
                    var ds = dbs.ExecuteQuery<SYS_Resource>("select ResoName from SYS_Resource where ResoId = @ResoId", new SqlParameter[1] { new SqlParameter("@ResoId", editModel.model.ResoParentId) });
                    if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
                    {
                        editModel.ResoParentName = ds.Tables[0].Rows[0][0].ToString();
                    }
                }                
            }
            return editModel;
        }

exec sp_executesql N'select * from SYS_Resource  where (ResoId = @para1)',N'@para1 nvarchar(36)',@para1=N'89fa1a64-6e49-42b9-b2a7-bd5fce0ea54e'
go
exec sp_executesql N'select ResoName from SYS_Resource where ResoId = @ResoId',N'@ResoId nvarchar(36)',@ResoId=N'74f6bb3b-8995-49b7-9b4b-db0e34aac304'
go

事务操作

            using (var dbs = UnitService.MaiDb)
            {
                try
                {
                    dbs.BeginTransaction();
                    //你的代码...
                    dbs.CommitTransaction();
                }
                catch (Exception ex)
                {
                    dbs.RollbackTransaction();
                }
            }

Lambda如何转换SQL语句，请参考lambda表达式转换sql

码农的世界，不知道可以走多远，坚持多久，好好珍惜当下。