国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > C# > 正文

詳解C#把DataTable中數(shù)據(jù)一次插入數(shù)據(jù)庫的方法

2019-10-29 21:15:22
字體:
供稿:網(wǎng)友

現(xiàn)在實(shí)際的情況是這樣的:

客戶有一臺(tái)打卡機(jī),員工打卡的信息全部?jī)?chǔ)存在打卡機(jī)的Access數(shù)據(jù)庫里面,現(xiàn)在客戶引入了一種新的管理系統(tǒng),需要將Access數(shù)據(jù)庫中的打卡數(shù)據(jù)同步到SQL Server數(shù)據(jù)庫中,由于時(shí)間比較久,數(shù)據(jù)積累了有40多萬條。

軟件功能:

選擇Access數(shù)據(jù)庫文件,填入目標(biāo)SQL Server數(shù)據(jù)庫的IP地址,然后開始進(jìn)行同步。

實(shí)現(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ù)庫 對(duì)應(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的簡(jiǎn)單使用方法

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();        //測(cè)試用,把數(shù)據(jù)從一個(gè)表批量插入到另一個(gè)表        //現(xiàn)實(shí)生活中肯定不會(huì)        using (SqlConnection destinationConnection =new SqlConnection(connectionString))        {          destinationConnection.Open();          //創(chuàng)建一個(gè)SQlBulkCopy對(duì)象          //指定目標(biāo)表名          //指定要插入的行數(shù)          //指定對(duì)應(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();            }          }        }      }    }

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持VEVB武林網(wǎng)。


注:相關(guān)教程知識(shí)閱讀請(qǐng)移步到c#教程頻道。
發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 安阳市| 报价| 高台县| 桦南县| 富民县| 榆树市| 青龙| 犍为县| 平南县| 奈曼旗| 阜南县| 蒲江县| 靖远县| 通化市| 康乐县| 嘉禾县| 泗水县| 全南县| 嘉义县| 茌平县| 旬阳县| 新宾| 中牟县| 滁州市| 潮安县| 高尔夫| 京山县| 华宁县| 宾阳县| 遵义县| 黄龙县| 富民县| 龙海市| 四平市| 富蕴县| 宜州市| 甘德县| 平罗县| 平罗县| 六枝特区| 固始县|