使用C#访问sqlite时,常会遇到多线程并发导致SQLITE数据库损坏的问题。
SQLite是文件级别的数据库,其锁也是文件级别的:多个线程可以同时读,但是同时只能有一个线程写。Android提供了SqliteOpenHelper类,加入Java的锁机制以便调用。但在C#中未提供类似功能。
作者利用读写锁(ReaderWriterLock),达到了多线程安全访问的目标。
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
// 使用单例,解决初始化与销毁时的问题
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
// 手动控制销毁,保证数据完整性
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
protected void Dispose(bool disposing)
{
if (!m_disposed)
{
if (disposing)
{
// Release managed resources
Console.WriteLine("关闭本地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("严重异常: 无法关闭本地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");
//加锁,直到释放前,其它线程无法得到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
}
}
////////////////////////
调用的代码如下:
SQLiteConnection conn = null;
try
{
conn = SqliteConn.GetInstance().GetConnection();
//在这里写自己的代码
}
finally
{
SqliteConn.GetInstance().ReleaseConn();
}
值得注意的是,每次申请连接后,必须使用ReleaseConn方法释放,否则其它线程就再也无法得到连接了。
安全起见,在作者写的这个工具类中,启用了最严格的读写锁限制(即在写入时无法读取)。如果数据读取频繁,读者亦可开发一个得到只读连接的方法以提高性能。
在Winxp/Win7/Win8/Win8.1 32/64位下测试通过。
分享到:
相关推荐
本文实例讲述了C#解决SQlite并发异常问题的方法。分享给大家供大家参考,具体如下: 使用C#访问sqlite时,常会遇到多线程并发导致SQLITE数据库损坏的问题。 SQLite是文件级别的数据库,其锁也是文件级别的:多个线程...
多线程读写sqlite数据库,同步锁,计时测试读写性能,
System.Data.SQLite.DLL C# 读写sqlite数据库 亲测可用 不能读取加密的sqlite数据库
本文实例讲述了C#操作SQLite数据库之读写数据库的方法。分享给大家供大家参考,具体如下: 这里演示读写数据库并在窗体(Form)中显示其数据,其方式为: 读: Database(SQLite) -> DataAdapter -> DataSet -> ...
这是一个C#.NET示例程序, 简单演示了如何使用C#操作SQLite数据库。同时演示了如何用C#讲图片二进制数据存储到数据库和从数据库读取图片二进制数据并显示在PictureBox.
一种非常简单的方式解决Sqlite中文排序问题(网页)
基于python实现的sqlite队列,方便的处理sqlite并发。SqliteQueue是继承了threading.Thread的线程,并且维护了一个向sqlite请求的队列。支持peewee请求。SqlQuery简单的封装了SQL语句
如果多线程同时读写(这里的指不同的线程用使用的是不同的Helper实例),后面的就会遇到android.database.sqlite.SQLiteException: database is locked这样的异常。对于这样的问题,解决的办法就是keep single ...
这是一个使用C#开发的Sqlite数据库创建、操作的源码工程,关于Sqlite的所有操作已经单独创建了专门的跨平台【.NETCore3.1】类库包含相应的帮助类,可以直接生成后拿到任何项目中直接使用,高效简单,省去了从头开发...
采用ReaderWriterLockSlim锁,实现读写锁分离,多线程操作sqlite...参考 让C#轻松实现读写锁分离--封装ReaderWriterLockSlim C#解决SQlite并发异常问题的方法(使用读写锁)2篇文章,已经封装sqlite常用增删改查函数。
用C#实现了对sqlite数据库的操作,包括动态连接库的引用,数据库操作类,增删改查,操作方便。
通过C#读写SQLite文件。
C# sqlite 批量更新及性能测试
多进程写sqlite数据库解决互斥的方案,当然代码也顺便处理了多线程写数据库的问题。
Sqlite的C#通用类和Sqlite工具(SQLiteExpertPersSetup.exe),直接使用
主要介绍了C#实现Excel导入sqlite的方法,是C#程序设计中非常重要的一个实用技巧,需要的朋友可以参考下
如何使用C#操作SQLite数据库如何使用C#操作SQLite数据库
主要介绍了SQLite教程(十二):锁和并发控制详解,本文讲解了锁和并发控制机制概述、文件锁、回滚日志、数据写入、SQL级别的事务控制等内容,需要的朋友可以参考下
c# sqlite 读写应用项目,可应用于实现项目上。项目需要应用到x86的SQLite.Interop.dll。