使用.net Core 3.1 多線程讀取數據庫

第一步:先創建一個DBhepler類,作為連接數據庫中心,這個不過多說明,單純作為數據庫的連接...........

   public static string Constr = "數據庫連接字符串";
       public static  DataTable Select(string sql, SqlParameter[] sp)
        {
            using (SqlConnection conn = new SqlConnection(Constr))
            {
                conn.Open();
                DataTable dt = new DataTable();
                SqlCommand cmd = new SqlCommand(sql, conn);
                if (sp != null)
                {
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.Parameters.AddRange(sp);

                }

                SqlDataAdapter sdr = new SqlDataAdapter(cmd);
                sdr.Fill(dt);
                conn.Close();
                return dt;
            }

        }

 

第二步:將讀取的DataTable,數據信息轉換為List

   public static IList<T> TableToListModel<T>(DataTable dt)
            where T : new()
        {


            IList<T> ts = new List<T>();// 定義集合
      
            foreach (DataRow dr in dt.Rows)
            {

                lock (obj_Lock)//就給鎖住,注意這里是要加鎖的,雖然我執行的時候沒加鎖,也成功了,但還是要加上............具體原因,你猜....
                {
                    T t = new T();
                    PropertyInfo[] propertys = t.GetType().GetProperties();// 獲得此模型的公共屬性
                    foreach (PropertyInfo pi in propertys)
                    {
                        //獲取屬性名稱
                        String name = pi.Name;
                        if (dr.Table.Columns.Contains(name))
                        {
                            //非泛型
                            if (!pi.PropertyType.IsGenericType)
                            {
                                pi.SetValue(t, string.IsNullOrEmpty(dr[name].ToString()) ? null : Convert.ChangeType(dr[name], pi.PropertyType), null);
                            }
                            //泛型Nullable<>
                            else
                            {
                                Type genericTypeDefinition = pi.PropertyType.GetGenericTypeDefinition();
                                //model屬性是可為null類型，進行賦null值
                                if (genericTypeDefinition == typeof(Nullable<>))
                                {
                                    //返回指定可以為 null 的類型的基礎類型參數
                                    pi.SetValue(t, string.IsNullOrEmpty(dr[name].ToString()) ? null : Convert.ChangeType(dr[name], Nullable.GetUnderlyingType(pi.PropertyType)), null);
                                }
                            }
                        }
                    }
                    ts.Add(t);

                }
            }
            return ts;
        }

 

 

第三步 :為了能夠將代碼打印出來,,更好的展示效果,我試圖用以下方法展示

        public static IList<GHXX> zhuanhaun(string sql)
        {
            DataTable dt = DBHelper.Select(sql, null);

            IList<GHXX> gHXXes = TableToListModel<GHXX>(dt);

            return gHXXes;
        }

        public static void showlist(string sql, int index)
        {
            IList<GHXX> gHXXes = zhuanhaun(sql);
            for (int i = 0; i < gHXXes.Count; i++)
            {
                Console.WriteLine("序號:{0},我來自第{1}個線程,編號:{2},類別:{3},門診編號:{4},姓名:{5}", i, index, gHXXes[i].MENZH, gHXXes[i].LEIB
                      , gHXXes[i].MENZKS, gHXXes[i].XINGM);
            }
   
        }

 

 

第四步:接下來就是啟動線程執行了

            Stopwatch sw = new Stopwatch();
            sw.Start();
            string sql1 = " 查詢的SQL1";
            string sql2 = "";
            string sql3 = "";
            string sql4 = "";
          

            TaskFactory taskFactory = new TaskFactory();
            List<Task> taskList = new List<Task>();
               //我開啟了四個線程執行
            taskList.Add(taskFactory.StartNew(() =>
            {
                showlist(sql1, 1);
            }));

            taskList.Add(taskFactory.StartNew(() =>
            {
                showlist(sql2, 2);
            }));
            taskList.Add(taskFactory.StartNew(() =>
            {
                showlist(sql3, 3);
            }));
            taskList.Add(taskFactory.StartNew(() =>
            {
                showlist(sql4, 4);
            }));


            sw.Stop();
            TimeSpan ts2 = sw.Elapsed;
            Task.WaitAny(taskList.ToArray());//也可以限時等待
            Console.WriteLine("其中一個線程執行完畢....");


            Task.WaitAll(taskList.ToArray());
            Console.WriteLine("線程全部執行完成,運行時間：" + ts2.TotalMilliseconds);

 

所以就好了..............

然后執行

開啟四個線程查詢8000條數據,耗時如圖所示

沒用啟用線程執行,耗時: