blocks|key|630391|text|你可以在你的记录上做一个foreach。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|630392|foreach+(var+record+in+records)+{
++++db.Save(record);
}|code-block|syntax|javascript|630393|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

You can just do a foreach on your records.

<pre><code>foreach (var record in records) {
 db.Save(record);
}
</code></pre>

blocks|key|630437|text|我尝试了两种不同的方法来插入大量行，速度比默认插入更快(当您有很多行时，这是相当慢的)。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|630438|1)用poco的第一个组成一个列表，然后将它们立即插入到一个循环中(和一个事务中)：|630439|using+(var+tr+=+PetaPocoDb.GetTransaction())
{
++++foreach+(var+record+in+listOfRecords)
++++{
++++++++PetaPocoDb.Insert(record);
++++}
++++tr.Complete();
}|code-block|syntax|javascript|630440|2)+SqlBulkCopy+a+DataTable：|630441|var+bulkCopy+=+new+SqlBulkCopy(connectionString,+SqlBulkCopyOptions.TableLock);
bulkCopy.DestinationTableName+=+"SomeTable";
bulkCopy.WriteToServer(dt);|630442|为了将我的列表转换为DataTable，我使用了Marc+Gravells的Convert+generic+List/Enumerable+to+DataTable?函数，该函数为我工作(在我将Poco属性重新排列为与数据库中的表字段完全相同的顺序之后)。|offset|length|630443|SqlBulkCopy是最快的，在我对大约1000行进行的(快速)性能测试中，它比事务方法快50%25左右。|630444|Hth|630445|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/questions/564366/generic-list-to-datatable^0|0|0|0|0|0|12|19|0|0|0|0^^$0|@$1|2|3|4|5|6|7|12|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|13|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|14|8|@]|9|@]|A|$G|H]]|$1|I|3|J|5|6|7|15|8|@]|9|@]|A|$]]|$1|K|3|L|5|F|7|16|8|@]|9|@]|A|$G|H]]|$1|M|3|N|5|6|7|17|8|@]|9|@$O|18|P|19|1|1A]]|A|$]]|$1|Q|3|R|5|6|7|1B|8|@]|9|@]|A|$]]|$1|S|3|T|5|6|7|1C|8|@]|9|@]|A|$]]|$1|U|3|-4|5|6|7|1D|8|@]|9|@]|A|$]]]|V|$W|$5|X|Y|Z|A|$10|11]]]]

I tried two different methods for inserting a large quantity of rows faster than the default Insert (which is pretty slow when you have a lot of rows).

1) Making up a List&lt;T&gt; with the poco's first and then inserting them at once within a loop (and in a transaction):

<pre><code>using (var tr = PetaPocoDb.GetTransaction())
{
 foreach (var record in listOfRecords)
 {
 PetaPocoDb.Insert(record);
 }
 tr.Complete();
}
</code></pre>

2) SqlBulkCopy a DataTable:

<pre><code>var bulkCopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.TableLock);
bulkCopy.DestinationTableName = "SomeTable";
bulkCopy.WriteToServer(dt);
</code></pre>

To get my List &lt;T&gt; to a DataTable I used Marc Gravells <a href="https://stackoverflow.com/questions/564366/generic-list-to-datatable">Convert generic List/Enumerable to DataTable?</a> function which worked ootb for me (after I rearranged the Poco properties to be in the exact same order as the table fields in the db.)

The SqlBulkCopy was fastest, 50% or so faster than the transactions method in the (quick) perf tests I did with ~1000 rows.

Hth

blocks|key|630494|text|在我的例子中，我利用了database.Execute()方法。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|630495|我创建了一个SQL参数，该参数包含插入的第一部分：|630496|var+sql+=+new+Sql("insert+into+myTable(Name,+Age,+Gender)+values");

