Castopod/AntennaPod
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Enable sqlite WAL

Browse Source
This commit is contained in:
Martin Fietz 2015-11-26 17:02:21 +01:00
parent 719075bbf9
commit ec03d548f0
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/src/main/java/de/danoeh/antennapod/core/storage/PodDBAdapter.java
View File

@ -10,6 +10,7 @@ import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory; import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper; import android.database.sqlite.SQLiteOpenHelper;
import android.media.MediaMetadataRetriever; import android.media.MediaMetadataRetriever;
import android.os.Build;
import android.text.TextUtils; import android.text.TextUtils;
import android.util.Log; import android.util.Log;
@ -18,7 +19,6 @@ import org.apache.commons.lang3.Validate;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import de.danoeh.antennapod.core.R; import de.danoeh.antennapod.core.R;
import de.danoeh.antennapod.core.event.ProgressEvent; import de.danoeh.antennapod.core.event.ProgressEvent;
@ -283,7 +283,7 @@ public class PodDBAdapter {
private SQLiteDatabase db; private SQLiteDatabase db;
private static Context context; private static Context context;
private static PodDBHelper dbHelper; private static PodDBHelper dbHelper;
private static AtomicInteger counter = new AtomicInteger(0); private static int counter = 0;
public static void init(Context context) { public static void init(Context context) {
PodDBAdapter.context = context.getApplicationContext(); PodDBAdapter.context = context.getApplicationContext();
@ -298,12 +298,15 @@ public class PodDBAdapter {
private PodDBAdapter() {} private PodDBAdapter() {}
public PodDBAdapter open() { public synchronized PodDBAdapter open() {
counter.incrementAndGet(); counter++;
if (db == null || !db.isOpen() || db.isReadOnly()) { if (db == null || !db.isOpen() || db.isReadOnly()) {
Log.v(TAG, "Opening DB"); Log.v(TAG, "Opening DB");
try { try {
db = dbHelper.getWritableDatabase(); db = dbHelper.getWritableDatabase();
if(Build.VERSION.SDK_INT >= 11) {
db.enableWriteAheadLogging();
}
} catch (SQLException ex) { } catch (SQLException ex) {
Log.e(TAG, Log.getStackTraceString(ex)); Log.e(TAG, Log.getStackTraceString(ex));
db = dbHelper.getReadableDatabase(); db = dbHelper.getReadableDatabase();
@ -312,13 +315,14 @@ public class PodDBAdapter {
return this; return this;
} }
public void close() { public synchronized void close() {
if(counter.decrementAndGet() == 0) { counter--;
if(counter == 0) {
Log.v(TAG, "Closing DB"); Log.v(TAG, "Closing DB");
db.close(); db.close();
}
db = null; db = null;
} }
}
public static boolean deleteDatabase() { public static boolean deleteDatabase() {
if(dbHelper != null) { if(dbHelper != null) {