SQLite数据库database is locked解决

开发语言C#
主要通过配置数据库连接字符串解决
关键语句：Journal Mode=WAL；

/// <summary>
/// 数据库连接字符串
/// </summary>
public static readonly string ConnectionStr = @"Data Source=D:\Work\snqk_sys_wpf\snqk_sys_analysis.db;Connect Timeout=30;Pooling=true;Journal Mode=WAL";

操作SQLite帮助类，定义了增删改的加锁

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SQLite;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WpfSnqkGasAnalysis.Model;
using System.Collections.Concurrent;namespace WpfSnqkGasAnalysis.IData_impl
{/// <summary>/// 基础类，提供公有方法/// </summary>public class BaseDAL{/// <summary>/// 写入数据检查并发，不允许并发写。/// 防止数据库被锁抛出database is locked异常/// </summary>   private static ConcurrentDictionary<string, bool> insertCheck = new ConcurrentDictionary<string, bool>();/// <summary>/// 等待解锁时长，毫秒/// </summary>const int KONG_SECONDS = 30;/// <summary>/// (同步执行)执行原始sql语句/// </summary>/// <typeparam name="T"></typeparam>/// <param name="sql">原始sql语句</param>/// <param name="paramesDict">参数</param>/// <param name="action">委托，有返回值</param>/// <param name="exceptionAction">异常消息委托，调用者处理消息，比如存起来</param>/// <returns></returns>public virtual T ExecSqlCmd<T>(string sql, Dictionary<string, object> paramesDict, Func<DbCommand, T> action, Action<Exception> exceptionAction = null){//获取操作锁LockCheck(sql);System.Data.SQLite.SQLiteConnection connection = null;SQLiteCommand command = null;try{connection = new System.Data.SQLite.SQLiteConnection(CommonConfig.ConnectionStr);connection.Open();command = connection.CreateCommand();command.CommandText = sql;if (paramesDict?.Count > 0){foreach (var item in paramesDict){command.Parameters.AddWithValue(item.Key, item.Value);}}//调用方实现自己的逻辑，比如读取字段数据封装到实体if (action == null){return default;}return action.Invoke(command);}catch (Exception ex){var ex1 = ex.InnerException ?? ex;var ex2 = ex1.InnerException ?? ex1;LogHelpter.AddLog("数据库执行异常，" + ex2.Message + "。执行的sql:" + sql, null, "db_error");//异常消息返回给调用方处理。创建时间：2022-12-1 16:54:31exceptionAction?.Invoke(ex2);}finally{if (command != null){command.Dispose();}if (connection != null){connection.Close();connection.Dispose();}insertCheck.Clear();//解锁}return default;}/// <summary>/// (同步执行)执行原始sql语句/// </summary>/// <typeparam name="T"></typeparam>/// <param name="sql">原始sql语句</param>/// <param name="paramesDict">参数</param>/// <param name="action">委托</param>/// <param name="exceptionAction">异常消息委托，调用者处理消息，比如存起来</param>/// <returns></returns>public virtual void ExecSqlCmd(string sql, Dictionary<string, object> paramesDict, Action<DbCommand> action, Action<Exception> exceptionAction = null){LockCheck(sql);System.Data.SQLite.SQLiteConnection connection = null;SQLiteCommand command = null;try{connection = new System.Data.SQLite.SQLiteConnection(CommonConfig.ConnectionStr);connection.Open();command = connection.CreateCommand();command.CommandText = sql;if (paramesDict?.Count > 0){foreach (var item in paramesDict){command.Parameters.AddWithValue(item.Key, item.Value);}}//调用方实现自己的逻辑，比如读取字段数据封装到实体action?.Invoke(command);}catch (Exception ex){var ex1 = ex.InnerException ?? ex;var ex2 = ex1.InnerException ?? ex1;LogHelpter.AddLog("数据库执行异常，" + ex2.Message + "。执行的sql:" + sql, null, "db_error");//异常消息返回给调用方处理。创建时间：2022-12-1 16:54:31exceptionAction?.Invoke(ex2);}finally{if (command != null){command.Dispose();}if (connection != null){connection.Close();connection.Dispose();}insertCheck.Clear();//解锁}}/// <summary>/// 获取操作锁，同一时间只允许一个操作执行/// </summary>private static void LockCheck(string sql){//写入数据并发检查。否则会导致数据库锁定if (sql.IndexOf("insert", StringComparison.OrdinalIgnoreCase) >= 0|| sql.IndexOf("delete", StringComparison.OrdinalIgnoreCase) >= 0|| sql.IndexOf("update", StringComparison.OrdinalIgnoreCase) >= 0){while (insertCheck.Count > 0){System.Threading.Thread.Sleep(KONG_SECONDS);//System.Threading.Thread.SpinWait(KONG_SECONDS);//Task.Delay(KONG_SECONDS).Wait();}insertCheck.TryAdd("insert", true);}只允许一个操作//while (insertCheck.Count > 0)//{//    LogHelpter.AddLog("数据库正忙...");//    System.Threading.Thread.Sleep(KONG_SECONDS);//    //System.Threading.Thread.SpinWait(KONG_SECONDS);//    //Task.Delay(KONG_SECONDS).Wait();//}LogHelpter.AddLog("拿取到DB操作权限，"+sql);insertCheck.TryAdd("112", true);}}
}