for+(int+i+=+0;+i+<+pocos.Count+;+%2B%2Bi)
{
+++var+p+=+pocos[i];
+++sql.Append("(@0,+@1,+@2)",+p.Name,+p.Age+,+p.Gender);
+++if(i+!=+pocos.Count+-1)
+++++sql.Append(",");
}

Database.Execute(sql);|code-block|syntax|javascript|630497|entityMap^0|B|I|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|R|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|S|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|N|$]]

In my case, I took advantage of the <code>database.Execute()</code> method.

I created a SQL parameter that had the first part of my insert:

<pre><code>var sql = new Sql("insert into myTable(Name, Age, Gender) values");

for (int i = 0; i &lt; pocos.Count ; ++i)
{
 var p = pocos[i];
 sql.Append("(@0, @1, @2)", p.Name, p.Age , p.Gender);
 if(i != pocos.Count -1)
 sql.Append(",");
}

Database.Execute(sql);
</code></pre>

blocks|key|846991|text|下面是可以添加到v5.01+PetaPoco.cs中的BulkInsert代码|type|unstyled|depth|inlineStyleRanges|entityRanges|data|846992|您可以将其粘贴到某个位置，然后在1098行结束常规插入|846993|你给它一个Pocos的IEnumerable，它会把它发送到数据库|846994|一批一批的x。代码是来自常规插入的90%25。|846995|我没有性能比较，请让我知道:)|846996|++++///+<summary>
++++///+Bulk+inserts+multiple+rows+to+SQL
++++///+</summary>
++++///+<param+name="tableName">The+name+of+the+table+to+insert+into</param>
++++///+<param+name="primaryKeyName">The+name+of+the+primary+key+column+of+the+table</param>
++++///+<param+name="autoIncrement">True+if+the+primary+key+is+automatically+allocated+by+the+DB</param>
++++///+<param+name="pocos">The+POCO+objects+that+specifies+the+column+values+to+be+inserted</param>
++++///+<param+name="batchSize">The+number+of+POCOS+to+be+grouped+together+for+each+database+rounddtrip</param>++++++++
++++public+void+BulkInsert(string+tableName,+string+primaryKeyName,+bool+autoIncrement,+IEnumerable<object>+pocos,+int+batchSize+=+25)
++++{
++++++++try
++++++++{
++++++++++++OpenSharedConnection();
++++++++++++try
++++++++++++{
++++++++++++++++using+(var+cmd+=+CreateCommand(_sharedConnection,+""))
++++++++++++++++{
++++++++++++++++++++var+pd+=+PocoData.ForObject(pocos.First(),+primaryKeyName);
++++++++++++++++++++//+Create+list+of+columnnames+only+once
++++++++++++++++++++var+names+=+new+List<string>();
++++++++++++++++++++foreach+(var+i+in+pd.Columns)
++++++++++++++++++++{
++++++++++++++++++++++++//+Don't+insert+result+columns
++++++++++++++++++++++++if+(i.Value.ResultColumn)
++++++++++++++++++++++++++++continue;

++++++++++++++++++++++++//+Don't+insert+the+primary+key+(except+under+oracle+where+we+need+bring+in+the+next+sequence+value)
++++++++++++++++++++++++if+(autoIncrement+&&+primaryKeyName+!=+null+&&+string.Compare(i.Key,+primaryKeyName,+true)+==+0)
++++++++++++++++++++++++{
++++++++++++++++++++++++++++//+Setup+auto+increment+expression
++++++++++++++++++++++++++++string+autoIncExpression+=+_dbType.GetAutoIncrementExpression(pd.TableInfo);
++++++++++++++++++++++++++++if+(autoIncExpression+!=+null)
++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++names.Add(i.Key);
++++++++++++++++++++++++++++}
++++++++++++++++++++++++++++continue;
++++++++++++++++++++++++}
++++++++++++++++++++++++names.Add(_dbType.EscapeSqlIdentifier(i.Key));
++++++++++++++++++++}
++++++++++++++++++++var+namesArray+=+names.ToArray();

++++++++++++++++++++var+values+=+new+List<string>();
++++++++++++++++++++int+count+=+0;
++++++++++++++++++++do
++++++++++++++++++++{
++++++++++++++++++++++++cmd.CommandText+=+"";
++++++++++++++++++++++++cmd.Parameters.Clear();
++++++++++++++++++++++++var+index+=+0;
++++++++++++++++++++++++foreach+(var+poco+in+pocos.Skip(count).Take(batchSize))
++++++++++++++++++++++++{
++++++++++++++++++++++++++++values.Clear();
++++++++++++++++++++++++++++foreach+(var+i+in+pd.Columns)
++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++//+Don't+insert+result+columns
++++++++++++++++++++++++++++++++if+(i.Value.ResultColumn)+continue;

++++++++++++++++++++++++++++++++//+Don't+insert+the+primary+key+(except+under+oracle+where+we+need+bring+in+the+next+sequence+value)
++++++++++++++++++++++++++++++++if+(autoIncrement+&&+primaryKeyName+!=+null+&&+string.Compare(i.Key,+primaryKeyName,+true)+==+0)
++++++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++++++//+Setup+auto+increment+expression
++++++++++++++++++++++++++++++++++++string+autoIncExpression+=+_dbType.GetAutoIncrementExpression(pd.TableInfo);
++++++++++++++++++++++++++++++++++++if+(autoIncExpression+!=+null)
++++++++++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++++++++++values.Add(autoIncExpression);
++++++++++++++++++++++++++++++++++++}
++++++++++++++++++++++++++++++++++++continue;
++++++++++++++++++++++++++++++++}

++++++++++++++++++++++++++++++++values.Add(string.Format("{0}{1}",+_paramPrefix,+index%2B%2B));
++++++++++++++++++++++++++++++++AddParam(cmd,+i.Value.GetValue(poco),+i.Value.PropertyInfo);
++++++++++++++++++++++++++++}

++++++++++++++++++++++++++++string+outputClause+=+String.Empty;
++++++++++++++++++++++++++++if+(autoIncrement)
++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++outputClause+=+_dbType.GetInsertOutputClause(primaryKeyName);
++++++++++++++++++++++++++++}

++++++++++++++++++++++++++++cmd.CommandText+%2B=+string.Format("INSERT+INTO+{0}+({1}){2}+VALUES+({3})",+_dbType.EscapeTableName(tableName),
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++string.Join(",",+namesArray),+outputClause,+string.Join(",",+values.ToArray()));
++++++++++++++++++++++++}
++++++++++++++++++++++++//+Are+we+done?
++++++++++++++++++++++++if+(cmd.CommandText+==+"")+break;
++++++++++++++++++++++++count+%2B=+batchSize;
++++++++++++++++++++++++DoPreExecute(cmd);
++++++++++++++++++++++++cmd.ExecuteNonQuery();
++++++++++++++++++++++++OnExecutedCommand(cmd);
++++++++++++++++++++}
++++++++++++++++++++while+(true);

