C#解決SQlite并發(fā)異常問題的方法(使用讀寫鎖)

更新時(shí)間：2016年07月05日 16:18:51 作者：yacki

這篇文章主要介紹了C#解決SQlite并發(fā)異常問題的方法,通過使用讀寫鎖達(dá)到多線程安全訪問,進(jìn)而解決SQLite并發(fā)異常的問題,具有一定參考借鑒價(jià)值,需要的朋友可以參考下

本文實(shí)例講述了C#解決SQlite并發(fā)異常問題的方法。分享給大家供大家參考，具體如下：

使用C#訪問sqlite時(shí)，常會(huì)遇到多線程并發(fā)導(dǎo)致SQLITE數(shù)據(jù)庫(kù)損壞的問題。

SQLite是文件級(jí)別的數(shù)據(jù)庫(kù)，其鎖也是文件級(jí)別的：多個(gè)線程可以同時(shí)讀，但是同時(shí)只能有一個(gè)線程寫。Android提供了SqliteOpenHelper類，加入Java的鎖機(jī)制以便調(diào)用。但在C#中未提供類似功能。

作者利用讀寫鎖（ReaderWriterLock），達(dá)到了多線程安全訪問的目標(biāo)。

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SQLite;
using System.Threading;
using System.Data;
namespace DataAccess
{
/////////////////
public sealed class SqliteConn
{
  private bool m_disposed;
  private static Dictionary<String, SQLiteConnection> connPool =
    new Dictionary<string, SQLiteConnection>();
  private static Dictionary<String, ReaderWriterLock> rwl =
    new Dictionary<String, ReaderWriterLock>();
  private static readonly SqliteConn instance = new SqliteConn();
  private static string DEFAULT_NAME = "LOCAL";
  #region Init
  // 使用單例，解決初始化與銷毀時(shí)的問題
  private SqliteConn()
  {
    rwl.Add("LOCAL", new ReaderWriterLock());
    rwl.Add("DB1", new ReaderWriterLock());
    connPool.Add("LOCAL", CreateConn("\\local.db"));
    connPool.Add("DB1", CreateConn("\\db1.db"));
    Console.WriteLine("INIT FINISHED");
  }
  private static SQLiteConnection CreateConn(string dbName)
  {
    SQLiteConnection _conn = new SQLiteConnection();
    try
    {
      string pstr = "pwd";
      SQLiteConnectionStringBuilder connstr = new SQLiteConnectionStringBuilder();
      connstr.DataSource = Environment.CurrentDirectory + dbName;
      _conn.ConnectionString = connstr.ToString();
      _conn.SetPassword(pstr);
      _conn.Open();
      return _conn;
    }
    catch (Exception exp)
    {
      Console.WriteLine("===CONN CREATE ERR====\r\n{0}", exp.ToString());
      return null;
    }
  }
  #endregion
  #region Destory
  // 手動(dòng)控制銷毀，保證數(shù)據(jù)完整性
  public void Dispose()
  {
    Dispose(true);
    GC.SuppressFinalize(this);
  }
  protected void Dispose(bool disposing)
  {
    if (!m_disposed)
    {
      if (disposing)
      {
        // Release managed resources
        Console.WriteLine("關(guān)閉本地DB連接...");
        CloseConn();
      }
      // Release unmanaged resources
      m_disposed = true;
    }
  }
  ~SqliteConn()
  {
    Dispose(false);
  }
  public void CloseConn()
  {
    foreach (KeyValuePair<string, SQLiteConnection> item in connPool)
    {
      SQLiteConnection _conn = item.Value;
      String _connName = item.Key;
      if (_conn != null && _conn.State != ConnectionState.Closed)
      {
        try
        {
          _conn.Close();
          _conn.Dispose();
          _conn = null;
          Console.WriteLine("Connection {0} Closed.", _connName);
        }
        catch (Exception exp)
        {
          Console.WriteLine("嚴(yán)重異常: 無(wú)法關(guān)閉本地DB {0} 的連接。", _connName);
          exp.ToString();
        }
        finally
        {
          _conn = null;
        }
      }
    }
  }
  #endregion
  #region GetConn
  public static SqliteConn GetInstance()
  {
    return instance;
  }
  public SQLiteConnection GetConnection(string name)
  {
    SQLiteConnection _conn = connPool[name];
    try
    {
      if (_conn != null)
      {
        Console.WriteLine("TRY GET LOCK");
        //加鎖，直到釋放前，其它線程無(wú)法得到conn
        rwl[name].AcquireWriterLock(3000);
        Console.WriteLine("LOCK GET");
        return _conn;
      }
    }
    catch (Exception exp)
    {
      Console.WriteLine("===GET CONN ERR====\r\n{0}", exp.StackTrace);
    }
    return null;
  }
  public void ReleaseConn(string name)
  {
    try
    {
      //釋放
      Console.WriteLine("RELEASE LOCK");
      rwl[name].ReleaseLock();
    }
    catch (Exception exp)
    {
      Console.WriteLine("===RELEASE CONN ERR====\r\n{0}", exp.StackTrace);
    }
  }
  public SQLiteConnection GetConnection()
  {
    return GetConnection(DEFAULT_NAME);
  }
  public void ReleaseConn()
  {
    ReleaseConn(DEFAULT_NAME);
  }
  #endregion
}
}
////////////////////////

調(diào)用的代碼如下：

SQLiteConnection conn = null;
try
{
  conn = SqliteConn.GetInstance().GetConnection();
  //在這里寫自己的代碼
}
finally
{
  SqliteConn.GetInstance().ReleaseConn();
}

值得注意的是，每次申請(qǐng)連接后，必須使用ReleaseConn方法釋放，否則其它線程就再也無(wú)法得到連接了。

安全起見，在作者寫的這個(gè)工具類中，啟用了最嚴(yán)格的讀寫鎖限制（即在寫入時(shí)無(wú)法讀取）。如果數(shù)據(jù)讀取頻繁，讀者亦可開發(fā)一個(gè)得到只讀連接的方法以提高性能。

在Winxp/Win7/Win8/Win8.1 32/64位下測(cè)試通過。

更多關(guān)于C#相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《C#程序設(shè)計(jì)之線程使用技巧總結(jié)》、《C#操作Excel技巧總結(jié)》、《C#中XML文件操作技巧匯總》、《C#常見控件用法教程》、《WinForm控件用法總結(jié)》、《C#數(shù)據(jù)結(jié)構(gòu)與算法教程》、《C#數(shù)組操作技巧總結(jié)》及《C#面向?qū)ο蟪绦蛟O(shè)計(jì)入門教程》

希望本文所述對(duì)大家C#程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: