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

Question

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

c#databasesqlitelockingsystem.data.sqlite

11

据我从SQLite FAQ中了解到，它支持多个进程读取（SELECT），但在任何时候只支持一个进程写入（INSERT、UPDATE、DELETE）数据库:

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

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

请问有人能够准确地向我解释这个过程吗？

这个过程是否会自动工作，如果已经有另一个写入 SQLiteCommand 正在执行相同的数据库，那么写入 SQLiteCommand 将简单地等待？

还是它会抛出异常？是什么样的异常？

很抱歉，但我没有找到关于这个机制的信息：）

谢谢。

更新：

我发现一篇帖子说将引发异常并带有特定的错误代码。

这个陈述正确吗？

- bairog

1

还没有 :) 我更喜欢在编码之前阅读教程 - 以获得优化和正确的解决方案... - bairog

1

如果您更喜欢“优化和正确的解决方案”，请不要将SQLite用于其未经优化的用途；它是一个很棒的数据库，但并不是一个很好的多用户数据库。 - Tim

3

我需要一个免费且轻量级（零配置和无服务器）的数据库用于我的项目。因此，大多数“多用户优化”的数据库对我来说不太合适 :) - bairog

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- bairog · Accepted Answer

我已经自己进行了调查:

我创建了一个样例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!");
            }
        }
    }
}

在我的Core2Duo E7500上的测试结果是：异常从未被触发！

看起来SQLite已经为我的需求做了足够的优化（根据SQLite FAQ所说，锁定/解锁非常快并且通常只需要几毫秒）- 很棒！

请注意，对于SQLiteException，没有必要检索整数ErrorCode - 您可以使用特殊的枚举ReturnCode字段。所有代码都在这里描述。

希望这些信息能够帮助到某些人。