++++++++++++++++}
++++++++++++}
++++++++++++finally
++++++++++++{
++++++++++++++++CloseSharedConnection();
++++++++++++}
++++++++}
++++++++catch+(Exception+x)
++++++++{
++++++++++++if+(OnException(x))
++++++++++++++++throw;
++++++++}
++++}


++++///+<summary>
++++///+Performs+a+SQL+Bulk+Insert
++++///+</summary>
++++///+<param+name="pocos">The+POCO+objects+that+specifies+the+column+values+to+be+inserted</param>++++++++
++++///+<param+name="batchSize">The+number+of+POCOS+to+be+grouped+together+for+each+database+rounddtrip</param>++++++++
++++public+void+BulkInsert(IEnumerable<object>+pocos,+int+batchSize+=+25)
++++{
++++++++if+(!pocos.Any())+return;
++++++++var+pd+=+PocoData.ForType(pocos.First().GetType());
++++++++BulkInsert(pd.TableInfo.TableName,+pd.TableInfo.PrimaryKey,+pd.TableInfo.AutoIncrement,+pocos);
++++}|code-block|syntax|javascript|846997|entityMap^0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|R|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|S|8|@]|9|@]|A|$]]|$1|F|3|G|5|6|7|T|8|@]|9|@]|A|$]]|$1|H|3|I|5|6|7|U|8|@]|9|@]|A|$]]|$1|J|3|K|5|L|7|V|8|@]|9|@]|A|$M|N]]|$1|O|3|-4|5|6|7|W|8|@]|9|@]|A|$]]]|P|$]]

