X-Git-Url: https://git.ktnx.net/?a=blobdiff_plain;f=app%2Fsrc%2Fmain%2Fjava%2Fnet%2Fktnx%2Fmobileledger%2FMobileLedgerDB.java;h=1f5801a7018ffbb2a181b6c77bcc0bc82caa9a0f;hb=ac3b5b52cfdf268b05578acab1c098647543245b;hp=2aee53316c9031a741a185644aa8a622aed3fd89;hpb=65e1c4a034f5f08db9117f7211ca924e2e293f8e;p=mobile-ledger.git

diff --git a/app/src/main/java/net/ktnx/mobileledger/MobileLedgerDB.java b/app/src/main/java/net/ktnx/mobileledger/MobileLedgerDB.java
index 2aee5331..1f5801a7 100644
--- a/app/src/main/java/net/ktnx/mobileledger/MobileLedgerDB.java
+++ b/app/src/main/java/net/ktnx/mobileledger/MobileLedgerDB.java
@@ -1,24 +1,111 @@
 package net.ktnx.mobileledger;
 
+import android.content.res.Resources;
+import android.database.Cursor;
 import android.database.sqlite.SQLiteDatabase;
+import android.util.Log;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
 
 class MobileLedgerDB {
     static final String DATABASE_NAME = "accounts";
     private static String db_filename;
     static SQLiteDatabase db;
 
-    public static String getDb_filename() {
+    static String getDb_filename() {
         return db_filename;
     }
 
-    public static void setDb_filename(String db_filename) {
+    static void setDb_filename(String db_filename) {
         MobileLedgerDB.db_filename = db_filename;
     }
 
-    public static void initDB() {
-        db = SQLiteDatabase.openOrCreateDatabase( db_filename, null );
+    static void initDB() {
+        db = SQLiteDatabase.openOrCreateDatabase(db_filename, null);
 
         db.execSQL("create table if not exists accounts(name varchar);");
         db.execSQL("create index if not exists idx_accounts_name on accounts(name);");
+        db.execSQL("create table if not exists options(name varchar, value varchar);");
+        db.execSQL("create unique index if not exists idx_options_name on options(name);");
+    }
+
+    static void applyRevisions(Resources rm) {
+        int next_ver = Integer.parseInt(get_option_value("db_version", "0")) + 1;
+
+        while (applyRevision(rm, next_ver)) {
+            next_ver++;
+        }
+    }
+    private static boolean applyRevision(Resources rm, int next_ver) {
+        try (InputStream res = rm.openRawResource(next_ver)) {
+            Log.d("db", "Applying revision " + String.valueOf(next_ver));
+            InputStreamReader isr = new InputStreamReader(res);
+            BufferedReader reader = new BufferedReader(isr);
+
+            String line;
+            while ((line = reader.readLine()) != null) {
+                db.execSQL(line);
+            }
+
+            db.setTransactionSuccessful();
+        } catch (Exception e) {
+            return false;
+        }
+        finally {
+            db.endTransaction();
+        }
+
+        return true;
+    }
+
+    static int get_option_value(String name, int default_value) {
+        String s = get_option_value(name, String.valueOf(default_value));
+        try {
+            return Integer.parseInt(s);
+        }
+        catch (Exception e) {
+            return default_value;
+        }
+    }
+
+    static long get_option_value(String name, long default_value) {
+        String s = get_option_value(name, String.valueOf(default_value));
+        try {
+            return Long.parseLong(s);
+        }
+        catch (Exception e) {
+            Log.d("db", "returning default long value of "+name, e);
+            return default_value;
+        }
+    }
+
+    static String get_option_value(String name, String default_value) {
+        Log.d("db", "about fo fetch option "+name);
+        try (Cursor cursor = db.rawQuery("select value from options where name=?", new String[]{name})) {
+            if (cursor.moveToFirst()) {
+                String result = cursor.getString(0);
+
+                if (result == null ) result = default_value;
+
+                Log.d("db", "option "+name+"="+result);
+                return result;
+            }
+            else return default_value;
+        }
+        catch(Exception e) {
+            Log.d("db", "returning default value for "+name, e);
+            return default_value;
+        }
+    }
+
+    static void set_option_value(String name, String value) {
+        Log.d("db", "setting option "+name+"="+value);
+        db.execSQL("insert or replace into options(name, value) values(?, ?);", new String[]{name, value});
+    }
+
+    static void set_option_value(String name, long value) {
+        set_option_value(name, String.valueOf(value));
     }
 }