nettika/geary
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Now using new async versions of SQLHeavy.Transaction.commit_async().

Browse source 
This revision of Geary requires the latest revision of SQLHeavy.
This commit is contained in:
Jim Nelson 2011-07-18 12:26:43 -07:00
parent 1683775ddf
commit 3e308a4d13
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/engine/sqlite/email/sqlite-message-table.vala
View file

@ -68,7 +68,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_int(0, row.fields);
query.bind_int64(1, row.id);
query.execute();
yield query.execute_async(cancellable);
if (row.fields.is_any_set(Geary.Email.Field.DATE)) {
query = transaction.prepare(
@ -77,7 +77,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_int64(1, row.date_time_t);
query.bind_int64(2, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.ORIGINATORS)) {
@ -88,7 +88,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(2, row.reply_to);
query.bind_int64(3, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.RECEIVERS)) {
@ -99,7 +99,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(2, row.bcc);
query.bind_int64(3, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.REFERENCES)) {
@ -109,7 +109,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(1, row.in_reply_to);
query.bind_int64(2, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.SUBJECT)) {
@ -118,7 +118,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(0, row.subject);
query.bind_int64(1, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.HEADER)) {
@ -127,7 +127,7 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(0, row.header);
query.bind_int64(1, row.id);
query.execute();
yield query.execute_async(cancellable);
}
if (row.fields.is_any_set(Geary.Email.Field.BODY)) {
@ -136,10 +136,10 @@ public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
query.bind_string(0, row.body);
query.bind_int64(1, row.id);
query.execute();
yield query.execute_async(cancellable);
}
transaction.commit();
yield transaction.commit_async();
}
public async Gee.List<MessageRow>? list_by_message_id_async(Geary.RFC822.MessageID message_id,