Oracle DataTable的数据批量写入数据库

insert语句,sqldataadapter.update(dataset,tablename);sqlbulkcopy.WriteToServer(datatable);三个方法的性能进行比较：

生成测试的datatable表，表结构如下：

 SqlConnection sqlconnection = new SqlConnection(connectionString);

 SqlDataAdapter sqldataadapter = new SqlDataAdapter("select * from dTable where 1=2", sqlconnection);

 DataSet dataset = new DataSet();

 sqldataadapter.Fill(dataset, "dTable");

 DataTable datatable = dataset.Tables[];

 //生成20000条记录

 for (int i = ; i < ; i++)

 {

　  DataRow datarow = datatable.NewRow();

　  datarow["CompanyName"] = "companyname"+string.Format("{0:0000}",i);

　  datarow["CompanyCode"] = "companycode" + string.Format("{0:0000}", i);

 　 datarow["Address"] = "address" + string.Format("{0:0000}", i);

　  datarow["Owner"] = "owner" + string.Format("{0:0000}", i);

 　 datarow["Memo"] = "memo" + string.Format("{0:0000}", i);

 　 datatable.Rows.Add(datarow);

 }

1.使用sqlcommand.executenonquery()方法插入

foreach (DataRow datarow in datatable.Rows)

{

　　string sql = "INSERT INTO [dTable]([CompanyName],[CompanyCode],[Address],[Owner],[Memo])" +

　　"VALUES('" + datarow["CompanyName"].ToString() + "'" +

　　",'" + datarow["CompanyCode"].ToString() + "'" +

　　",'" + datarow["Address"].ToString() + "'" +

　　",'" + datarow["Owner"].ToString() + "'" +

　　",'" + datarow["Memo"].ToString() + "')";

   using (SqlConnection sqlconn = new SqlConnection(connectionString))

   {

       sqlconn.Open();

       SqlCommand sqlcommand = new SqlCommand(sql, sqlconn);

       sqlcommand.ExecuteNonQuery();

       sqlconn.Close();

   }

}

-插入20000条记录时间:00:00:29.7336000-

2.使用sqldataadapter.update(dataset,tablename);

SqlCommand insertcommand = new SqlCommand("INSERT INTO [dTable]([CompanyName],[CompanyCode],[Address],[Owner],[Memo])" +

"VALUES(@CompanyName, @CompanyCode,@Address,@Owner,@Memo)",new SqlConnection(connectionString));

insertcommand.Parameters.Add("@CompanyName", SqlDbType.NChar, , "CompanyName");

insertcommand.Parameters.Add("@CompanyCode", SqlDbType.NChar, , "CompanyCode");

insertcommand.Parameters.Add("@Address", SqlDbType.NChar, , "Address");

insertcommand.Parameters.Add("@Owner", SqlDbType.NChar, , "Owner");

insertcommand.Parameters.Add("@Memo", SqlDbType.NChar, , "Memo");

sqldataadapter.InsertCommand = insertcommand;

sqldataadapter.Update(dataset, "dTable");

-插入20000条记录时间:00:00:22.8938000-

3.使用sqlbulkcopy.writetoserver(datatable)

SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.UseInternalTransaction);

sqlbulkcopy.DestinationTableName = "dTable";//数据库中的表名

sqlbulkcopy.WriteToServer(dataset.Tables[]);

-插入20000条记录时间:00:00:00.3276000-

所以说速度是sqlbulkcopy最快，sqldataadapter.update()次之，sqlcommand.ExecuteNonQuery()最慢。

秒客网

Oracle DataTable的数据批量写入数据库

相关文章