C#中怎樣連接資料庫並將查詢結果轉為實體類以及如何加入事務

来源:https://www.cnblogs.com/badaoliumangqizhi/archive/2019/12/09/12011007.html

場景 新建一個程式,需要對數據的表進行查詢並將查詢結果轉換為實體類,然後將多個實體類 再插入到另一個資料庫的表中,執行插入的過程中要使用事務。 註: 博客主頁: https://blog.csdn.net/badao_liumang_qizhi 關註公眾號 霸道的程式猿 獲取編程相關電子書、教程推送 ...


場景

新建一個程式,需要對數據的表進行查詢並將查詢結果轉換為實體類,然後將多個實體類

再插入到另一個資料庫的表中,執行插入的過程中要使用事務。

註:

博客主頁:
https://blog.csdn.net/badao_liumang_qizhi
關註公眾號
霸道的程式猿
獲取編程相關電子書、教程推送與免費下載。

實現

不帶事務只是查詢

//儲存數據的工具初始化
            DataSet idxDs = new DataSet();
            //constr:資料庫連接字元串配置
           stringconstr="server=localhost;database=Badao;uid=sa;pwd=123";
            using (SqlConnection conn=new SqlConnection(constr))
           
            {
  
                conn.Open();
                Console.WriteLine("開始查詢索引數據...");
                //查詢索引數據
                string idxSql = "SELECT * FROM Idx1_1";//獲取sql語句
                SqlDataAdapter idxSda = new SqlDataAdapter(idxSql, conn);   //(查詢語句和連接工具)
                idxSda.Fill(idxDs);    //將適配器數據存入DataSet工具中
             }

 

註:

首先聲明一個DataSet用來存儲執行查詢的結果,然後使用連接數據的字元串打開連接。

然後使用Adapter執行sql語句,將查詢結果填充到Dataset中。

怎樣將查詢結果與實體類對應賦值

                IdxRecord idx = null;
                Console.WriteLine("開始儲存索引數據...");
                foreach (DataRow row in idxDs.Tables[0].Rows)
                {
                    idx = new IdxRecord();
                    idx.IdxID = DataProcessor.RowValue(row, "Idx_ID", 0);
                    idx.DataPoint = DataProcessor.RowValue(row, "Data_Point", 0);
                    idx.ScheduleIndex = DataProcessor.RowValue(row, "Schedule_Index", 0L);                  
                    idxList.Add(idx);
                }

 

註:

聲明一個實體類,其中要有與資料庫列所對應的欄位。

然後將DataSet中的內容與實體列的屬性一一賦值。

最後將實體類對象添加到實體類的list上。

其中DataProcessor.RowValue是一個工具類中的方法,此方法中的第二個參數是對應的資料庫中的列

 public static short RowValue(DataRow dr, string field, short defaultValue)
        {
            short Result = defaultValue;
            if (dr.Table.Columns.Contains(field))
            {
                if (dr[field] != null && dr[field] != DBNull.Value)
                {
                    if (short.TryParse(dr[field].ToString(), out Result))
                    {
                        return Result;
                    }
                }
            }
            else
            {
                Console.WriteLine("DataTable中不存在[" + field + "]列!");
            }
            return defaultValue;
        }

 

怎樣開啟事務並存入數據

            //存入bak資料庫
           stringconstrBak="server=localhost;database=BadaoBak;uid=sa;pwd=123";
            using (SqlConnection conn = new SqlConnection(constrBak))//constr:資料庫連接配置
            {
                conn.Open();
                //開啟事務
                SqlTransaction trans = conn.BeginTransaction();
                SqlCommand cmd = new SqlCommand();
                cmd.Connection = conn;//添加連接工具
                cmd.Transaction = trans;//添加事務
                try
                {
                    cmd.CommandText = "INSERT INTO idx1_1 values  ('" + idx.IdxID + "','" + idx.StepEnd +"')";//添加sql語句
                    cmd.ExecuteNonQuery();//執行
                    Console.WriteLine("插入索引數據成功");
                    trans.Commit();//執行完成之後提交
                   

                }
                catch (Exception e)
                {
                    //執行sql語句失敗,事務回滾
                    trans.Rollback();
                  

                }
                finally
                {
                    conn.Close();

                }
            }

 

