日期:2014-05-16  浏览次数:20406 次

SQLiteDatabase使用问题总结

SQLiteDatabase使用过程中经常碰到的问题

1.DatabaseHelper在onCreate或者是onUpdate的时候调用DatabaseHelper.getWriteDatabase获取SQLiteDatabase

会导致一个递归死循环

解决方案:

如果在onCreate或者是onUpdate的时候需要获取一个SQLiteDatabase进行数据的读取与写入,应该在onCreate或者是onUpdate的时候设定这个过程中本身对应的SQLiteDatabase

?

2.多个线程中同时进行多张数据表的写(读数据是没有关系的)

写数据的使用,应该使用线程锁synchronized进行锁定,同时线程锁的对象应该是整个app中相同的database中完全一样的

?

3.多个线程中进行多张数据表的写,写完之后调用SQLiteDatabase.close进行了资源的关闭

例如,存在A,B,C,D...N多个线程,其中,B线程中在数据写完后进行了Databse.close操作

在A线程拿到线程锁进行写数据的时候,SQLiteDatabase会提示数据库已经关闭,不能进行数据的写入操作

解决方案:在获取writableDatabase的与readableDatabase的时候,应该通过函数来完成,例如:

private AtomicInteger mOpenCounter = new AtomicInteger();
	/**
	 * openDatabase与relaseDatabase需要配对出现
	 * @return
	 */
	public synchronized SQLiteDatabase openWriteDatabase() {
		final String userId = this.mCurrentUserId;
		DatabaseSQLiteHelper helper = getSQLiteHelper(userId);
		SQLiteDatabase db = getSQLiteHelper(userId).getDefaultWritableDatabase();
		//db为空的情况或者是db已经关闭的情况
		if(db == null || !db.isOpen()){
			db = helper.getWritableDatabase();
			helper.setDefaultWritableDatabase(db);
		}
		//每次调用一次,就将计数器往上加1次
		incrementDatabseUsed(helper);
		return db;
	}
	
	/**
	 * openDatabase与relaseDatabase需要配对出现
	 * @return
	 */
	public synchronized void relaseWriteDatabase(){
		decrementWriteDatabseUsed(true);
	}
	
	private Object mAtomicLoker = new Object();
	void incrementDatabseUsed(DatabaseSQLiteHelper helper){
		synchronized (mAtomicLoker) {
			int result = mOpenCounter.incrementAndGet();
		}
	}
	
	void decrementWriteDatabseUsed(boolean isCloseDatabse){
		synchronized (mAtomicLoker) {
			final String userId = this.mCurrentUserId;
			if(TextUtils.isEmpty(userId)){
				return;
			}
			DatabaseSQLiteHelper helper = getSQLiteHelper(userId);
			int result = mOpenCounter.decrementAndGet();
			
			if(isCloseDatabse && !helper.isDoingDataMigratoring){
				if(result <= 0){
					SQLiteDatabase db = helper.getDefaultWritableDatabase();
					if(db != null){
						db.close();
					}
					db = helper.getReadableDatabase();
					if(db != null){
						int currentResult = mOpenCounter.get();
						if(currentResult <= 0){
							db.close();
						}
					}
				}
			}
		}
	}

?