1

我的应用程序遇到问题。它是一个桌面应用程序，由c#with制成，Sqlite DB用于缓存并且是多线程的。

我的问题有时caching operation是与来自其他线程的操作相冲突。

任何人都可以帮助我或如何解决这个困境？

我正在考虑解锁数据库（也许重新启动程序），但我知道这不是一个好方法。

4

2 回答 2

5

对于类似的问题进行搜索，共识似乎是您需要自己进行锁定。一些答案指向将同一个SqliteConnection对象传递给所有进行写入的线程。虽然我认为这不会解决问题。

我建议重新考虑并发写/读。我假设您的线程做了一些工作，然后保存到该线程中的数据库。我会重写它，以便线程做一些工作并返回输出。将数据保存到 db 的过程不需要与执行工作的过程相结合。并发读取应该无需更改即可工作，因为锁是shared用于读取的。当然，可能存在写入和读取同时发生的情况。在这种情况下，错误会再次弹出。

我认为仅使用全局变量lock object并使用它来同步/序列化所有写入/读取可能会更简单。但是，当您这样做时，您已经有效地使 db 访问成为单线程的。这是答案取决于您的最终目标的问题之一。

顺便说一句，您不应该使用数据库级别的事务而不是应用程序级别吗？类似http://msdn.microsoft.com/en-us/library/86773566.aspx

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    SqlCommand command = connection.CreateCommand();
    SqlTransaction transaction;

    // Start a local transaction.
    transaction = connection.BeginTransaction("SampleTransaction");

    // Must assign both transaction object and connection 
    // to Command object for a pending local transaction
    command.Connection = connection;
    command.Transaction = transaction;

    try
    {
        command.CommandText =
            "Insert into Region (RegionID, RegionDescription) VALUES (100, 'Description')";
        command.ExecuteNonQuery();
        command.CommandText =
            "Insert into Region (RegionID, RegionDescription) VALUES (101, 'Description')";
        command.ExecuteNonQuery();

        // Attempt to commit the transaction.
        transaction.Commit();
        Console.WriteLine("Both records are written to database.");
    }
    catch (Exception ex)
    {
        Console.WriteLine("Commit Exception Type: {0}", ex.GetType());
        Console.WriteLine("  Message: {0}", ex.Message);

        // Attempt to roll back the transaction. 
        try
        {
            transaction.Rollback();
        }
        catch (Exception ex2)
        {
            // This catch block will handle any errors that may have occurred 
            // on the server that would cause the rollback to fail, such as 
            // a closed connection.
            Console.WriteLine("Rollback Exception Type: {0}", ex2.GetType());
            Console.WriteLine("  Message: {0}", ex2.Message);
        }
    }
}
于 2013-10-03T09:15:47.537 回答
1

我想做同样的事情，将SQLiteDatabase链接到C# Application。我拿到：

Database is locked(5)

同样，我在代码中使用Transactions修复了这个问题，这是我使用的 Transaction 示例：

 using (TransactionScope tran = new TransactionScope())
 {
     //Perform action on SQLite Database here.


     tran.Complete();
 }
于 2013-10-03T07:30:29.127 回答