Então estou enfrentando alguns problemas com minha conexão com o SQLite, onde não estou encontrando uma solução hábil.
Cenário
Meu cenário é o seguinte:
- Faço sincronização dos dados do meu aplicativo com um sistema legado, através de um WebService;
- Está sincronização é feita através de uma Thread que verifica o que há de novo na base legada e inicia varias outras Threads para obter os dados e salva-los em sua base local (SQLite);
- Para cada entidade que é encontrado novos dados na base legado é aberta uma nova Thread, (cada entidade tem um EndPoint, onde é acessado, baixado, e salvo os dados, e depois finalizada a Thread). Ex: se há novos clientes na base legada, é iniciada uma requisição que irá buscar todos os novos clientes, e salva-os em minha tabela de clientes no SQLite, isso executaria em uma Thread;
Problema
O problema é que mesmo que uso AsyncTask.SERIAL_EXECUTOR
que somente executa uma Thread por vez, entre uma abertura e outra de conexão acaba gerando problema de Lock, onde não consigo obter a referencia current da conexão e ao tentar criar um nova ele acusa que o db está Locked.
Acredito que meu problema nem é com as Threads executando simultaneamente, mas sim em minha class
de gerenciamento de conexão, a que estou utilizando atualmente é está:
public abstract class GConexaoAdapter {
private final DatabaseHelper mDbHelper;
private SQLiteDatabase mDb;
protected final Context ctx;
public GConexaoAdapter(Context ctx, String dbName, int dbVersion) {
this.mDbHelper = new DatabaseHelper(ctx, dbName, dbVersion);
this.ctx = ctx;
}
private void open() {
try {
synchronized (ctx) {
synchronized (mDbHelper) {
if (mDb == null) {
mDb = mDbHelper.getWritableDatabase();
} else {
synchronized (mDb) {
mDb = mDbHelper.getWritableDatabase();
}
}
}
}
} catch (IllegalStateException e) {
e.printStackTrace();
if (mDb == null || !mDb.isOpen())
mDb = ctx.openOrCreateDatabase(mDbHelper.getDatabaseName(), 0,
null);
Log.i("TRATAR", "tratar");
}
}
protected SQLiteDatabase getConexao() {
synchronized (ctx) {
synchronized (mDbHelper) {
if (mDb == null) {
this.open();
} else if (!mDb.isOpen()) {
synchronized (mDb) {
if (!mDb.isOpen()) {
this.open();
}
}
}
return mDb;
}
}
}
protected void closeConexao() {
synchronized (ctx) {
synchronized (mDbHelper) {
if (mDb != null && mDb.isOpen()) {
synchronized (mDb) {
if (mDb.isOpen()) {
if (mDb.inTransaction()) {
mDb.endTransaction();
}
mDb.close();
}
}
}
}
}
}
private static class DatabaseHelper extends SQLiteOpenHelper {
@Override
public void onOpen(SQLiteDatabase db) {
super.onOpen(db);
if (!db.isReadOnly()) {
// db.execSQL("PRAGMA foreign_keys=ON;");
}
}
DatabaseHelper(Context context, String dbNome, int dbVersion) {
super(context, dbNome, null, dbVersion);
}
@Override
public void onCreate(SQLiteDatabase db) {
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
}
}
}
Acredito que nem necessito de todos os synchronized
que tenho, é que já tentei diversas soluções que encontrei e nenhuma me trouxe o resultado esperado.
Pergunta?
Acredito que até haja uma "Receita de Bolo" para este tipo de gerenciamento de conexão. Pois não devo ser o único a necessitar de uma solução como está.
Então como faria para gerenciar de forma, eficaz minha conexão com o banco de dados SQLite?
Observação muito importante:
Gostaria de gerenciar a conexão SQLite entre várias thread simultâneas, porém sem causar locks que acabam gerando exceções e violando a integridade dos dados!