import android.content.res.Resources;
import android.database.Cursor;
+import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
+import java.util.Locale;
class MobileLedgerDB {
static final String DATABASE_NAME = "accounts";
+ static final String OPT_DB_REVISION = "db_revision";
+ static final String ACCOUNTS_TABLE = "accounts";
+ static final String DESCRIPTION_HISTORY_TABLE = "description_history";
private static String db_filename;
static SQLiteDatabase db;
MobileLedgerDB.db_filename = db_filename;
}
- static void initDB() {
+ static void initDB(Resources rm, String pkg_name) {
db = SQLiteDatabase.openOrCreateDatabase(db_filename, null);
+ int cur_ver = Integer.parseInt(get_option_value(OPT_DB_REVISION, "-1"));
- 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);");
- db.execSQL("create table if not exists account_values(account varchar not null, currency varchar not null, value decimal(18,2) not null);");
- db.execSQL("create index if not exists idx_account_values_account on account_values(account);");
- db.execSQL("create unique index if not exists un_account_values on account_values(account,currency);");
- }
-
- static void applyRevisions(Resources rm) {
- int next_ver = Integer.parseInt(get_option_value("db_version", "0")) + 1;
+ Log.d("db", "Current DB revision is "+String.valueOf(cur_ver));
- while (applyRevision(rm, next_ver)) {
- next_ver++;
+ while (applyRevision(rm, pkg_name, cur_ver+1)) {
+ cur_ver++;
}
+
+ Log.d("db", "Database revision is "+String.valueOf(cur_ver)+" now");
}
- 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));
+ private static boolean applyRevision(Resources rm, String pkg_name, int rev_no) {
+ String rev_file = String.format(Locale.US, "sql_%d", rev_no);
+
+ int res_id = rm.getIdentifier(rev_file, "raw", pkg_name);
+ if (res_id == 0) {
+ Log.d("db", String.format(Locale.US, "No resource for revision %d", rev_no));
+ return false;
+ }
+ db.beginTransaction();
+ try (InputStream res = rm.openRawResource(res_id)) {
+ Log.d("db", "Applying revision " + String.valueOf(rev_no));
InputStreamReader isr = new InputStreamReader(res);
BufferedReader reader = new BufferedReader(isr);
db.execSQL(line);
}
+ set_option_value(OPT_DB_REVISION, rev_no);
db.setTransactionSuccessful();
- } catch (Exception e) {
+ } catch (Resources.NotFoundException e) {
+ Log.d("db", "SQL revision "+String.valueOf(rev_no)+" not found");
+ return false;
+ }
+ catch (SQLException e) {
+ Log.e("db", String.format(Locale.US, "Error applying revision %d: %s", rev_no, e.getMessage()));
+ return false;
+ }
+ catch (Exception e) {
+ Log.w("db", "Error reading revision" + String.valueOf(rev_no)+": "+e.getMessage());
return false;
}
finally {