提高OleDB插入到语句中的性能，BeginTransaction CommitTransaction

Question

我已经编写了附加从定制c＃列表中插入数据到MSAccess的函数。

第仅仅设置了为每个记录一个新的连接：

 public static void appenddatatotable(string connectionstring, string tablename, string[] values) 
    { 

      var myconn = new OleDbConnection(connectionstring); 


      var cmd = new OleDbCommand(); 
      cmd.CommandText = "INSERT INTO " + tablename + " ([RunDate],[ReportingGroup], [Tariff], [Year]) VALUES(@RunDate, @ReportingGroup, @Tariff, @Year)"; 

      cmd.Parameters.AddRange(new[] { new OleDbParameter("@RunDate", values[0]), new OleDbParameter("@ReportingGroup", values[1]), new OleDbParameter("@Tariff", values[2]), new OleDbParameter("@Year", values[3])}); 
      cmd.Connection = myconn; 
      myconn.Open(); 
      cmd.ExecuteNonQuery(); 
      myconn.Close(); 

    } 

我后来干脆在我的值列表循环，并呼吁每个迭代此功能。这工作正常，但速度很慢。

在第二个功能我想包括在功能上环和与BeginTransction和Committransaction工作：

 public static void appenddatatotable2(string connectionstring, string tablename, string datstr, List<PowRes> values) 
    { 

     var myconn = new OleDbConnection(connectionstring); 
     int icounter = 0; 

     var cmd = new OleDbCommand(); 
     OleDbTransaction trans = null; 

     cmd.Connection = myconn; 
     myconn.Open(); 
     foreach (var item in values) 
     { 
      if (icounter == 0) 
      { 
       trans = cmd.Connection.BeginTransaction(); 
       cmd.Transaction = trans; 
      } 

      cmd.CommandText = "INSERT INTO " + tablename + " ([RunDate],[ReportingGroup], [Tariff], [Year]) VALUES(@RunDate, @ReportingGroup, @Tariff, @Year)"; 
      if (string.IsNullOrEmpty(item.yr)) 
       item.yr = ""; 

      cmd.Parameters.AddRange(new[] { new OleDbParameter("@RunDate", datstr), new OleDbParameter("@ReportingGroup", item.RG), new OleDbParameter("@Tariff", item.tar), new OleDbParameter("@Year", item.yr)}); 
      cmd.ExecuteNonQuery(); 
      icounter++; 
      if (icounter >= 500) 
      { 
       trans.Commit(); 
       icounter = 0; 
      } 
     } 
     if (icounter > 0) 
     { 
      trans.Commit(); 
     } 


     myconn.Close(); 

    } 

这也工作正常，但更慢。

我的代码错了吗？我怎么能加快多个插入？

谢谢！

Answer 1

没有测试，只是我的猜测你的第二个功能：你在循环添加了太多的参数相同的命令 - cmd.Parameters每次使用之前从来没有被清除..

正常投入大量的命令集在一个连接中的速度要比在单个连接上一个接一个的速度快得多。

另一种方式来加快你的刀片是所有的INSERT语句转储到长文本，用分号隔开，再火一次性提交（我不知道MSACCESS是否支持与否）

编辑：

到更新命令合并为一个文本：

var updates = values.Select(x => string.Format("INSERT INTO myTable ([RunDate],[ReportingGroup], [Tariff], [Year]) VALUES({0}, {1}, {2}, {3})", 
       datstr, x.RG, x.tar, x.yr)) 
       .Aggregate((m, n) => m + ";" + n); 
cmd.CommandText = update; 

虽然这会对SQL注入的问题。

Answer 2

这应该是比所有的退出版本

public static void appenddatatotable2(string connectionstring, string tablename, string datstr, List<PowRes> values) 
     { 
      string commandText = "INSERT INTO " + tablename + " ([RunDate],[ReportingGroup], [Tariff], [Year]) VALUES(@RunDate, @ReportingGroup, @Tariff, @Year)"; 
      using (var myconn = new OleDbConnection(connectionstring)) 
      { 
       myconn.Open(); 
       using (var cmd = new OleDbCommand()) 
       { 
        foreach (var item in values) 
        { 
         cmd.CommandText = commandText; 
         cmd.Parameters.Clear(); 
         cmd.Parameters.AddRange(new[] { new OleDbParameter("@RunDate", datstr), new OleDbParameter("@ReportingGroup", item.RG), new OleDbParameter("@Tariff", item.tar), new OleDbParameter("@Year", item.yr) }); 
         cmd.Connection = myconn; 
         cmd.Prepare(); 
         cmd.ExecuteNonQuery(); 
        } 
       } 
      } 
     }