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关键字。
网友评论