X-Git-Url: https://git.ktnx.net/?p=mobile-ledger.git;a=blobdiff_plain;f=app%2Fsrc%2Fmain%2Fjava%2Fnet%2Fktnx%2Fmobileledger%2Fdb%2FDB.java;h=482628888b1b021c9b78d53eb159ab974c479d2e;hp=cff1d9c14f62452ad80c0af679e81099477a1263;hb=833544eb24cb630dc1ce221e4aa3dedb3f6341e3;hpb=b668c61f3c8968c51033e7d82a08993b57b098e0 diff --git a/app/src/main/java/net/ktnx/mobileledger/db/DB.java b/app/src/main/java/net/ktnx/mobileledger/db/DB.java index cff1d9c1..48262888 100644 --- a/app/src/main/java/net/ktnx/mobileledger/db/DB.java +++ b/app/src/main/java/net/ktnx/mobileledger/db/DB.java @@ -33,7 +33,6 @@ import net.ktnx.mobileledger.App; import net.ktnx.mobileledger.dao.AccountDAO; import net.ktnx.mobileledger.dao.AccountValueDAO; import net.ktnx.mobileledger.dao.CurrencyDAO; -import net.ktnx.mobileledger.dao.DescriptionHistoryDAO; import net.ktnx.mobileledger.dao.OptionDAO; import net.ktnx.mobileledger.dao.ProfileDAO; import net.ktnx.mobileledger.dao.TemplateAccountDAO; @@ -42,11 +41,14 @@ import net.ktnx.mobileledger.dao.TransactionAccountDAO; import net.ktnx.mobileledger.dao.TransactionDAO; import net.ktnx.mobileledger.utils.Logger; +import org.jetbrains.annotations.NotNull; + import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.util.Locale; +import java.util.UUID; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -54,11 +56,11 @@ import static net.ktnx.mobileledger.utils.Logger.debug; @Database(version = DB.REVISION, entities = {TemplateHeader.class, TemplateAccount.class, Currency.class, Account.class, - Profile.class, Option.class, AccountValue.class, DescriptionHistory.class, - Transaction.class, TransactionAccount.class + Profile.class, Option.class, AccountValue.class, Transaction.class, + TransactionAccount.class }) abstract public class DB extends RoomDatabase { - public static final int REVISION = 59; + public static final int REVISION = 65; public static final String DB_NAME = "MoLe.db"; public static final MutableLiveData initComplete = new MutableLiveData<>(false); private static DB instance; @@ -69,30 +71,50 @@ abstract public class DB extends RoomDatabase { if (instance != null) return instance; - return instance = Room.databaseBuilder(App.instance, DB.class, DB_NAME) - .addMigrations(new Migration[]{singleVersionMigration(17), - singleVersionMigration(18), - singleVersionMigration(19), - singleVersionMigration(20), - multiVersionMigration(20, 22), - multiVersionMigration(22, 30), - multiVersionMigration(30, 32), - multiVersionMigration(32, 34), - multiVersionMigration(34, 40), - singleVersionMigration(41), - multiVersionMigration(41, 58), - singleVersionMigration(59) - }) - .addCallback(new Callback() { - @Override - public void onOpen(@NonNull SupportSQLiteDatabase db) { - super.onOpen(db); - db.execSQL("PRAGMA foreign_keys = ON"); - db.execSQL("pragma case_sensitive_like=ON;"); - - } - }) - .build(); + RoomDatabase.Builder builder = + Room.databaseBuilder(App.instance, DB.class, DB_NAME); + builder.addMigrations( + new Migration[]{singleVersionMigration(17), singleVersionMigration(18), + singleVersionMigration(19), singleVersionMigration(20), + multiVersionMigration(20, 22), multiVersionMigration(22, 30), + multiVersionMigration(30, 32), multiVersionMigration(32, 34), + multiVersionMigration(34, 40), singleVersionMigration(41), + multiVersionMigration(41, 58), singleVersionMigration(59), + singleVersionMigration(60), singleVersionMigration(61), + singleVersionMigration(62), singleVersionMigration(63), + singleVersionMigration(64), new Migration(64, 65) { + @Override + public void migrate(@NonNull @NotNull SupportSQLiteDatabase database) { + try (Cursor c = database.query( + "SELECT id, description FROM transactions")) + { + while (c.moveToNext()) { + final long id = c.getLong(0); + final String description = c.getString(1); + database.execSQL( + "UPDATE transactions SET description_uc=? WHERE id=?", + new Object[]{description.toUpperCase(), id + }); + } + } + } + } + }) + .addCallback(new Callback() { + @Override + public void onOpen(@NonNull SupportSQLiteDatabase db) { + super.onOpen(db); + db.execSQL("PRAGMA foreign_keys = ON"); + db.execSQL("pragma case_sensitive_like" + "=ON;"); + + } + }); + +// if (BuildConfig.DEBUG) +// builder.setQueryCallback(((sqlQuery, bindArgs) -> Logger.debug("room", sqlQuery)), +// Executors.newSingleThreadExecutor()); + + return instance = builder.build(); } } private static Migration singleVersionMigration(int toVersion) { @@ -107,8 +129,8 @@ abstract public class DB extends RoomDatabase { // SharedPreferences if (toVersion == 59) { try (Cursor c = db.query( - "SELECT p.id, p.theme_hue FROM profiles p WHERE p.id=(SELECT o.value " + - "FROM options WHERE o.profile_uid IS NULL AND o.name=?", + "SELECT p.id, p.theme FROM profiles p WHERE p.id=(SELECT o.value " + + "FROM options o WHERE o.profile_id=0 AND o.name=?)", new Object[]{"profile_id"})) { if (c.moveToFirst()) { @@ -121,6 +143,14 @@ abstract public class DB extends RoomDatabase { } } } + if (toVersion == 63) { + try (Cursor c = db.query("SELECT id FROM templates")) { + while (c.moveToNext()) { + db.execSQL("UPDATE templates SET uuid=? WHERE id=?", + new Object[]{UUID.randomUUID().toString(), c.getLong(0)}); + } + } + } } }; } @@ -213,7 +243,18 @@ abstract public class DB extends RoomDatabase { public abstract OptionDAO getOptionDAO(); - public abstract DescriptionHistoryDAO getDescriptionHistoryDAO(); - public abstract ProfileDAO getProfileDAO(); + + @androidx.room.Transaction + public void deleteAllSync() { + getTransactionAccountDAO().deleteAllSync(); + getTransactionDAO().deleteAllSync(); + getAccountValueDAO().deleteAllSync(); + getAccountDAO().deleteAllSync(); + getTemplateAccountDAO().deleteAllSync(); + getTemplateDAO().deleteAllSync(); + getCurrencyDAO().deleteAllSync(); + getOptionDAO().deleteAllSync(); + getProfileDAO().deleteAllSync(); + } }