1、先把Access数据库中要导入的数据存入DataTable中
配置文件中的数据库连接字符串
1 <connectionStrings> 2 <add name="oleConStr" connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source="/> 3 4 <add name="sqlConStr" connectionString ="server=tiantiankaixing;database=新建数据库;trusted_connection=sspi"/> 5 </connectionStrings>
封装读取Access数据库数据到DataTable中的方法
1 public static string OleConStr = ConfigurationManager.ConnectionStrings["oleConStr"].ConnectionString ;
2
3 public static DataTable OleGetDataTable(string sql, string filePath)
4 {
6 string a = OleConStr + filePath;
7 using (OleDbConnection conn = new OleDbConnection(a))
8 {
10 using (OleDbDataAdapter da = new OleDbDataAdapter(sql, conn))
11 {
12 try
13 {
14 conn.Open();
15 DataTable dt = new DataTable();
16 da.Fill(dt);
17 return dt;
18 }
19 catch (Exception ex)
20 {
21 throw ex;
22 }
23 finally
24 {
25 if (conn.State == ConnectionState.Open)
26 conn.Close();
27 }
28 }
29 }
30 }
读取目标Access数据库到Datatable
1 string sql = "select Id,Time from checkinout"; 2 DataTable dt = AcHelper.OleGetDataTable(sql, @"F:\project\tiantiankaixing\admin.mdb");
2、封装批量插入数据SQL Server数据的方法
1 public static void DataTableToSQLServer(DataTable dt,string connectString)
2 {
3 string connectionString = connectString;
4
5 using (SqlConnection destinationConnection = new SqlConnection(connectionString))
6 {
7 destinationConnection.Open();
8
9 using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection))
10 {
13 try
14 {
16 bulkCopy.DestinationTableName = "checkinout";//要插入的表的表名
17 bulkCopy.BatchSize = dt.Rows.Count;
18 bulkCopy.ColumnMappings.Add("ID", "ID");//映射字段名 DataTable列名 ,数据库 对应的列名
19 bulkCopy.ColumnMappings.Add("TIME", "TIME");
20
21 bulkCopy.WriteToServer(dt);
22 System.Windows.Forms.MessageBox.Show("插入成功");
23 }
24 catch (Exception ex)
25 {
26 Console.WriteLine(ex.Message);
27 }
28 finally
29 {
30
32 }
33 }
36 }
38 }
3、调用DataTableToSQlServer()方法
1 string localCon = "server=tiantiankaixing;database=Test;trusted_connection=sspi"; 2 3 Entity.DataTableToSQLServer(dt, localCon);
即可将DataTable中的全部数据插入数据库
附：SqlBulkCopy的简单使用方法
1 public void Test()
2 {
3 string connectionString = "server=tiantiankaixing;database=新建数据库;trusted_connection=sspi";
4
5 using (SqlConnection sourceConnection =
6 new SqlConnection(connectionString))
7 {
8 sourceConnection.Open();
9 //获取读取的表总行数
10 SqlCommand commandRowCount = new SqlCommand("select count(*) from student",sourceConnection);
11 long countStart = System.Convert.ToInt32(commandRowCount.ExecuteScalar());
12
13
14 //使用SqlDataReader读取源数据
15 SqlCommand commandSourceData = new SqlCommand("select * from student", sourceConnection);
16 SqlDataReader reader =commandSourceData.ExecuteReader();
17
18 //测试用，把数据从一个表批量插入到另一个表
19 //现实生活中肯定不会
20 using (SqlConnection destinationConnection =new SqlConnection(connectionString))
21 {
22 destinationConnection.Open();
23
24 //创建一个SQlBulkCopy对象
25 //指定目标表名
26 //指定要插入的行数
27 //指定对应的映射
28 using (SqlBulkCopy bulkCopy =new SqlBulkCopy(destinationConnection))
29 {
30 bulkCopy.DestinationTableName ="test";
31 bulkCopy.BatchSize = 1;
32 bulkCopy.ColumnMappings.Add("数据源列名","目标列名");
33
34 try
35 {
36
37 bulkCopy.WriteToServer(reader);
38 }
39 catch (Exception ex)
40 {
41 Console.WriteLine(ex.Message);
42 }
43 finally
44 {
45 reader.Close();
46 }
47 }
48 }
53 }
54 }