sqlite数据库,同一时刻允许多个进程/线程读,但同一时刻只允许一个线程写。在操行写操作时,数据库文件被琐定,此时任何其他读/写操作都被阻塞,如果阻塞超过5秒钟(默认是5秒,能过重新编译sqlite可以修改超时时间),就报"database is locked"错误。
SQLite是文件级别的锁:多个线程可以同时读,但是同时只能有一个线程写。Android提供了SqliteOpenHelper类,加入Java的锁机制以便调用。
如果多线程同时读写(这里的指不同的线程用使用的是不同的Helper实例),后面的就会遇到android.database.sqlite.SQLiteException: database is locked这样的异常。对于这样的问题,解决的办法就是保持sqlite连接单例,保持单个SqliteOpenHelper实例,同时对所有数据库操作的方法添加synchronized关键字。也就是说是读写数据库时存在的同步问题,所以采用单例+同步锁的方法,并且在每次数据库操作后都关闭数据库
1、DBHelper 用单例
public class DBHelper extends SQLiteOpenHelper {
private final String TAG = "DBHelper";
private final static String DATABASE_NAME = "stu.db";
private final static String TABLE_NAME = "student";
private final static int DATABASE_VERSION = 1;
private static DBHelper mInstance;
public DBHelper(Context context) {
super(context, DATABASE_NAME, null, DATABASE_VERSION);
}
@Override
public void onCreate(SQLiteDatabase db) {
db.execSQL("CREATE TABLE IF NOT EXISTS " + TABLE_NAME
+ "(_id INTEGER PRIMARY KEY AUTOINCREMENT, name, age)");
}
//获取单例
public synchronized static DBHelper getInstance(Context context) {
if (mInstance == null) {
mInstance = new DBHelper(context.getApplicationContext());
}
return mInstance;
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
// 删除原来的数据表
db.execSQL("DROP TABLE IF EXISTS " + TABLE_NAME);
// 重新创建
onCreate(db);
}
}
2、写操作加同步锁
public class StudentManager {
//表的名字和字段的常量
private static final String TABLE_NAME = "student";
private static final String KEY_ID = "_id";
private static final String KEY_NAME = "name";
private static final String KEY_AGE = "age";
private DBHelper dbHelper;
public StudentManager(Context context) {
//初始化DbHelper
dbHelper = DBHelper.getInstance(context);
}
//添加单个联系人
public synchronized boolean insert(Student stu) throws Exception {
//如果数据库不存在,则创建并打开。否则,直接打开。
SQLiteDatabase db = dbHelper.getReadableDatabase();
//数据添加的操作
ContentValues cv = new ContentValues();
cv.put(KEY_NAME, stu.getName());
cv.put(KEY_AGE, stu.getAge());
long id = db.insert(TABLE_NAME, null, cv);
//关闭数据库
db.close();
if (id == -1) {
return false;//插入失败
}
return true;
}
//查询所有联系人
public List<Student> getAll() throws Exception {
List<Student> stus = new ArrayList<>();
//查询数据,放入集合
//打开数据库
SQLiteDatabase db = dbHelper.getReadableDatabase();
//执行查询操作
Cursor cursor = db.query(TABLE_NAME, null, null, null, null, null, null);
//Cursor是游标(集),存放了你的数据的
//先根据字段的名称,获得字段的id
int idIndex = cursor.getColumnIndex(KEY_ID);
int nameIndex = cursor.getColumnIndex(KEY_NAME);
int ageIndex = cursor.getColumnIndex(KEY_AGE);
while (cursor.moveToNext()) {
//取指定位置的数据,参数指的是字段的下标,从0开始
int id = cursor.getInt(idIndex);
String name = cursor.getString(nameIndex);
int age = cursor.getInt(ageIndex);
Student stu = new Student(name, age);
stus.add(stu);
}
//关闭游标
cursor.close();
//关闭数据库
db.close();
return stus;
}
}
总结
1、多线程访问造成的数据库锁定。
如A线程在访问当前的数据库,这时候B线程也需要访问数据库,这样在B线程中,就会有类似以上的异常产生,我们需要将提供数据库访问的方法设置成同步的,防止异步调用时出现问题,如:
public static synchronized DBConnection getConnection(String connectionName) throws Exception {
String pathFile = getPath() + connectionName;// 转换目录data下
return new DBConnection(SQLiteDatabase.openDatabase(pathFile,
null, SQLiteDatabase.OPEN_READWRITE)); }
使用synchronized 关键字来修饰获取数据库连接的方法,或者使用isDbLockedByOtherThreads方法判断数据库是否被锁住了,然后等待一定的时间再进行访问。
2、·sqlite自身的问题
有时我们会在调试程序的时候发现Log控制台频繁的出现上述异常,而在运行程序的时候就没有这个问题,这种现象我在调试ResultSet时也会出现,查资料找原因是因为sqlite数据不完全是线程安全的,导致在一些地方会莫名其妙的出问题,如果遇到这样的情况,那只能不要将断点打到数据库连接的地方了。
3、如果多线程同时读写(这里的指不同的线程用使用的是不同的Helper实例),后面的就会遇到database.sqlite.SQLiteException: database is locked这样的异常。对于这样的问题,解决的办法就是keep single sqlite connection,保持单个SqliteOpenHelper实例,同时对所有数据库操作的方法添加synchronized关键字。