Here is the code for BulkInsert that you can add to v5.01 PetaPoco.cs 

You can paste it somewhere close the regular insert at line 1098

You give it an IEnumerable of Pocos and it will send it to the database 

in batches of x together. The code is 90% from the regular insert. 

I do not have performance comparison, let me know :)

<pre><code> /// &lt;summary&gt;
 /// Bulk inserts multiple rows to SQL
 /// &lt;/summary&gt;
 /// &lt;param name="tableName"&gt;The name of the table to insert into&lt;/param&gt;
 /// &lt;param name="primaryKeyName"&gt;The name of the primary key column of the table&lt;/param&gt;
 /// &lt;param name="autoIncrement"&gt;True if the primary key is automatically allocated by the DB&lt;/param&gt;
 /// &lt;param name="pocos"&gt;The POCO objects that specifies the column values to be inserted&lt;/param&gt;
 /// &lt;param name="batchSize"&gt;The number of POCOS to be grouped together for each database rounddtrip&lt;/param&gt; 
 public void BulkInsert(string tableName, string primaryKeyName, bool autoIncrement, IEnumerable&lt;object&gt; pocos, int batchSize = 25)
 {
 try
 {
 OpenSharedConnection();
 try
 {
 using (var cmd = CreateCommand(_sharedConnection, ""))
 {
 var pd = PocoData.ForObject(pocos.First(), primaryKeyName);
 // Create list of columnnames only once
 var names = new List&lt;string&gt;();
 foreach (var i in pd.Columns)
 {
 // Don't insert result columns
 if (i.Value.ResultColumn)
 continue;

 // Don't insert the primary key (except under oracle where we need bring in the next sequence value)
 if (autoIncrement &amp;&amp; primaryKeyName != null &amp;&amp; string.Compare(i.Key, primaryKeyName, true) == 0)
 {
 // Setup auto increment expression
 string autoIncExpression = _dbType.GetAutoIncrementExpression(pd.TableInfo);
 if (autoIncExpression != null)
 {
 names.Add(i.Key);
 }
 continue;
 }
 names.Add(_dbType.EscapeSqlIdentifier(i.Key));
 }
 var namesArray = names.ToArray();

 var values = new List&lt;string&gt;();
 int count = 0;
 do
 {
 cmd.CommandText = "";
 cmd.Parameters.Clear();
 var index = 0;
 foreach (var poco in pocos.Skip(count).Take(batchSize))
 {
 values.Clear();
 foreach (var i in pd.Columns)
 {
 // Don't insert result columns
 if (i.Value.ResultColumn) continue;

 // Don't insert the primary key (except under oracle where we need bring in the next sequence value)
 if (autoIncrement &amp;&amp; primaryKeyName != null &amp;&amp; string.Compare(i.Key, primaryKeyName, true) == 0)
 {
 // Setup auto increment expression
 string autoIncExpression = _dbType.GetAutoIncrementExpression(pd.TableInfo);
 if (autoIncExpression != null)
 {
 values.Add(autoIncExpression);
 }
 continue;
 }

 values.Add(string.Format("{0}{1}", _paramPrefix, index++));
 AddParam(cmd, i.Value.GetValue(poco), i.Value.PropertyInfo);
 }

 string outputClause = String.Empty;
 if (autoIncrement)
 {
 outputClause = _dbType.GetInsertOutputClause(primaryKeyName);
 }

 cmd.CommandText += string.Format("INSERT INTO {0} ({1}){2} VALUES ({3})", _dbType.EscapeTableName(tableName),
 string.Join(",", namesArray), outputClause, string.Join(",", values.ToArray()));
 }
 // Are we done?
 if (cmd.CommandText == "") break;
 count += batchSize;
 DoPreExecute(cmd);
 cmd.ExecuteNonQuery();
 OnExecutedCommand(cmd);
 }
 while (true);

 }
 }
 finally
 {
 CloseSharedConnection();
 }
 }
 catch (Exception x)
 {
 if (OnException(x))
 throw;
 }
 }


 /// &lt;summary&gt;
 /// Performs a SQL Bulk Insert
 /// &lt;/summary&gt;
 /// &lt;param name="pocos"&gt;The POCO objects that specifies the column values to be inserted&lt;/param&gt; 
 /// &lt;param name="batchSize"&gt;The number of POCOS to be grouped together for each database rounddtrip&lt;/param&gt; 
 public void BulkInsert(IEnumerable&lt;object&gt; pocos, int batchSize = 25)
 {
 if (!pocos.Any()) return;
 var pd = PocoData.ForType(pocos.First().GetType());
 BulkInsert(pd.TableInfo.TableName, pd.TableInfo.PrimaryKey, pd.TableInfo.AutoIncrement, pocos);
 }
