X-Git-Url: https://git.ktnx.net/?p=mobile-ledger.git;a=blobdiff_plain;f=app%2Fsrc%2Fmain%2Fjava%2Fnet%2Fktnx%2Fmobileledger%2Fdao%2FAccountDAO.java;h=0c581787a30a2fac55c605674904eebdd7441995;hp=a4ed06e4cd91b3fcebeb4ced59eca8cc19f98009;hb=833544eb24cb630dc1ce221e4aa3dedb3f6341e3;hpb=caf9db3f39e12a8050f1d26bf196857bd3d36f2e diff --git a/app/src/main/java/net/ktnx/mobileledger/dao/AccountDAO.java b/app/src/main/java/net/ktnx/mobileledger/dao/AccountDAO.java index a4ed06e4..0c581787 100644 --- a/app/src/main/java/net/ktnx/mobileledger/dao/AccountDAO.java +++ b/app/src/main/java/net/ktnx/mobileledger/dao/AccountDAO.java @@ -19,35 +19,178 @@ package net.ktnx.mobileledger.dao; import androidx.annotation.NonNull; import androidx.lifecycle.LiveData; +import androidx.room.ColumnInfo; import androidx.room.Dao; import androidx.room.Delete; import androidx.room.Insert; +import androidx.room.OnConflictStrategy; import androidx.room.Query; +import androidx.room.Transaction; import androidx.room.Update; import net.ktnx.mobileledger.db.Account; +import net.ktnx.mobileledger.db.AccountValue; +import net.ktnx.mobileledger.db.AccountWithAmounts; +import net.ktnx.mobileledger.db.DB; +import java.util.ArrayList; import java.util.List; + @Dao public abstract class AccountDAO extends BaseDAO { - @Insert - abstract void insertSync(Account item); + static public List unbox(List list) { + ArrayList result = new ArrayList<>(list.size()); + for (AccountNameContainer item : list) { + result.add(item.name); + } + + return result; + } + + @Insert(onConflict = OnConflictStrategy.REPLACE) + public abstract long insertSync(Account item); + @Insert(onConflict = OnConflictStrategy.REPLACE) + public abstract void insertSync(List items); + + @Transaction + public void insertSync(@NonNull AccountWithAmounts accountWithAmounts) { + final AccountValueDAO valueDAO = DB.get() + .getAccountValueDAO(); + Account account = accountWithAmounts.account; + account.setId(insertSync(account)); + for (AccountValue value : accountWithAmounts.amounts) { + value.setAccountId(account.getId()); + value.setGeneration(account.getGeneration()); + value.setId(valueDAO.insertSync(value)); + } + } @Update - abstract void updateSync(Account item); + public abstract void updateSync(Account item); + + @Delete + public abstract void deleteSync(Account item); @Delete - abstract void deleteSync(Account item); + public abstract void deleteSync(List items); - @Query("SELECT * FROM accounts") - abstract LiveData> getAll(); + @Query("DELETE FROM accounts") + public abstract void deleteAllSync(); - @Query("SELECT * FROM accounts WHERE profile = :profileUUID AND name = :accountName") - abstract LiveData getByName(@NonNull String profileUUID, @NonNull String accountName); + @Query("SELECT * FROM accounts WHERE profile_id=:profileId ORDER BY name") + public abstract LiveData> getAll(long profileId); -// not useful for now + @Transaction + @Query("SELECT * FROM accounts WHERE profile_id = :profileId ORDER BY name") + public abstract LiveData> getAllWithAmounts(long profileId); + + @Query("SELECT * FROM accounts WHERE id=:id") + public abstract Account getByIdSync(long id); + + // not useful for now // @Transaction // @Query("SELECT * FROM patterns") // List getPatternsWithAccounts(); + @Query("SELECT * FROM accounts WHERE profile_id = :profileId AND name = :accountName") + public abstract LiveData getByName(long profileId, @NonNull String accountName); + + @Query("SELECT * FROM accounts WHERE profile_id = :profileId AND name = :accountName") + public abstract Account getByNameSync(long profileId, @NonNull String accountName); + + @Transaction + @Query("SELECT * FROM accounts WHERE profile_id = :profileId AND name = :accountName") + public abstract LiveData getByNameWithAmounts(long profileId, + @NonNull String accountName); + + @Query("SELECT name, CASE WHEN name_upper LIKE :term||'%%' THEN 1 " + + " WHEN name_upper LIKE '%%:'||:term||'%%' THEN 2 " + + " WHEN name_upper LIKE '%% '||:term||'%%' THEN 3 " + + " ELSE 9 END AS ordering " + "FROM accounts " + + "WHERE profile_id=:profileId AND name_upper LIKE '%%'||:term||'%%' " + + "ORDER BY ordering, name_upper, rowid ") + public abstract LiveData> lookupNamesInProfileByName(long profileId, + @NonNull + String term); + + @Query("SELECT name, CASE WHEN name_upper LIKE :term||'%%' THEN 1 " + + " WHEN name_upper LIKE '%%:'||:term||'%%' THEN 2 " + + " WHEN name_upper LIKE '%% '||:term||'%%' THEN 3 " + + " ELSE 9 END AS ordering " + "FROM accounts " + + "WHERE profile_id=:profileId AND name_upper LIKE '%%'||:term||'%%' " + + "ORDER BY ordering, name_upper, rowid ") + public abstract List lookupNamesInProfileByNameSync(long profileId, + @NonNull String term); + + @Transaction + @Query("SELECT * FROM accounts " + + "WHERE profile_id=:profileId AND name_upper LIKE '%%'||:term||'%%' " + + "ORDER BY CASE WHEN name_upper LIKE :term||'%%' THEN 1 " + + " WHEN name_upper LIKE '%%:'||:term||'%%' THEN 2 " + + " WHEN name_upper LIKE '%% '||:term||'%%' THEN 3 " + + " ELSE 9 END, name_upper, rowid ") + public abstract List lookupWithAmountsInProfileByNameSync(long profileId, + @NonNull String term); + + @Query("SELECT DISTINCT name, CASE WHEN name_upper LIKE :term||'%%' THEN 1 " + + " WHEN name_upper LIKE '%%:'||:term||'%%' THEN 2 " + + " WHEN name_upper LIKE '%% '||:term||'%%' THEN 3 " + + " ELSE 9 END AS ordering " + "FROM accounts " + + "WHERE name_upper LIKE '%%'||:term||'%%' " + "ORDER BY ordering, name_upper, rowid ") + public abstract LiveData> lookupNamesByName(@NonNull String term); + + @Query("SELECT DISTINCT name, CASE WHEN name_upper LIKE :term||'%%' THEN 1 " + + " WHEN name_upper LIKE '%%:'||:term||'%%' THEN 2 " + + " WHEN name_upper LIKE '%% '||:term||'%%' THEN 3 " + + " ELSE 9 END AS ordering " + "FROM accounts " + + "WHERE name_upper LIKE '%%'||:term||'%%' " + "ORDER BY ordering, name_upper, rowid ") + public abstract List lookupNamesByNameSync(@NonNull String term); + + @Query("SELECT * FROM accounts WHERE profile_id = :profileId") + public abstract List allForProfileSync(long profileId); + + @Query("SELECT generation FROM accounts WHERE profile_id = :profileId LIMIT 1") + protected abstract AccountGenerationContainer getGenerationPOJOSync(long profileId); + public long getGenerationSync(long profileId) { + AccountGenerationContainer result = getGenerationPOJOSync(profileId); + + if (result == null) + return 0; + return result.generation; + } + @Query("DELETE FROM accounts WHERE profile_id = :profileId AND generation <> " + + ":currentGeneration") + public abstract void purgeOldAccountsSync(long profileId, long currentGeneration); + + @Query("DELETE FROM account_values WHERE EXISTS (SELECT 1 FROM accounts a WHERE a" + + ".id=account_values.account_id AND a.profile_id=:profileId) AND generation <> " + + ":currentGeneration") + public abstract void purgeOldAccountValuesSync(long profileId, long currentGeneration); + @Transaction + public void storeAccountsSync(List accounts, long profileId) { + long generation = getGenerationSync(profileId) + 1; + + for (AccountWithAmounts rec : accounts) { + rec.account.setGeneration(generation); + rec.account.setProfileId(profileId); + insertSync(rec); + } + purgeOldAccountsSync(profileId, generation); + purgeOldAccountValuesSync(profileId, generation); + } + + static public class AccountNameContainer { + @ColumnInfo + public String name; + @ColumnInfo + public int ordering; + } + + static class AccountGenerationContainer { + @ColumnInfo + long generation; + public AccountGenerationContainer(long generation) { + this.generation = generation; + } + } }