完整示例代碼

 public static void Main(string[] args)
        {
            List<IdxRecord> idxList = null;         //索引數據
            //儲存數據的工具初始化
            DataSet idxDs = new DataSet();
            //constr:資料庫連接字元串配置
            string constr = "server=localhost;database=Badao;uid=sa;pwd=123";
            using (SqlConnection conn=new SqlConnection(constr))
            {
                conn.Open();
                Console.WriteLine("開始查詢索引數據...");
                //查詢索引數據
                string idxSql = "SELECT * FROM Idx1_1";//獲取sql語句
                SqlDataAdapter idxSda = new SqlDataAdapter(idxSql, conn);   //(查詢語句和連接工具)
                idxSda.Fill(idxDs);    //將適配器數據存入DataSet工具中
                idxList = new List<IdxRecord>();
                IdxRecord idx = null;
                Console.WriteLine("開始儲存索引數據...");
                foreach (DataRow row in idxDs.Tables[0].Rows)
                {
                    idx = new IdxRecord();
                    idx.IdxID = DataProcessor.RowValue(row, "Idx_ID", 0);
                   
                    idxList.Add(idx);
                }
                Console.WriteLine("儲存索引數據成功,成功儲存數量為:" + idxList.Count);
                Console.WriteLine("查詢索引數據成功");
                Console.WriteLine("開始根據索引數據查詢記錄數據...");
                //在迴圈中根據索引數據查詢記錄數據
                for (int i = 0; i+1 < idxList.Count;i++)
                {
                    List<Record> recordList = new List<Record>();
                    List<List<AuxRecord>> autxRecordsList = new List<List<AuxRecord>>();
                    for (int k = idxList[i].DataPoint; k < idxList[i + 1].DataPoint;k++ )
                    {
                        DataSet recordsDs = new DataSet();
                        DataSet auxTDs = new DataSet();
                        //查詢 記錄數據
                        string recordSql = "SELECT * FROM WsC1_1 where Data_Point =" + k;//獲取sql語句
                        //Console.WriteLine("開始執行的查詢語句為:" + recordSql);
                        SqlDataAdapter recordsSda = new SqlDataAdapter(recordSql, conn);   //(查詢語句和連接工具)
                        recordsSda.Fill(recordsDs);    //將適配器數據存入DataSet工具中
                        Record entity = new Record();
                        DataRow row = recordsDs.Tables[0].Rows[0];
                        entity.DataPoint = DataProcessor.RowValue(row, "Data_Point", 0);
                        entity.ScheduleIndex = DataProcessor.RowValue(row, "Schedule_Index", 0L);
                        
                        recordList.Add(entity);
                        //Console.WriteLine("根據索引數據的DataPoint:" + k + "查詢到的記錄數據的DataPoint:" + entity.DataPoint);

                        //根據索引數據查詢輔助通道溫度數據
                        Console.WriteLine("開始根據記錄數據查詢輔助通道溫度數據....");
                        List<AuxRecord> autxRecords = new List<AuxRecord>();         //輔助通道溫度數據
                        string AuxTSql = "SELECT * FROM Aux1_1_25 where IvIndex =" + entity.AuxIndex;//獲取sql語句
                        SqlDataAdapter AuxTSda = new SqlDataAdapter(AuxTSql, conn);   //(查詢語句和連接工具)
                        AuxTSda.Fill(auxTDs);    //將適配器數據存入DataSet工具中
                        //autxRecords = new List<AuxRecord>();
                        AuxRecord aux = null;
                        foreach (DataRow auxrow in auxTDs.Tables[0].Rows)
                        {
                            aux = new AuxRecord();
                            aux.DataPoint = DataProcessor.RowValue(auxrow, "Data_Point", 0);
                            aux.IvIndex = DataProcessor.RowValue(auxrow, "IvIndex", 0);
                            foreach (DataColumn col in auxTDs.Tables[0].Columns)
                            {
                                if (col.ColumnName.StartsWith("T") || col.ColumnName.StartsWith("V"))
                                {
                                    aux.Data.Add(DataProcessor.RowValue(row, col.ColumnName, 0D));
                                }
                            }
                            autxRecords.Add(aux);
                        }
                        autxRecordsList.Add(autxRecords);
                        Console.WriteLine("根據記錄數據查詢輔助通道溫度數據成功");

                        
                    }
                    //conn.Close();
                    //開始向資料庫插入中傳遞參數
                    bool isStoreSuccess = StoreRecordData(idxList[i],recordList,autxRecordsList);
                    if (isStoreSuccess)
                    {
                        Console.WriteLine("存入資料庫成功");
                    }
                    else
                    {
                        Console.WriteLine("存入資料庫失敗");
                    }
                    //開始休眠
                    Console.WriteLine("開始休眠...");
                    System.Threading.Thread.Sleep(1000 * 5);//
                    Console.WriteLine("休眠結束...");

                }
                
                //Console.WriteLine("查詢輔助通道溫度數據成功");
                //Console.ReadKey();
                
            }
        }

        public static bool StoreRecordData(IdxRecord idx, List<Record> recordList, List<List<AuxRecord>> autxRecordsList)
        {
            //存入bak資料庫
            string constrBak = "server=localhost;database=BadaoBak;uid=sa;pwd=123";
            using (SqlConnection conn = new SqlConnection(constrBak))//constr:資料庫連接配置
            {
                conn.Open();
                //開啟事務
                SqlTransaction trans = conn.BeginTransaction();
                SqlCommand cmd = new SqlCommand();
                cmd.Connection = conn;//添加連接工具
                cmd.Transaction = trans;//添加事務
                try
                {
                    cmd.CommandText = "INSERT INTO idx1_1 values  ('" + idx.IdxID + "','" + idx.DataPoint + "','" + idx.StepEnd +"')";//添加sql語句
                    cmd.ExecuteNonQuery();//執行
                    Console.WriteLine("插入索引數據成功");
                    foreach(Record record in recordList)
                    {
                        cmd.CommandText = "INSERT INTO WsC1_1 values  ('" + record.DataPoint + "','" + record.ScheduleIndex + "','" + record.AuxIndex + "')";//添加sql語句
                        cmd.ExecuteNonQuery();//執行
                    }
                    Console.WriteLine("插入記錄數據成功");
                    foreach (List<AuxRecord> auxRecords in autxRecordsList)
                    {
                        cmd.CommandText = "INSERT INTO Aux1_1_25 values  ('" + auxRecords[0].DataPoint + "','" + auxRecords[0].IvIndex + "','" + auxRecords[0].Data[0] + "')";//添加sql語句
                        cmd.ExecuteNonQuery();//執行
                    }
                    Console.WriteLine("插入輔助通道溫度數據成功");
                    trans.Commit();//執行完成之後提交
                    return true;

                }
                catch (Exception e)
                {
                    //執行sql語句失敗,事務回滾
                    trans.Rollback();
                    return false;

                }
                finally
                {
                    conn.Close();

                }
            }
        }

 