</code></pre>

blocks|key|630643|text|如果你想使用BulkUpdate，在同一行中：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|630644|public+void+BulkUpdate<T>(string+tableName,+string+primaryKeyName,+IEnumerable<T>+pocos,+int+batchSize+=+25)
{
++++try
++++{
++++++++object+primaryKeyValue+=+null;

++++++++OpenSharedConnection();
++++++++try
++++++++{
++++++++++++using+(var+cmd+=+CreateCommand(_sharedConnection,+""))
++++++++++++{
++++++++++++++++var+pd+=+PocoData.ForObject(pocos.First(),+primaryKeyName);

++++++++++++++++int+count+=+0;
++++++++++++++++do
++++++++++++++++{
++++++++++++++++++++cmd.CommandText+=+"";
++++++++++++++++++++cmd.Parameters.Clear();
++++++++++++++++++++var+index+=+0;

++++++++++++++++++++var+cmdText+=+new+StringBuilder();

++++++++++++++++++++foreach+(var+poco+in+pocos.Skip(count).Take(batchSize))
++++++++++++++++++++{
++++++++++++++++++++++++var+sb+=+new+StringBuilder();
++++++++++++++++++++++++var+colIdx+=+0;
++++++++++++++++++++++++foreach+(var+i+in+pd.Columns)
++++++++++++++++++++++++{
++++++++++++++++++++++++++++//+Don't+update+the+primary+key,+but+grab+the+value+if+we+don't+have+it
++++++++++++++++++++++++++++if+(string.Compare(i.Key,+primaryKeyName,+true)+==+0)
++++++++++++++++++++++++++++{
++++++++++++++++++++++++++++++++primaryKeyValue+=+i.Value.GetValue(poco);
++++++++++++++++++++++++++++++++continue;
++++++++++++++++++++++++++++}

++++++++++++++++++++++++++++//+Dont+update+result+only+columns
++++++++++++++++++++++++++++if+(i.Value.ResultColumn)
++++++++++++++++++++++++++++++++continue;

++++++++++++++++++++++++++++//+Build+the+sql
++++++++++++++++++++++++++++if+(colIdx+>+0)
++++++++++++++++++++++++++++++++sb.Append(",+");
++++++++++++++++++++++++++++sb.AppendFormat("{0}+=+{1}{2}",+_dbType.EscapeSqlIdentifier(i.Key),+_paramPrefix,
++++++++++++++++++++++++++++++++++++++++++++index%2B%2B);

++++++++++++++++++++++++++++//+Store+the+parameter+in+the+command
++++++++++++++++++++++++++++AddParam(cmd,+i.Value.GetValue(poco),+i.Value.PropertyInfo);
++++++++++++++++++++++++++++colIdx%2B%2B;
++++++++++++++++++++++++}

++++++++++++++++++++++++//+Find+the+property+info+for+the+primary+key
++++++++++++++++++++++++PropertyInfo+pkpi+=+null;
++++++++++++++++++++++++if+(primaryKeyName+!=+null)
++++++++++++++++++++++++{
++++++++++++++++++++++++++++pkpi+=+pd.Columns[primaryKeyName].PropertyInfo;
++++++++++++++++++++++++}


++++++++++++++++++++++++cmdText.Append(string.Format("UPDATE+{0}+SET+{1}+WHERE+{2}+=+{3}{4};\n",
+++++++++++++++++++++++++++++++++++++++++++++++++++++_dbType.EscapeTableName(tableName),+sb.ToString(),
+++++++++++++++++++++++++++++++++++++++++++++++++++++_dbType.EscapeSqlIdentifier(primaryKeyName),+_paramPrefix,
+++++++++++++++++++++++++++++++++++++++++++++++++++++index%2B%2B));
++++++++++++++++++++++++AddParam(cmd,+primaryKeyValue,+pkpi);
++++++++++++++++++++}

++++++++++++++++++++if+(cmdText.Length+==+0)+break;

++++++++++++++++++++if+(_providerName.IndexOf("oracle",+StringComparison.OrdinalIgnoreCase)+>=+0)
++++++++++++++++++++{
++++++++++++++++++++++++cmdText.Insert(0,+"BEGIN\n");
++++++++++++++++++++++++cmdText.Append("\n+END;");
++++++++++++++++++++}

++++++++++++++++++++DoPreExecute(cmd);

++++++++++++++++++++cmd.CommandText+=+cmdText.ToString();
++++++++++++++++++++count+%2B=+batchSize;
++++++++++++++++++++cmd.ExecuteNonQuery();
++++++++++++++++++++OnExecutedCommand(cmd);

++++++++++++++++}+while+(true);
++++++++++++}
++++++++}
++++++++finally
++++++++{
++++++++++++CloseSharedConnection();
++++++++}
++++}
++++catch+(Exception+x)
++++{
++++++++if+(OnException(x))
++++++++++++throw;
++++}
}|code-block|syntax|javascript|630645|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

