详解C#把DataTable中数据一次插入数据库的示例代码


本文摘自PHP中文网,作者黄舟,侵删。

本篇文章主要介绍了详解C#把DataTable中数据一次插入数据库的方法,具有一定的参考价值,有兴趣的可以了解一下。

现在实际的情况是这样的:

客户有一台打卡机,员工打卡的信息全部储存在打卡机的Access数据库里面,现在客户引入了一种新的管理系统,需要将Access数据库中的打卡数据同步到SQL Server数据库中,由于时间比较久,数据积累了有40多万条。

软件功能:

选择Access数据库文件,填入目标SQL Server数据库的IP地址,然后开始进行同步。

实现方法:

1、先把Access数据库中要导入的数据存入DataTable中

配置文件中的数据库连接字符串

1

2

3

4

5

<connectionStrings>

  <add name="oleConStr" connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source="/>

   

  <add name="sqlConStr" connectionString ="server=tiantiankaixing;database=新建数据库;trusted_connection=sspi"/>

 </connectionStrings>

封装读取Access数据库数据到DataTable中的方法

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

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();

          }

        }

      }

    }

读取目标Access数据库到Datatable

1

2

string sql = "select Id,Time from checkinout";

DataTable dt = AcHelper.OleGetDataTable(sql, @"F:\project\tiantiankaixing\admin.mdb");

2、封装批量插入数据SQL Server数据的方法

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

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列名 ,数据库 对应的列名

            bulkCopy.ColumnMappings.Add("TIME", "TIME");

             

            bulkCopy.WriteToServer(dt);

            System.Windows.Forms.MessageBox.Show("插入成功");

          }

          catch (Exception ex)

          {

            Console.WriteLine(ex.Message);

          }

          finally

          {

             

 

          }

        }

 

 

      }

 

    }

3、调用DataTableToSQlServer()方法

1

2

string localCon = "server=tiantiankaixing;database=Test;trusted_connection=sspi";

Entity.DataTableToSQLServer(dt, localCon);

即可将DataTable中的全部数据插入数据库

附:SqlBulkCopy的简单使用方法

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

public void Test()

    {

      string connectionString = "server=tiantiankaixing;database=新建数据库;trusted_connection=sspi";

       

      using (SqlConnection sourceConnection =

            new SqlConnection(connectionString))

      {

        sourceConnection.Open();

        //获取读取的表总行数

        SqlCommand commandRowCount = new SqlCommand("select count(*) from student",sourceConnection);

        long countStart = System.Convert.ToInt32(commandRowCount.ExecuteScalar());

         

 

        //使用SqlDataReader读取源数据

        SqlCommand commandSourceData = new SqlCommand("select * from student", sourceConnection);

        SqlDataReader reader =commandSourceData.ExecuteReader();

 

        //测试用,把数据从一个表批量插入到另一个表

        //现实生活中肯定不会

        using (SqlConnection destinationConnection =new SqlConnection(connectionString))

        {

          destinationConnection.Open();

 

          //创建一个SQlBulkCopy对象

          //指定目标表名

          //指定要插入的行数

          //指定对应的映射

          using (SqlBulkCopy bulkCopy =new SqlBulkCopy(destinationConnection))

          {

            bulkCopy.DestinationTableName ="test";

            bulkCopy.BatchSize = 1;

            bulkCopy.ColumnMappings.Add("数据源列名","目标列名");

 

            try

            {

               

              bulkCopy.WriteToServer(reader);

            }

            catch (Exception ex)

            {

              Console.WriteLine(ex.Message);

            }

            finally

            {

              reader.Close();

            }

          }

        }

 

 

      }

    }

以上就是详解C#把DataTable中数据一次插入数据库的示例代码的详细内容!

相关阅读 >>

新手学习.net编程计划-1

C#获取ip及判断ip是否在区间的示例代码

C# 日志记录类创建的源码分享

C#基础入门-变量介绍

C#教程】C# 多态性

C#异常增强

详细介绍C#时间戳和js时间戳互转方法的代码分享

C#实现与现有.net事件桥接的简单代码

采用 C# 编写的学委助手详解及实例

C#如何实现两个richtextbox控件滚动条同步滚动的简单方法

更多相关阅读请进入《C#》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...

    暂无评论...