您的分享是我們最大的動力!

更多相關文章
一周排行
  • 比如要拆分“呵呵呵90909086676喝喝999”,下麵當type=0返回的是中文字元串“呵呵呵,喝喝”,type=1返回的是數字字元串“90909086676,999”, private string GetStrings(string str,int type=0) { IList<strin ...
  • Swagger一個優秀的Api介面文檔生成工具。Swagger可以可以動態生成Api介面文檔,有效的降低前後端人員關於Api介面的溝通成本,促進項目高效開發。 1、使用NuGet安裝最新的包:Swashbuckle.AspNetCore。 2、編輯項目文件(NetCoreTemplate.Web.c ...
  • 2020 年 7 月 30 日, 由.NET基金會和微軟 將舉辦一個線上和為期一天的活動,包括 微軟 .NET 團隊的演講者以及社區的演講者。本次線上大會 專註.NET框架構建微服務,演講者分享構建和部署雲原生應用程式的最佳實踐、模式、提示和技巧。有關更多信息和隨時瞭解情況:https://focu... ...
  • #abp框架Excel導出——基於vue #1.技術棧 ##1.1 前端採用vue,官方提供 UI套件用的是iview ##1.2 後臺是abp——aspnetboilerplate 即abp v1,https://github.com/aspnetboilerplate/aspnetboilerp ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 作者:碧茂大數據 PS:如有需要Python學習資料的小伙伴可以加下方的群去找免費管理員領取 input()輸入 Python提供了 input() 內置函數從標準輸入讀入一 ...
  • 從12年到20年,python以肉眼可見的趨勢超過了java,成為了當今It界人人皆知的編程語言。 python為什麼這麼火? 網路編程語言搜索指數 適合初學者 Python具有語法簡單、語句清晰的特點,這就讓初學者在學習階段可以把精力集中在編程對象和思維方法上。 大佬都在用 Google,YouT ...
  • 在社會上存在一種普遍的對培訓機構的學生一種歧視的現象,具體表現在,比如:當你去公司面試的時候,一旦你說了你是培訓機構出來的,那麼基本上你就涼了,那麼你瞞著不說,然後又通過了面試成功入職,但是以後一旦在公司被髮現有培訓經歷,可能會面臨被降薪,甚至被辭退,培訓機構出來的學生,在用人單位眼裡就是能力低下的 ...
  • from typing import List# 這道題看了大佬寫的代碼,經過自己的理解寫出來了。# 從最外圍的四周找有沒有為O的,如果有的話就進入深搜函數,然後深搜遍歷# 判斷上下左右的位置是否為Oclass Solution: def solve(self, board: List[List[s ...
  • import requests; import re; import os; # 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, li ...
  • import requests; import re; import os; import parsel; 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537. ...