通过system.data.SQLite和C#对单个SQLite数据库文件的多次访问

Question

正如我从SQLite FAQ中读到的那样，它支持多个进程读取(SELECT)，并且在任何时刻只支持一个进程写入(INSERT、UPDATE、DELETE）数据库：

如果已经在同一个数据库上执行了另一个写入SQLiteCommand的操作，那么这个过程是否会自动工作，并且写入SQLiteCommand只需等待？

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

对不起，我没有找到关于这个机制的信息：）

我发现有帖子说异常将用特定的错误代码引发

那个说法正确吗？

Answer 1

我自己调查过：

我创建了一个示例SQLite数据库C:\123.db，其中有一个表categories，该表包含两个字段:id(uniqueidentifier)和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!");
            }
        }
    }
}

请注意，不需要为SQLiteException检索整数ErrorCode-您可以使用一个特殊的枚举returncode字段。这里描述了所有代码。

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