And in the same lines if you want BulkUpdate:

<pre><code>public void BulkUpdate&lt;T&gt;(string tableName, string primaryKeyName, IEnumerable&lt;T&gt; pocos, int batchSize = 25)
{
 try
 {
 object primaryKeyValue = null;

 OpenSharedConnection();
 try
 {
 using (var cmd = CreateCommand(_sharedConnection, ""))
 {
 var pd = PocoData.ForObject(pocos.First(), primaryKeyName);

 int count = 0;
 do
 {
 cmd.CommandText = "";
 cmd.Parameters.Clear();
 var index = 0;

 var cmdText = new StringBuilder();

 foreach (var poco in pocos.Skip(count).Take(batchSize))
 {
 var sb = new StringBuilder();
 var colIdx = 0;
 foreach (var i in pd.Columns)
 {
 // Don't update the primary key, but grab the value if we don't have it
 if (string.Compare(i.Key, primaryKeyName, true) == 0)
 {
 primaryKeyValue = i.Value.GetValue(poco);
 continue;
 }

 // Dont update result only columns
 if (i.Value.ResultColumn)
 continue;

 // Build the sql
 if (colIdx &gt; 0)
 sb.Append(", ");
 sb.AppendFormat("{0} = {1}{2}", _dbType.EscapeSqlIdentifier(i.Key), _paramPrefix,
 index++);

 // Store the parameter in the command
 AddParam(cmd, i.Value.GetValue(poco), i.Value.PropertyInfo);
 colIdx++;
 }

 // Find the property info for the primary key
 PropertyInfo pkpi = null;
 if (primaryKeyName != null)
 {
 pkpi = pd.Columns[primaryKeyName].PropertyInfo;
 }


 cmdText.Append(string.Format("UPDATE {0} SET {1} WHERE {2} = {3}{4};\n",
 _dbType.EscapeTableName(tableName), sb.ToString(),
 _dbType.EscapeSqlIdentifier(primaryKeyName), _paramPrefix,
 index++));
 AddParam(cmd, primaryKeyValue, pkpi);
 }

 if (cmdText.Length == 0) break;

 if (_providerName.IndexOf("oracle", StringComparison.OrdinalIgnoreCase) &gt;= 0)
 {
 cmdText.Insert(0, "BEGIN\n");
 cmdText.Append("\n END;");
 }

 DoPreExecute(cmd);

 cmd.CommandText = cmdText.ToString();
 count += batchSize;
 cmd.ExecuteNonQuery();
 OnExecutedCommand(cmd);

 } while (true);
 }
 }
 finally
 {
 CloseSharedConnection();
 }
 }
 catch (Exception x)
 {
 if (OnException(x))
 throw;
 }
}
</code></pre>

