android|android sqlite数据库并发问题 androidsqlite数据库并发问题

当你在多线程中只使用一个SQLiteDatabase的引用时，需要格外注意你SQLiteDataBase.close()调用的时机，因为你是使用的同一个引用，比如在一个线程中当一个Add操作结束后立刻关闭了数据库连接，而另一个现场中正准备执行查询操作，但此时db已经被关闭了，然后就会报异常错误。此时一般有三种解决方案，

简单粗暴给所有的CRUD添加一个 synchronized关键字；
永远不关闭数据库连接，只在最后退出是关闭连接。其实每次执行getWriteableDataBase()或getReadableDatabase()方法时，如果有已经建立的数据库连接则直接返回(例外:如果旧的连接是以只读方式打开的，则会在新建连接成功的前提下，关闭旧连接)，所以程序中将始终保持有且只有一个数据库连接(前提是单例)，资源消耗的很少。
可以自己进行引用计数，简单示例代码如下：

publicstatic 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 staticint 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(); } }

【android|android sqlite数据库并发问题】上面借助了AtomicInteger 解决多线程并发，对应AtomicInteger可以参考解：https://blog.csdn.net/gong_yangyang/article/details/77281456