return Float.compare(o1.getAmount(), o2.getAmount());
};
private final long profile;
- private final Integer id;
+ private final long id;
private final List<LedgerTransactionAccount> accounts;
private SimpleDate date;
private String description;
private String comment;
private String dataHash;
private boolean dataLoaded;
- public LedgerTransaction(Integer id, String dateString, String description)
- throws ParseException {
+ public LedgerTransaction(long id, String dateString, String description) throws ParseException {
this(id, Globals.parseLedgerDate(dateString), description);
}
- public LedgerTransaction(Integer id, SimpleDate date, String description,
+ public LedgerTransaction(long id, SimpleDate date, String description,
MobileLedgerProfile profile) {
this.profile = profile.getId();
this.id = id;
this.dataHash = null;
dataLoaded = false;
}
- public LedgerTransaction(Integer id, SimpleDate date, String description) {
+ public LedgerTransaction(long id, SimpleDate date, String description) {
this(id, date, description, Data.getProfile());
}
public LedgerTransaction(SimpleDate date, String description) {
- this(null, date, description);
+ this(0, date, description);
}
public LedgerTransaction(int id) {
this(id, (SimpleDate) null, null);
public void setComment(String comment) {
this.comment = comment;
}
- public int getId() {
+ public long getId() {
return id;
}
protected void fillDataHash() {
sql += ", expanded=?";
params.add(acc.isExpanded() ? 1 : 0);
}
- sql += " where profile=? and name=?";
+ sql += " where profile_id=? and name=?";
params.add(id);
params.add(acc.getName());
db.execSQL(sql, params.toArray());
- db.execSQL("insert into accounts(profile, name, name_upper, parent_name, level, " +
+ db.execSQL("insert into accounts(profile_id, name, name_upper, parent_name, level, " +
"expanded, generation) select ?,?,?,?,?,0,? where (select changes() = 0)",
new Object[]{id, acc.getName(), acc.getName().toUpperCase(), acc.getParentName(),
acc.getLevel(), generation
}
}
- db.execSQL("replace into account_values(profile, account, " +
- "currency, value, generation) values(?, ?, ?, ?, ?);",
- new Object[]{id, name, Misc.emptyIsNull(currency), amount, generation});
+ long accId = findAddAccount(db, name);
+
+ db.execSQL("replace into account_values(account_id, " +
+ "currency, value, generation) values(?, ?, ?, ?);",
+ new Object[]{accId, Misc.emptyIsNull(currency), amount, generation});
+ }
+ private long findAddAccount(SQLiteDatabase db, String accountName) {
+ try (Cursor c = db.rawQuery("select id from accounts where profile_id=? and name=?",
+ new String[]{String.valueOf(id), accountName}))
+ {
+ if (c.moveToFirst())
+ return c.getLong(0);
+
+ }
+
+ try (Cursor c = db.rawQuery(
+ "insert into accounts(profile_id, name, name_upper) values(?, ?, ?) returning id",
+ new String[]{String.valueOf(id), accountName, accountName.toUpperCase()}))
+ {
+ c.moveToFirst();
+ return c.getInt(0);
+ }
}
public void storeTransaction(SQLiteDatabase db, int generation, LedgerTransaction tr) {
tr.fillDataHash();
// Logger.debug("storeTransaction", String.format(Locale.US, "ID %d", tr.getId()));
SimpleDate d = tr.getDate();
db.execSQL("UPDATE transactions SET year=?, month=?, day=?, description=?, comment=?, " +
- "data_hash=?, generation=? WHERE profile=? AND id=?",
+ "data_hash=?, generation=? WHERE profile_id=? AND ledger_id=?",
new Object[]{d.year, d.month, d.day, tr.getDescription(), tr.getComment(),
tr.getDataHash(), generation, id, tr.getId()
});
- db.execSQL("INSERT INTO transactions(profile, id, year, month, day, description, " +
- "comment, data_hash, generation) " +
- "select ?,?,?,?,?,?,?,?,? WHERE (select changes() = 0)",
+ db.execSQL(
+ "INSERT INTO transactions(profile_id, ledger_id, year, month, day, description, " +
+ "comment, data_hash, generation) " +
+ "select ?,?,?,?,?,?,?,?,? WHERE (select changes() = 0)",
new Object[]{id, tr.getId(), tr.getDate().year, tr.getDate().month,
tr.getDate().day, tr.getDescription(), tr.getComment(),
tr.getDataHash(), generation
int accountOrderNo = 1;
for (LedgerTransactionAccount item : tr.getAccounts()) {
db.execSQL("UPDATE transaction_accounts SET account_name=?, amount=?, currency=?, " +
- "comment=?, generation=? " +
- "WHERE profile=? AND transaction_id=? AND order_no=?",
+ "comment=?, generation=? " + "WHERE transaction_id=? AND order_no=?",
new Object[]{item.getAccountName(), item.getAmount(),
Misc.nullIsEmpty(item.getCurrency()), item.getComment(),
- generation, id, tr.getId(), accountOrderNo
+ generation, tr.getId(), accountOrderNo
});
- db.execSQL("INSERT INTO transaction_accounts(profile, transaction_id, " +
+ db.execSQL("INSERT INTO transaction_accounts(transaction_id, " +
"order_no, account_name, amount, currency, comment, generation) " +
"select ?, ?, ?, ?, ?, ?, ?, ? WHERE (select changes() = 0)",
- new Object[]{id, tr.getId(), accountOrderNo, item.getAccountName(),
+ new Object[]{tr.getId(), accountOrderNo, item.getAccountName(),
item.getAmount(), Misc.nullIsEmpty(item.getCurrency()),
item.getComment(), generation
});
}
public void setOption(String name, String value) {
debug("profile", String.format("setting option %s=%s", name, value));
- DbOpQueue.add("insert or replace into options(profile, name, value) values(?, ?, ?);",
+ DbOpQueue.add("insert or replace into options(profile_id, name, value) values(?, ?, ?);",
new String[]{String.valueOf(id), name, value});
}
public void setLongOption(String name, long value) {
db.beginTransactionNonExclusive();
try {
Object[] id_param = new Object[]{id};
- db.execSQL("delete from transaction_accounts where profile=?", id_param);
- db.execSQL("delete from transactions where profile=?", id_param);
- db.execSQL("delete from account_values where profile=?", id_param);
+ db.execSQL("delete from transactions where profile_id=?", id_param);
db.execSQL("delete from accounts where profile=?", id_param);
db.execSQL("delete from options where profile=?", id_param);
- db.execSQL("delete from profiles where uuid=?", id_param);
+ db.execSQL("delete from profiles where id=?", id_param);
db.setTransactionSuccessful();
}
finally {
}
public int getNextTransactionsGeneration(SQLiteDatabase db) {
int generation = 1;
- try (Cursor c = db.rawQuery("SELECT generation FROM transactions WHERE profile=? LIMIT 1",
+ try (Cursor c = db.rawQuery(
+ "SELECT generation FROM transactions WHERE profile_id=? LIMIT 1",
new String[]{String.valueOf(id)}))
{
if (c.moveToFirst()) {
}
private int getNextAccountsGeneration(SQLiteDatabase db) {
int generation = 1;
- try (Cursor c = db.rawQuery("SELECT generation FROM accounts WHERE profile=? LIMIT 1",
+ try (Cursor c = db.rawQuery("SELECT generation FROM accounts WHERE profile_id=? LIMIT 1",
new String[]{String.valueOf(id)}))
{
if (c.moveToFirst()) {