当你在多线程中只使用一个SQLiteDatabase的引用时,需要格外注意你SQLiteDataBase.close()调用的时机,因为你是使用的同一个引用,比如在一个线程中当一个Add操作结束后立刻关闭了数据库连接,而另一个现场中正准备执行查询操作,但此时db已经被关闭了,然后就会报异常错误。此时一般有三种解决方案,
简单粗暴给所有的CRUD添加一个 synchronized关键字;
永远不关闭数据库连接,只在最后退出是关闭连接。其实每次执行getWriteableDataBase()或getReadableDatabase()方法时,如果有已经建立的数据库连接则直接返回(例外:如果旧的连接是以只读方式打开的,则会在新建连接成功的前提下,关闭旧连接),所以程序中将始终保持有且只有一个数据库连接(前提是单例),资源消耗的很少。
可以自己进行引用计数,简单示例代码如下:
public static DBHelper getInstance(Context context) {
/**
* 只有在为空的时候,会有同步锁的影响
*/
if (mInstance == null) {
synchronized (DBHelper.class) {
if (mInstance == null) {
mInstance = new DBHelper(context);
}
}
}
return mInstance;
};
在不同的线程中去操作数据库:
线程一:
DBManagerCorrect manager = new DBManagerLocked(MainActivity.this);
SQLiteDatabase openDb = manager.openDb();
manager.insertAll();
manager.CloseDb(openDb);
线程二:
DBManagerCorrect manager = new DBManagerLocked(MainActivity.this);
SQLiteDatabase openDb = manager.openDb();
manager.insertAll();
manager.CloseDb(openDb);
对数据库
/**
* 记数器 应该设置静态的类变量
* @param context
*/
private static int mCount;
//同一个数据库连接
private static DBManagerCorrect mMnanagerInstance;
private DBManagerCorrect(Context context) {
helper = DBHelper.getInstance(context);
}
//单例
public static synchronized DBManagerCorrect getIntance(Context context){
if(mMnanagerInstance==null){
return new DBManagerCorrect(context);
}
return mMnanagerInstance;
}
public synchronized SQLiteDatabase openDb(){
if(mCount==0){
db=helper.getWritableDatabase();
}
mCount++;
return db;
}
public synchronized void CloseDb(SQLiteDatabase database){
mCount--;
if(mCount==0){
database.close();
}
}
上面的代码主要思想是引入一个用于计算的静态变量mCount。这样一来我们操作数据库时调用(manager.openDb())每次打开数据连接的时候加一,每次关闭(manager.ColoseDb())的时候再减一。这样一来如果该值不减到零的时候不会关闭数据库。如果该值减到零说明没有数据库连接在使用,就可以正常关闭数据库。这样可以很轻松的避免出现上面的异常,再使用的时候也完成不需要担心数据库的关闭,只需要调用manager的这个两个函数即可。
- 上面的代码可以进一步优化:
//打开数据库方法
public synchronized SQLiteDatabase openDatabase() {
AtomicInteger mOpenCounter = new AtomicInteger();
if (mOpenCounter.incrementAndGet() == 1) {
// Opening new database
try {
mDatabase = sInstance.getWritableDatabase();
} catch (Exception e) {
mDatabase = sInstance.getReadableDatabase();
}
}
return mDatabase;
}
//关闭数据库方法
public synchronized void closeDatabase() {
if (mOpenCounter.decrementAndGet() == 0) {
// Closing database
mDatabase.close();
}
}
上面借助了AtomicInteger 解决多线程并发 ,对应AtomicInteger可以参考解:https://blog.csdn.net/gong_yangyang/article/details/77281456