通过 System.Data.SQLite 和 c# 对单个 SQLite 数据库文件进行多次访问

Question

正如我从SQLite FAQ 看到的那样，它在任何时候都支持多进程读取（SELECT）和仅一个进程写入（INSERT、UPDATE、DELETE）数据库：

SQLite 使用读/写锁来控制对数据库的访问。 当任何进程要写入时，它必须锁定整个数据库文件 在其更新期间。但这通常只需要几个 毫秒。其他进程只是等待作者完成然后 继续他们的业务

我正在通过 c# 使用System.Data.SQLite 适配器。

请问有人可以解释一下吗？究竟这个过程是如何进行的？

如果已经在同一个数据库上执行另一个写入 SQLiteCommand，这个过程是否会自动工作并且写入 SQLiteCommand 会简单地等待？

或者它可能会抛出异常？什么样的？

抱歉，我没有找到有关此机制的信息 :)

谢谢。

更新：

我发现帖子说 exception will be raised 带有特定的错误代码

这个说法正确吗？

Answer 1

我自己调查过：

我创建了一个示例 SQLite 数据库 c:\123.db，其中一个表 Categories 包含两个字段：ID（唯一标识符）和 Name（nvarchar）。

然后我编写了一些多线程代码来模拟对数据库的多次写入访问（如果您使用此代码，请不要忘记在您的项目中添加 System.Data.SQLite 引用）：

using System;
using System.Data.SQLite;
using System.Threading.Tasks;

namespace SQLiteTest
{
    class Program
    {
        static void Main(string[] args)
        {
            var tasks = new Task[100];

            for (int i = 0; i < 100; i++)
            {
                tasks[i] = new Task(new Program().WriteToDB);
                tasks[i].Start();
            }

            foreach (var task in tasks)
                task.Wait();
        }

        public void WriteToDB()
        {
            try
            {
                using (SQLiteConnection myconnection = new SQLiteConnection(@"Data Source=c:\123.db"))
                {
                    myconnection.Open();
                    using (SQLiteTransaction mytransaction = myconnection.BeginTransaction())
                    {
                        using (SQLiteCommand mycommand = new SQLiteCommand(myconnection))
                        {
                            Guid id = Guid.NewGuid();

                            mycommand.CommandText = "INSERT INTO Categories(ID, Name) VALUES ('" + id.ToString() + "', '111')";
                            mycommand.ExecuteNonQuery();

                            mycommand.CommandText = "UPDATE Categories SET Name='222' WHERE ID='" + id.ToString() + "'";
                            mycommand.ExecuteNonQuery();

                            mycommand.CommandText = "DELETE FROM Categories WHERE ID='" + id.ToString() + "'";
                            mycommand.ExecuteNonQuery();
                        }
                        mytransaction.Commit();
                    }
                }
            }
            catch (SQLiteException ex)
            {
                if (ex.ReturnCode == SQLiteErrorCode.Busy)
                    Console.WriteLine("Database is locked by another process!");
            }
        }
    }
}

我的 Core2Duo E7500 上的结果是从未引发异常！

看起来 SQLite 已经针对我的需要进行了足够优化（锁定/解锁非常快，通常只需几毫秒，正如 SQLite FAQ 告诉我们的那样） - 太好了！

请注意，无需为 SQLiteException 检索整数 ErrorCode - 您可以改用特殊的枚举 ReturnCode 字段。所有代码均描述为here。

希望这些信息对某人有所帮助。