许多行的SQLite更新非常慢

我相信我已经用很多方法来加速许多行的更新，但到目前为止没有任何帮助。

我们正在打开一个交易，如下所示：

private SQLiteTransaction BeginTransaction(SQLiteConnection connection) { return connection.BeginTransaction(); } 

并在课程结束时关闭它。 我们打开一个连接，一个事务，然后我们更新数据库上的许多行。 这意味着我们在很多表中累积了许多不同的SQL语句。

一个重要的部分是在一个表中更新12000条记录

 protected override void UpdateRows(SQLiteConnection connection, IEnumerable rowsToUpdate) { var command = new SQLiteCommand(Queries.SQLUpdateDocument, connection); foreach (DataRow documentRow in rowsToUpdate) { command.Parameters.AddWithValue("@Filename", documentRow[Constants.Col_Document_Filename]); command.Parameters.AddWithValue("@ClassID", documentRow[Constants.Col_Document_ClassID]); command.Parameters.AddWithValue("@PageCount", documentRow[Constants.Col_Document_PageCount]); command.Parameters.AddWithValue("@DocID", documentRow[Constants.Col_Document_GlobalDocID]); command.Parameters.AddWithValue("@ReadOnly", documentRow[Constants.Col_Document_ReadOnly]); command.Parameters.AddWithValue("@Confirmed", documentRow[Constants.Col_Document_Confirmed]); command.Parameters.AddWithValue("@ParentFolderID", documentRow[Constants.Col_Document_ParentFolderID]); command.Parameters.AddWithValue("@SequenceNumber", documentRow[Constants.Col_Document_SequenceNumber]); command.Parameters.AddWithValue("@XmlRepr", documentRow[Constants.Col_Document_XmlRepr]); command.ExecuteNonQuery(); documentRow.AcceptChanges(); } } 

与查询beeing：

 UPDATE T_Doc SET Filename = @Filename, ClassID = @ClassID, PageCount = @PageCount, ReadOnly = @ReadOnly, Confirmed = @Confirmed, ParentFolderID = @ParentFolderID, SequenceNumber = @SequenceNumber, XmlRepr = @XmlRepr WHERE ID = @DocID; 

AcceptChanges（）不需要很长时间。 ExecuteNonQuery（）比预期慢得多。

 PRAGMA foreign_keys = ON; 

已在update命令之前执行，ClassID和ParentFolderID引用其他表。

无论如何 – 更新速度非常慢，更新12000条记录需要15-30分钟。

任何人都可以帮我吗？

Answer 1

我怀疑你没有调用BeginTransaction ，或者你没有将命令与事务关联…如果未明确指定事务，则每次执行命令时都会隐式创建一个新事务。

试试这个：

 protected override void UpdateRows(SQLiteConnection connection, IEnumerable rowsToUpdate) { using (var command = new SQLiteCommand(Queries.SQLUpdateDocument, connection)) using (var transaction = connection.BeginTransaction()) { command.Transaction = transaction; foreach (DataRow documentRow in rowsToUpdate) { command.Parameters.AddWithValue("@Filename", documentRow[Constants.Col_Document_Filename]); command.Parameters.AddWithValue("@ClassID", documentRow[Constants.Col_Document_ClassID]); command.Parameters.AddWithValue("@PageCount", documentRow[Constants.Col_Document_PageCount]); command.Parameters.AddWithValue("@DocID", documentRow[Constants.Col_Document_GlobalDocID]); command.Parameters.AddWithValue("@ReadOnly", documentRow[Constants.Col_Document_ReadOnly]); command.Parameters.AddWithValue("@Confirmed", documentRow[Constants.Col_Document_Confirmed]); command.Parameters.AddWithValue("@ParentFolderID", documentRow[Constants.Col_Document_ParentFolderID]); command.Parameters.AddWithValue("@SequenceNumber", documentRow[Constants.Col_Document_SequenceNumber]); command.Parameters.AddWithValue("@XmlRepr", documentRow[Constants.Col_Document_XmlRepr]); command.ExecuteNonQuery(); documentRow.AcceptChanges(); } transaction.Commit(); } } 

请注意，如果您有非常多的行，则可能需要在更新所有内容之前提交，例如每1000行。 在这种情况下，您需要在提交前一个事务后创建一个新事务。