C＃+ SQLite - 数据库锁

Question

我面临我的应用程序的问题。它是一个桌面应用程序，由c＃和Sqlite DB进行缓存并且是多线程的。 我的问题是有时候缓存操作与其他线程的操作冲突。

任何人都可以帮我解决还是如何解决是两难境地？

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

Answer 1

我想做同样的事情，将SQLite数据库链接到C＃应用程序。我得到了：

Database is locked(5)

藏汉，我解决了这个在我的代码使用Transactions，这里是一个交易我用一个例子：

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


    tran.Complete(); 
} 

Answer 2

SO Searcing类似的问题，共识似乎你需要自己锁定。一些答案指出将相同的SqliteConnection对象传递给所有写入的线程。虽然我认为这不会解决问题。

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

我认为使用全局的lock object可能会更简单，并使用它来同步/序列化所有的写/读操作。然而，当你这样做的时候，你已经有效地使数据库访问单线程。这是其中一个问题，答案取决于你的最终目标是什么。

顺便说一句，你不应该使用数据库级别的事务，而不是应用程序级别？像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); 
     } 
    } 
}