zoukankan      html  css  js  c++  java
  • Dapper扩展之~~~Dapper.Contrib

    平台之大势何人能挡? 带着你的Net飞奔吧!http://www.cnblogs.com/dunitian/p/4822808.html#skill

    上一篇文章:Dapper逆天入门~强类型,动态类型,多映射,多返回值,增删改查+存储过程+事物案例演示

     官方地址:https://github.com/StackExchange/dapper-dot-net/tree/master/Dapper.Contrib

    实战案例:https://github.com/dunitian/LoTCode/tree/master/PawChina(更新ing)

    注意点:Model里面的Table和Key是Dapper.Contrib.Extensions命名空间下的~~~~如果不是~~请看下篇文章(点我

    用法很简单,贴一下帮助类:

    /// <summary>
        /// 扩展方法
        /// </summary>
        public abstract partial class DapperDataAsync
        {
            #region 查询系
            /// <summary>
            /// 获取Model-Key为int类型
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="id"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <returns></returns>
            public static async Task<T> GetAsync<T>(int id, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.GetAsync<T>(id, transaction, commandTimeout);
                }
            }
            /// <summary>
            /// 获取Model-Key为long类型
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="id"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <returns></returns>
            public static async Task<T> GetAsync<T>(long id, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.GetAsync<T>(id, transaction, commandTimeout);
                }
            }
            /// <summary>
            /// 获取Model-Key为Guid类型
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="id"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <returns></returns>
            public static async Task<T> GetAsync<T>(System.Guid id, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.GetAsync<T>(id, transaction, commandTimeout);
                }
            }
            /// <summary>
            /// 获取Model-Key为string类型
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="id"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <returns></returns>
            public static async Task<T> GetAsync<T>(string id, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.GetAsync<T>(id, transaction, commandTimeout);
                }
            }
            /// <summary>
            /// 获取Model集合(没有Where条件)
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <returns></returns>
            public static async Task<IEnumerable<T>> GetAllAsync<T>() where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.GetAllAsync<T>();
                }
            }
            #endregion
    
            #region 增删改
            /// <summary>
            /// 插入一个Model
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="model"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <param name="sqlAdapter"></param>
            /// <returns></returns>
            public static async Task<int> InsertAsync<T>(T model, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    return await conn.InsertAsync<T>(model, transaction, commandTimeout);
                }
            }
    
            /// <summary>
            /// 更新一个Model
            /// </summary>
            /// <typeparam name="T"></typeparam>
            /// <param name="connection"></param>
            /// <param name="entityToUpdate"></param>
            /// <param name="transaction"></param>
            /// <param name="commandTimeout"></param>
            /// <returns></returns>
            public static async Task<T> UpdateAsync<T>(T model, IDbTransaction transaction = null, int? commandTimeout = null) where T : class, new()
            {
                using (var conn = ConnFactory.GetConnection())
                {
                    bool b = await conn.UpdateAsync<T>(model, transaction, commandTimeout);
                    if (b) { return model; }
                    else { return null; }
                }
            }
            #endregion
    
            #region 分页查询
            /// <summary>
            /// 分页查询(为什么不用out,请参考:http://www.cnblogs.com/dunitian/p/5556909.html)
            /// </summary>
            /// <param name="sql">查询语句</param>
            /// <param name="p">动态参数</param>
            /// <param name="sqlTotal">total语句</param>
            /// <param name="p2">Total动态参数</param>
            /// <returns></returns>
            public static async Task<string> PageLoadAsync<T>(string sql, object p = null, string sqlTotal = "", object p2 = null)
            {
                var rows = await QueryAsync<T>(sql.ToString(), p);
                var total = rows.Count();
                if (!sqlTotal.IsNullOrWhiteSpace()) { total = await ExecuteScalarAsync<int>(sqlTotal, p2); }
                return new { rows = rows, total = total }.ObjectToJson();
            }
            #endregion
        }
    

     

  • 相关阅读:
    2018最新程序员必备技术类微信公众号
    Navicat Premium for Mac 11.1.8 免费中文破解版下载
    尚硅谷Spring4视频教程免费下载
    业余草www.xttblog.com的最新文章推荐
    AdBlock — 最佳广告拦截工具(Chrome插件安利)
    Leetcode 705. 设计哈希集合【哈希表模板】
    Luogu P3370 【模板】字符串哈希
    POJ3737 UmBasketella
    POJ2456 Aggressive cows
    docker 离线安装
  • 原文地址:https://www.cnblogs.com/dunitian/p/5710382.html
Copyright © 2011-2022 走看看