SQLite数据库锁定异常

在此过程中，某个连接处于打开状态。去掉OpenConnection和CloseConnection，将ExecuteNonQuery改为：

using (SQLiteConnection c = new SQLiteConnection(ConnectionString))
{
    c.Open();
    using (SQLiteCommand cmd = new SQLiteCommand(sql, c))
    {
        cmd.ExecuteNonQuery();
    }
}

此外，将读取数据的方式更改为：

using (SQLiteConnection c = new SQLiteConnection(ConnectionString))
{
    c.Open();
    using (SQLiteCommand cmd = new SQLiteCommand(sql, c))
    {
        using (SQLiteDataReader rdr = cmd.ExecuteReader())
        {
            ...
        }
    }
}

不要尝试，像在这里一样自己管理连接池。首先，它比您编码的要复杂得多，但第二，它已经在SQLiteConnection对象内部处理了。最后，如果您没有利用using，那么您就没有正确地处理这些对象，最终会出现类似您现在看到的问题。

您可以使用下面的"using"语句，这将确保连接&即使在异常中也能正确处理命令

private static void ExecuteNonQuery(string queryString)
{
    using (var connection = new SQLiteConnection(
               ConnectionString))
    {
        using (var command = new SQLiteCommand(queryString, connection))
        {
            command.Connection.Open();
            command.ExecuteNonQuery();
        }
    }
}

在尝试将任何数据写入数据库之前，应关闭DataReader。用途：

dr.Close();

在您使用完DataReader之后。

在我的情况下，我非常愚蠢，我在SQLite浏览器中进行了更改，但没有点击写更改，这锁定了要由服务修改的数据库。在我点击"写更改"按钮后，所有的帖子请求都按预期进行了。

这里有很多有用的帖子，对于那些可能忘记清理悬挂连接的人来说，但还有另一种可能发生的方式：SQLite不支持并发INSERT；如果同时发布两个INSERT，则将串行处理。当INSERT很快时，这是可以的，但如果一次INSERT花费的时间超过超时时间，则第二次INSERT可能会失败并显示此消息。

当我使用一个长时间运行的事务将一堆INSERT累积到一个大的提交中时，就发生了这种情况。基本上，我在事务处理期间锁定了数据库，使其不受任何其他活动的影响。切换到journal_mode=WAL将允许并发写入和读取，但不允许并发写入。

我去掉了长时间运行的事务，让每个INSERT都自动提交，这就解决了我的问题。

Mine是由调用HasRows（）时未关闭SqliteDataReader引起的。

我有这个：

 using (SQLiteConnection connection = new SQLiteConnection(DbPath))
 {
    connection.Open();
    string sql = $"SELECT * FROM ...";
    using (SQLiteCommand command = new SQLiteCommand(sql, connection))
    {
        return command.ExecuteReader().HasRows;
    }
    connection.Close();
}

但需要围绕ExecuteReader这样使用：

using (SQLiteDataReader reader = command.ExecuteReader())
{
      return command.ExecuteReader().HasRows;
}

即使每次数据库仍被读取器锁定时，都会释放并重新创建DbConnection。

我在这里也得到了同样的错误：

if (new basics.HindiMessageBox(HMsg, HTitle).ShowDialog()==true)
{
    SQLiteConnection m_dbConnection = new SQLiteConnection(MainWindow.con);
    m_dbConnection.Open();
    sql = "DELETE FROM `users`  WHERE `id`=" + SelectedUser.Id;
    command = new SQLiteCommand(sql, m_dbConnection);
    command.ExecuteNonQuery();
    m_dbConnection.Close();
    LoadUserDG();
}

但是当我刚更改SQLiteConnection声明位置时

public partial class User : Window
{
    SQLiteCommand command;
    string sql;
    AddUser AddUserObj;
    List<basics.users> usersList;
    basics.users SelectedUser;
    SQLiteConnection m_dbConnection;
    // ...
    private void DeleteBtn_Click(object sender, RoutedEventArgs e)
    {
        // ...
        if (new basics.HindiMessageBox(HMsg, HTitle).ShowDialog()==true)
        {
            m_dbConnection = new SQLiteConnection(MainWindow.con);
            m_dbConnection.Open();
            sql = "DELETE FROM `users`  WHERE `id`=" + SelectedUser.Id;
            command = new SQLiteCommand(sql, m_dbConnection);
            command.ExecuteNonQuery();
            m_dbConnection.Close();
            LoadUserDG();
        }
}

现在一切都很好。我希望这对你也有用。如果有人能说出这是怎么发生的，我想知道细节，以提高我的知识，请。

当从多个线程将大量数据加载到不同的表时，我遇到了同样的问题。当我尝试插入时，数据库被锁定了，因为程序插入太多太快，SQLite没有时间在另一个事务到来之前完成每个事务。

插入是通过线程完成的，因为我不希望接口被锁定并等待插入完成。

我的解决方案是将BlockingCollection与ThreadPool.QueueUserWorkItem一起使用。这允许我在插入时释放接口。所有插入都按FIFO（先进先出）顺序排队并执行。现在，在从任何线程执行任何SQL事务时，数据库都不会被锁定。

public class DatabaseQueueBus
{
    private BlockingCollection<TransportBean> _dbQueueBus = new BlockingCollection<TransportBean>(new ConcurrentQueue<TransportBean>());
    private CancellationTokenSource __dbQueueBusCancelToken;
    public CancellationTokenSource _dbQueueBusCancelToken { get => __dbQueueBusCancelToken; set => __dbQueueBusCancelToken = value; }
    public DatabaseQueueBus()
    {
        _dbQueueBusCancelToken = new CancellationTokenSource();
        DatabaseQueue();
    }
    public void AddJob(TransportBean dto)
    {
        _dbQueueBus.Add(dto);
    }
    private void DatabaseQueue()
    {
        ThreadPool.QueueUserWorkItem((param) =>
        {
            try
            {
                do
                {
                    string job = "";
                    TransportBean dto = _dbQueueBus.Take(_dbQueueBusCancelToken.Token);
                    try
                    {
                        job = (string)dto.DictionaryTransBean["job"];
                        switch (job)
                        {
                            case "SaveClasse":
                                //Save to table here
                                break;
                            case "SaveRegistrant":
                                //Save Registrant here
                                break;
                          
                        }
                    }
                    catch (Exception ex)
                    {//TODO: Handle this exception or not
                    }
                } while (_dbQueueBusCancelToken.Token.IsCancellationRequested != true);
            }
            catch (OperationCanceledException)
            {
            }
            catch (Exception ex)
            {
            }
        });
    }
}

插入是这样完成的，但如果没有排队，我仍然会遇到锁定问题。

using (SQLiteConnection c = new SQLiteConnection(BaseDal.SQLiteCon))
        {
            c.Open();
            using (SQLiteCommand cmd = new SQLiteCommand(sql, c))
            {
                cmd.ExecuteNonQuery();
            }
            c.Close();
        }