blocks|key|630683|text|这是一个很好的2018年的更新，使用NuGet的FastMember：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|630684|++++private+static+void+SqlBulkCopyPoco<T>(PetaPoco.Database+db,+IEnumerable<T>+data)
++++{
++++++++var+pd+=+PocoData.ForType(typeof(T),+db.DefaultMapper);
++++++++using+(var+bcp+=+new+SqlBulkCopy(db.ConnectionString))
++++++++using+(var+reader+=+ObjectReader.Create(data))+
++++++++{
++++++++++++//+set+up+a+mapping+from+the+property+names+to+the+column+names
++++++++++++var+propNames+=+typeof(T).GetProperties().Select(propertyInfo+=>+propertyInfo.Name).ToArray();
++++++++++++foreach+(var+propName+in+propNames)
++++++++++++{
++++++++++++++++bcp.ColumnMappings.Add(propName,+"["+%2B+pd.GetColumnName(propName)+%2B+"]");
++++++++++++}
++++++++++++bcp.DestinationTableName+=+pd.TableInfo.TableName;
++++++++++++bcp.WriteToServer(reader);
++++++++}
++++}|code-block|syntax|javascript|630685|entityMap|0|LINK|mutability|MUTABLE|url|http://nuget.org/packages/FastMember/^0|O|A|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

Here's a nice 2018 update using <a href="http://nuget.org/packages/FastMember/" rel="nofollow noreferrer">FastMember</a> from NuGet:

<pre><code> private static void SqlBulkCopyPoco&lt;T&gt;(PetaPoco.Database db, IEnumerable&lt;T&gt; data)
 {
 var pd = PocoData.ForType(typeof(T), db.DefaultMapper);
 using (var bcp = new SqlBulkCopy(db.ConnectionString))
 using (var reader = ObjectReader.Create(data)) 
 {
 // set up a mapping from the property names to the column names
 var propNames = typeof(T).GetProperties().Select(propertyInfo =&gt; propertyInfo.Name).ToArray();
 foreach (var propName in propNames)
 {
 bcp.ColumnMappings.Add(propName, "[" + pd.GetColumnName(propName) + "]");
 }
 bcp.DestinationTableName = pd.TableInfo.TableName;
 bcp.WriteToServer(reader);
 }
 }
</code></pre>

I'm using the <code>Save()</code> method to insert or update records, but I would like to make it perform a bulk insert and bulk update with only one database hit. How do I do this?

Bulk insert/Update with Petapoco

性能测试

数据库

我使用Save()方法插入或更新记录，但我想让它在只有一次数据库命中的情况下执行批量插入和批量更新。我该怎么做呢？

问使用Petapoco进行批量插入/更新
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Petapoco进行批量插入/更新EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用Petapoco进行批量插入/更新
EN