66 lines
2.1 KiB
Java
66 lines
2.1 KiB
Java
package org.schabi.newpipe;
|
|
|
|
import android.content.Context;
|
|
import android.database.Cursor;
|
|
|
|
import androidx.annotation.NonNull;
|
|
import androidx.room.Room;
|
|
|
|
import org.schabi.newpipe.database.AppDatabase;
|
|
|
|
import static org.schabi.newpipe.database.AppDatabase.DATABASE_NAME;
|
|
import static org.schabi.newpipe.database.Migrations.MIGRATION_1_2;
|
|
import static org.schabi.newpipe.database.Migrations.MIGRATION_2_3;
|
|
import static org.schabi.newpipe.database.Migrations.MIGRATION_3_4;
|
|
|
|
public final class NewPipeDatabase {
|
|
private static volatile AppDatabase databaseInstance;
|
|
|
|
private NewPipeDatabase() {
|
|
//no instance
|
|
}
|
|
|
|
private static AppDatabase getDatabase(final Context context) {
|
|
return Room
|
|
.databaseBuilder(context.getApplicationContext(), AppDatabase.class, DATABASE_NAME)
|
|
.addMigrations(MIGRATION_1_2, MIGRATION_2_3, MIGRATION_3_4)
|
|
.build();
|
|
}
|
|
|
|
@NonNull
|
|
public static AppDatabase getInstance(@NonNull final Context context) {
|
|
AppDatabase result = databaseInstance;
|
|
if (result == null) {
|
|
synchronized (NewPipeDatabase.class) {
|
|
result = databaseInstance;
|
|
if (result == null) {
|
|
databaseInstance = getDatabase(context);
|
|
result = databaseInstance;
|
|
}
|
|
}
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
public static void checkpoint() {
|
|
if (databaseInstance == null) {
|
|
throw new IllegalStateException("database is not initialized");
|
|
}
|
|
final Cursor c = databaseInstance.query("pragma wal_checkpoint(full)", null);
|
|
if (c.moveToFirst() && c.getInt(0) == 1) {
|
|
throw new RuntimeException("Checkpoint was blocked from completing");
|
|
}
|
|
}
|
|
|
|
public static void close() {
|
|
if (databaseInstance != null) {
|
|
synchronized (NewPipeDatabase.class) {
|
|
if (databaseInstance != null) {
|
|
databaseInstance.close();
|
|
databaseInstance = null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|