SQLite数据库database is locked解决相关推荐

sqlite遇到database is locked问题的完美解决
这两天在项目中用大强度大频率的方法测试时遇到sqlite报database is locked的问题, 分析下来原因是sqlite对数据库做修改操作时会做(文件)锁使得其它进程同一时间使用时会报该错误 ...
SQLITE数据库损坏分析及解决
1 前言本文主要阐述SQLTE数据库文件在异常场景下发生损坏的原因及提供相应的解决方案.本文涉及代码部分的SQLITE库使用SQLITE_VERSION 3.20.1. 2 数据库异常操作 SQLT ...
【Laravel】连接 sqlite 数据库 Database [xxx] not exist
.env 文件 DB_CONNECTION=sqlite VIRSH_SQLITE_DATABASE=database_path('database.sqlite') config/database. ...
Sqlite出现database is locked
一个方法内很多次对单个表的单个数据的操作时会出现这个错误在网上看到个处理办法: 1.可以加锁 object obj=new object(); lock (obj) { } 但我这个程序肯定只会同时 ...
sqlite database is locked 问题解决方案
这两天在项目中用大强度大频率的方法测试时遇到sqlite报database is locked的问题, 分析下来原因是sqlite对数据库做修改操作时会做(文件)锁使得其它进程同一时间使用时会报该错误 ...
python database is locked_sqlite遇到database is locked问题的完美解决
这两天在项目中用大强度大频率的方法测试时遇到sqlite报database is locked的问题, 分析下来原因是sqlite对数据库做修改操作时会做(文件)锁使得其它进程同一时间使用时会报该错误 ...
hue集成mysql报错_hue集成hive访问报database is locked
这个问题这应该是hue默认的SQLite数据库出现错误,你可以使用mysql postgresql等来替换 hue默认使用sqlite作为元数据库,不推荐在生产环境中使用.会经常出现database ...
close() was never explicitly called on database 和 database is locked 错误原因
1.cursor 使用完没有关闭. 2.数据库用完没有关闭. 3.数据库重复新建(new了多个对象). 我的错误是new了多个对象. LogCat 报错信息: [java] view plaincop ...
.NET 中使用 SQlite 数据库_1.新数据库的创建
1.先在项目中添加对"System.data.SQLite.dll"的引用,如果没有可以到官网去下载 C# 创建新的SQlite数据库Database(两个方法) 1. 使用Sys ...

SQLite数据库database is locked解决

操作SQLite帮助类，定义了增删改的加锁

SQLite数据库database is locked解决相关推荐

最新文章

热门文章