Dapper逆天入門~強類型，動態類型，多映射，多返回值，增刪改查+存儲過程+事物案例演示

Dapper的牛逼就不扯蛋了，答應群友做個入門Demo的，現有園友需要，那么公開分享一下：

完整Demo：http://pan.baidu.com/s/1i3TcEzj

注 意 事 項：http://www.cnblogs.com/dunitian/p/5221058.html

平台之大勢何人能擋？ 帶着你的Net飛奔吧！

http://www.cnblogs.com/dunitian/p/4822808.html#skill

擴展篇：http://www.cnblogs.com/dunitian/p/5710382.html

先安裝一下Dapper（建議用nuget包來管理）

連接字符串：

string connStr = "Data Source=.;Initial Catalog=DapperDB;User ID=用戶名;Password=密碼";

強類型：

#region 強類型
            //public static IEnumerable<T> Query<T>(this IDbConnection cnn, string sql, object param = null, SqlTransaction transaction = null, bool buffered = true)
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();

                //無參查詢
                //var qqModeList = conn.Query<QQModel>("select Id,Name,Count from QQModel"); 
                //帶參查詢
                var qqModeList = conn.Query<QQModel>("select Id,Name,Count from QQModel where Id in @id and Count>@count", new { id = new int[] { 1, 2, 3, 4, 5, 6 }, count = 1 });
                foreach (var item in qqModeList)
                {
                    Console.WriteLine(item.Id + " " + item.Name + " " + item.Count);
                }
            }
            #endregion

動態類型：

#region 動態類型
            ////逆天動態類型用的比較多[可能是MVC ViewBag用多了]
            //public static IEnumerable<dynamic> Query (this IDbConnection cnn, string sql, object param = null, SqlTransaction transaction = null, bool buffered = true)
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                var qqModeList = conn.Query("select Id,Name,Count from QQModel").ToList();
                foreach (var item in qqModeList)
                {
                    Console.WriteLine(item.Id + " " + item.Name + " " + item.Count);
                }
            }
            #endregion

多映射：

            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string sqlStr = @"select A.Id,A.Title,S.SeoKeywords from Article A
                                inner join SeoTKD S on A.SeoId=S.Id
                                where A.Id in @ids";
                conn.Open();
                var articleList = conn.Query(sqlStr, new { ids = new int[] { 41, 42, 43, 44, 45, 46, 47, 48 } });
                foreach (var item in articleList)
                {
                    Console.WriteLine(item.Id + " | " + item.SeoKeywords + " | ：" + item.Title);
                }
            }

　多返回值：

            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string sqlStr = @"select Id,Title,Author from Article where Id = @id 
                                  select * from QQModel where Name = @name 
                                  select * from SeoTKD where Status = @status";
                conn.Open();
                using (var multi = conn.QueryMultiple(sqlStr, new { id = 11, name = "打代碼", status = 99 }))
                {
                    //multi.IsConsumed   reader的狀態 ，true 是已經釋放
                    if (!multi.IsConsumed)
                    {
                        //注意一個東西，Read獲取的時候必須是按照上面返回表的順序 （article，qqmodel，seotkd）
                        //強類型
                        var articleList = multi.Read<Temp>();//類不見得一定得和表名相同
                        var QQModelList = multi.Read<QQModel>();
                        var SeoTKDList = multi.Read<SeoTKD>();

                        //動態類型
                        //var articleList = multi.Read();
                        //var QQModelList = multi.Read();
                        //var SeoTKDList = multi.Read();

                        #region 輸出
                        foreach (var item in QQModelList)
                        {
                            Console.WriteLine(item.Id + " " + item.Name + " " + item.Count);
                        }
                        foreach (var item in SeoTKDList)
                        {
                            Console.WriteLine(item.Id + " | " + item.SeoKeywords);
                        }
                        foreach (var item in articleList)
                        {
                            Console.WriteLine(item.Author);
                        }
                        #endregion
                    }

                }
            }

　增刪改查：（刪項目里面基本上不用）

            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                //增
                int count = conn.Execute("insert into Article values(@title,@content,@author,961,1,2,2,N'2015-11-23 11:06:36.553',N'2015-11-23 11:06:36.553',N'5,103,113',91,N'3,5,11',0,N'/Images/article/16.jpg')", new { title = "Title1", content = "TContent1", author = "毒逆天" });

                //改
                //int count = conn.Execute("update Article set Title=@title where Id=@id", new { title = "么么噠", id = 274 });
                if (count > 0)
                {
                    Console.WriteLine(count + "條操作成功");
                }
            }

存儲過程：

            //查詢
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                //參數名得和存儲過程的變量名相同（參數可以跳躍傳，鍵值對方式即可）
                //動態類型
                //var list = conn.Query("usp_test", new { aId = 11 }, commandType: CommandType.StoredProcedure);
                //強類型
                var list = conn.Query<TitleAndKeyWords>("usp_test", new { aId = 11 }, commandType: CommandType.StoredProcedure);
                foreach (var item in list)
                {
                    Console.WriteLine(item.Id + " | " + item.SeoKeywords + " | ：" + item.Title);
                }
            }

            //插入
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                int count = conn.Execute("usp_insertArticle", new { title = "Title11", content = "TContent1", author = "毒逆天" }, commandType: CommandType.StoredProcedure);
                if (count > 0)
                {
                    Console.WriteLine(count + "條操作成功");
                }
            }

            //更新
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                int count = conn.Execute("usp_updateArticle", new { id = 276, title = "Dapper使用" }, commandType: CommandType.StoredProcedure);
                if (count > 0)
                {
                    Console.WriteLine(count + "條操作成功");
                }
            }

事物的使用：

先看看ADO.Net怎么用的

            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string sql = @"insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 999999999999999999999999) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               ";
                using (SqlCommand cmd = new SqlCommand(sql, conn))
                {
                    conn.Open();
                    cmd.Transaction = conn.BeginTransaction();
                    try
                    {
                        int i = cmd.ExecuteNonQuery();
　　　　　　　　　　　　　　cmd.Transaction.Commit();
                        Console.WriteLine(i);
                    }
                    catch (Exception ex)
                    {
                        cmd.Transaction.Rollback();
                        Console.WriteLine(ex);
                    }
                }
            }

再看看Dapper的

using (SqlConnection conn = new SqlConnection(connStr))
            {
                string sql = @"insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 9999999999999999999) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               insert into SeoTKD values(N'毒逆天，測試', N'測試測試測試', 1) 
                               ";
                conn.Open();
                var transaction = conn.BeginTransaction();
                try
                {
                    int i = conn.Execute(sql, transaction: transaction);
                    transaction.Commit();
                    Console.WriteLine(i);
                }
                catch (Exception ex)
                {
                    transaction.Rollback();
                    Console.WriteLine(ex);
                }
            }