详解C#把DataTable中数据一次插入数据库的方法
现在实际的情况是这样的:
客户有一台打卡机,员工打卡的信息全部储存在打卡机的Access数据库里面,现在客户引入了一种新的管理系统,需要将Access数据库中的打卡数据同步到SQLServer数据库中,由于时间比较久,数据积累了有40多万条。
软件功能:
选择Access数据库文件,填入目标SQLServer数据库的IP地址,然后开始进行同步。
实现方法:
1、先把Access数据库中要导入的数据存入DataTable中
配置文件中的数据库连接字符串
<connectionStrings> <addname="oleConStr"connectionString="Provider=Microsoft.Jet.OLEDB.4.0;DataSource="/> <addname="sqlConStr"connectionString="server=tiantiankaixing;database=新建数据库;trusted_connection=sspi"/> </connectionStrings>
封装读取Access数据库数据到DataTable中的方法
publicstaticstringOleConStr=ConfigurationManager.ConnectionStrings["oleConStr"].ConnectionString; publicstaticDataTableOleGetDataTable(stringsql,stringfilePath) { stringa=OleConStr+filePath; using(OleDbConnectionconn=newOleDbConnection(a)) { using(OleDbDataAdapterda=newOleDbDataAdapter(sql,conn)) { try { conn.Open(); DataTabledt=newDataTable(); da.Fill(dt); returndt; } catch(Exceptionex) { throwex; } finally { if(conn.State==ConnectionState.Open) conn.Close(); } } } }
读取目标Access数据库到Datatable
stringsql="selectId,Timefromcheckinout"; DataTabledt=AcHelper.OleGetDataTable(sql,@"F:\project\tiantiankaixing\admin.mdb");
2、封装批量插入数据SQLServer数据的方法
publicstaticvoidDataTableToSQLServer(DataTabledt,stringconnectString) { stringconnectionString=connectString; using(SqlConnectiondestinationConnection=newSqlConnection(connectionString)) { destinationConnection.Open(); using(SqlBulkCopybulkCopy=newSqlBulkCopy(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(Exceptionex) { Console.WriteLine(ex.Message); } finally { } } } }
3、调用DataTableToSQlServer()方法
stringlocalCon="server=tiantiankaixing;database=Test;trusted_connection=sspi"; Entity.DataTableToSQLServer(dt,localCon);
即可将DataTable中的全部数据插入数据库
附:SqlBulkCopy的简单使用方法
publicvoidTest() { stringconnectionString="server=tiantiankaixing;database=新建数据库;trusted_connection=sspi"; using(SqlConnectionsourceConnection= newSqlConnection(connectionString)) { sourceConnection.Open(); //获取读取的表总行数 SqlCommandcommandRowCount=newSqlCommand("selectcount(*)fromstudent",sourceConnection); longcountStart=System.Convert.ToInt32(commandRowCount.ExecuteScalar()); //使用SqlDataReader读取源数据 SqlCommandcommandSourceData=newSqlCommand("select*fromstudent",sourceConnection); SqlDataReaderreader=commandSourceData.ExecuteReader(); //测试用,把数据从一个表批量插入到另一个表 //现实生活中肯定不会 using(SqlConnectiondestinationConnection=newSqlConnection(connectionString)) { destinationConnection.Open(); //创建一个SQlBulkCopy对象 //指定目标表名 //指定要插入的行数 //指定对应的映射 using(SqlBulkCopybulkCopy=newSqlBulkCopy(destinationConnection)) { bulkCopy.DestinationTableName="test"; bulkCopy.BatchSize=1; bulkCopy.ColumnMappings.Add("数据源列名","目标列名"); try { bulkCopy.WriteToServer(reader); } catch(Exceptionex) { Console.WriteLine(ex.Message); } finally { reader.Close(); } } } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。