+
+ private static class AccountAndTransactionListSaver extends Thread {
+ private final MobileLedgerProfile profile;
+ private final List<LedgerAccount> accounts;
+ private final List<LedgerTransaction> transactions;
+ AccountAndTransactionListSaver(MobileLedgerProfile profile, List<LedgerAccount> accounts,
+ List<LedgerTransaction> transactions) {
+ this.accounts = accounts;
+ this.transactions = transactions;
+ this.profile = profile;
+ }
+ public int getNextDescriptionsGeneration(SQLiteDatabase db) {
+ int generation = 1;
+ try (Cursor c = db.rawQuery("SELECT generation FROM description_history LIMIT 1",
+ null))
+ {
+ if (c.moveToFirst()) {
+ generation = c.getInt(0) + 1;
+ }
+ }
+ return generation;
+ }
+ void deleteNotPresentDescriptions(SQLiteDatabase db, int generation) {
+ Logger.debug("db/benchmark", "Deleting obsolete descriptions");
+ db.execSQL("DELETE FROM description_history WHERE generation <> ?",
+ new Object[]{generation});
+ db.execSQL("DELETE FROM description_history WHERE generation <> ?",
+ new Object[]{generation});
+ Logger.debug("db/benchmark", "Done deleting obsolete descriptions");
+ }
+ @Override
+ public void run() {
+ SQLiteDatabase db = App.getDatabase();
+ db.beginTransactionNonExclusive();
+ try {
+ int accountsGeneration = profile.getNextAccountsGeneration(db);
+ if (isInterrupted())
+ return;
+
+ int transactionsGeneration = profile.getNextTransactionsGeneration(db);
+ if (isInterrupted())
+ return;
+
+ for (LedgerAccount acc : accounts) {
+ profile.storeAccount(db, accountsGeneration, acc, false);
+ if (isInterrupted())
+ return;
+ for (LedgerAmount amt : acc.getAmounts()) {
+ profile.storeAccountValue(db, accountsGeneration, acc.getName(),
+ amt.getCurrency(), amt.getAmount());
+ if (isInterrupted())
+ return;
+ }
+ }
+
+ for (LedgerTransaction tr : transactions) {
+ profile.storeTransaction(db, transactionsGeneration, tr);
+ if (isInterrupted())
+ return;
+ }
+
+ profile.deleteNotPresentTransactions(db, transactionsGeneration);
+ if (isInterrupted()) {
+ return;
+ }
+ profile.deleteNotPresentAccounts(db, accountsGeneration);
+ if (isInterrupted())
+ return;
+
+ Map<String, Boolean> unique = new HashMap<>();
+
+ debug("descriptions", "Starting refresh");
+ int descriptionsGeneration = getNextDescriptionsGeneration(db);
+ try (Cursor c = db.rawQuery("SELECT distinct description from transactions",
+ null))
+ {
+ while (c.moveToNext()) {
+ String description = c.getString(0);
+ String descriptionUpper = description.toUpperCase();
+ if (unique.containsKey(descriptionUpper))
+ continue;
+
+ storeDescription(db, descriptionsGeneration, description, descriptionUpper);
+
+ unique.put(descriptionUpper, true);
+ }
+ }
+ deleteNotPresentDescriptions(db, descriptionsGeneration);
+
+ db.setTransactionSuccessful();
+ }
+ finally {
+ db.endTransaction();
+ }
+ }
+ private void storeDescription(SQLiteDatabase db, int generation, String description,
+ String descriptionUpper) {
+ db.execSQL("UPDATE description_history SET description=?, generation=? WHERE " +
+ "description_upper=?", new Object[]{description, generation, descriptionUpper
+ });
+ db.execSQL(
+ "INSERT INTO description_history(description, description_upper, generation) " +
+ "select ?,?,? WHERE (select changes() = 0)",
+ new Object[]{description, descriptionUpper, generation
+ });
+ }
+ }