詳解C#把DataTable中數(shù)據(jù)一次插入數(shù)據(jù)庫的方法
現(xiàn)在實際的情況是這樣的:
客戶有一臺打卡機,員工打卡的信息全部儲存在打卡機的Access數(shù)據(jù)庫里面,現(xiàn)在客戶引入了一種新的管理系統(tǒng),需要將Access數(shù)據(jù)庫中的打卡數(shù)據(jù)同步到SQL Server數(shù)據(jù)庫中,由于時間比較久,數(shù)據(jù)積累了有40多萬條。
軟件功能:
選擇Access數(shù)據(jù)庫文件,填入目標(biāo)SQL Server數(shù)據(jù)庫的IP地址,然后開始進行同步。
實現(xiàn)方法:
1、先把Access數(shù)據(jù)庫中要導(dǎo)入的數(shù)據(jù)存入DataTable中
配置文件中的數(shù)據(jù)庫連接字符串
<connectionStrings> <add name="oleConStr" connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source="/> <add name="sqlConStr" connectionString ="server=tiantiankaixing;database=新建數(shù)據(jù)庫;trusted_connection=sspi"/> </connectionStrings>
封裝讀取Access數(shù)據(jù)庫數(shù)據(jù)到DataTable中的方法
public static string OleConStr = ConfigurationManager.ConnectionStrings["oleConStr"].ConnectionString ; public static DataTable OleGetDataTable(string sql, string filePath) { string a = OleConStr + filePath; using (OleDbConnection conn = new OleDbConnection(a)) { using (OleDbDataAdapter da = new OleDbDataAdapter(sql, conn)) { try { conn.Open(); DataTable dt = new DataTable(); da.Fill(dt); return dt; } catch (Exception ex) { throw ex; } finally { if (conn.State == ConnectionState.Open) conn.Close(); } } } }
讀取目標(biāo)Access數(shù)據(jù)庫到Datatable
string sql = "select Id,Time from checkinout"; DataTable dt = AcHelper.OleGetDataTable(sql, @"F:\project\tiantiankaixing\admin.mdb");
2、封裝批量插入數(shù)據(jù)SQL Server數(shù)據(jù)的方法
public static void DataTableToSQLServer(DataTable dt,string connectString) { string connectionString = connectString; using (SqlConnection destinationConnection = new SqlConnection(connectionString)) { destinationConnection.Open(); using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection)) { try { bulkCopy.DestinationTableName = "checkinout";//要插入的表的表名 bulkCopy.BatchSize = dt.Rows.Count; bulkCopy.ColumnMappings.Add("ID", "ID");//映射字段名 DataTable列名 ,數(shù)據(jù)庫 對應(yīng)的列名 bulkCopy.ColumnMappings.Add("TIME", "TIME"); bulkCopy.WriteToServer(dt); System.Windows.Forms.MessageBox.Show("插入成功"); } catch (Exception ex) { Console.WriteLine(ex.Message); } finally { } } } }
3、調(diào)用DataTableToSQlServer()方法
string localCon = "server=tiantiankaixing;database=Test;trusted_connection=sspi"; Entity.DataTableToSQLServer(dt, localCon);
即可將DataTable中的全部數(shù)據(jù)插入數(shù)據(jù)庫
附:SqlBulkCopy的簡單使用方法
public void Test() { string connectionString = "server=tiantiankaixing;database=新建數(shù)據(jù)庫;trusted_connection=sspi"; using (SqlConnection sourceConnection = new SqlConnection(connectionString)) { sourceConnection.Open(); //獲取讀取的表總行數(shù) SqlCommand commandRowCount = new SqlCommand("select count(*) from student",sourceConnection); long countStart = System.Convert.ToInt32(commandRowCount.ExecuteScalar()); //使用SqlDataReader讀取源數(shù)據(jù) SqlCommand commandSourceData = new SqlCommand("select * from student", sourceConnection); SqlDataReader reader =commandSourceData.ExecuteReader(); //測試用,把數(shù)據(jù)從一個表批量插入到另一個表 //現(xiàn)實生活中肯定不會 using (SqlConnection destinationConnection =new SqlConnection(connectionString)) { destinationConnection.Open(); //創(chuàng)建一個SQlBulkCopy對象 //指定目標(biāo)表名 //指定要插入的行數(shù) //指定對應(yīng)的映射 using (SqlBulkCopy bulkCopy =new SqlBulkCopy(destinationConnection)) { bulkCopy.DestinationTableName ="test"; bulkCopy.BatchSize = 1; bulkCopy.ColumnMappings.Add("數(shù)據(jù)源列名","目標(biāo)列名"); try { bulkCopy.WriteToServer(reader); } catch (Exception ex) { Console.WriteLine(ex.Message); } finally { reader.Close(); } } } } }
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持我們。
欄 目:C#教程
本文標(biāo)題:詳解C#把DataTable中數(shù)據(jù)一次插入數(shù)據(jù)庫的方法
本文地址:http://mengdiqiu.com.cn/a1/C_jiaocheng/5964.html
您可能感興趣的文章
- 01-10C#中Socket通信用法實例詳解
- 01-10C#裝箱和拆箱原理詳解
- 01-10C#類的多態(tài)性詳解
- 01-10C++調(diào)用C#的DLL程序?qū)崿F(xiàn)方法
- 01-10C#創(chuàng)建不規(guī)則窗體的4種方式詳解
- 01-10C#中深度復(fù)制和淺度復(fù)制詳解
- 01-10C#編程實現(xiàn)DataTable添加行的方法
- 01-10C#實現(xiàn)DataTable映射成Model的方法(附源碼)
- 01-10C#數(shù)據(jù)結(jié)構(gòu)之隊列(Quene)實例詳解
- 01-10C#數(shù)據(jù)結(jié)構(gòu)之順序表(SeqList)實例詳解


閱讀排行
本欄相關(guān)
- 01-10C#通過反射獲取當(dāng)前工程中所有窗體并
- 01-10關(guān)于ASP網(wǎng)頁無法打開的解決方案
- 01-10WinForm限制窗體不能移到屏幕外的方法
- 01-10WinForm繪制圓角的方法
- 01-10C#實現(xiàn)txt定位指定行完整實例
- 01-10WinForm實現(xiàn)仿視頻播放器左下角滾動新
- 01-10C#停止線程的方法
- 01-10C#實現(xiàn)清空回收站的方法
- 01-10C#通過重寫Panel改變邊框顏色與寬度的
- 01-10C#實現(xiàn)讀取注冊表監(jiān)控當(dāng)前操作系統(tǒng)已
隨機閱讀
- 01-10delphi制作wav文件的方法
- 08-05DEDE織夢data目錄下的sessions文件夾有什
- 08-05dedecms(織夢)副欄目數(shù)量限制代碼修改
- 01-11ajax實現(xiàn)頁面的局部加載
- 01-10C#中split用法實例總結(jié)
- 01-10使用C語言求解撲克牌的順子及n個骰子
- 08-05織夢dedecms什么時候用欄目交叉功能?
- 01-10SublimeText編譯C開發(fā)環(huán)境設(shè)置
- 01-11Mac OSX 打開原生自帶讀寫NTFS功能(圖文
- 04-02jquery與jsp,用jquery