Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
52e6e8842a |
@@ -269,7 +269,7 @@ class AppDatabase extends _$AppDatabase {
|
|||||||
AppDatabase([QueryExecutor? executor]) : super(executor ?? _openConnection());
|
AppDatabase([QueryExecutor? executor]) : super(executor ?? _openConnection());
|
||||||
|
|
||||||
@override
|
@override
|
||||||
int get schemaVersion => 25;
|
int get schemaVersion => 24;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
MigrationStrategy get migration => MigrationStrategy(
|
MigrationStrategy get migration => MigrationStrategy(
|
||||||
@@ -431,22 +431,6 @@ class AppDatabase extends _$AppDatabase {
|
|||||||
if (from >= 4 && from < 24) {
|
if (from >= 4 && from < 24) {
|
||||||
await m.addColumn(drafts, drafts.imapServerId);
|
await m.addColumn(drafts, drafts.imapServerId);
|
||||||
}
|
}
|
||||||
if (from < 25) {
|
|
||||||
// For observeMailboxes: filter by account_id, sort by path.
|
|
||||||
await m.createIndex(
|
|
||||||
Index(
|
|
||||||
'mailboxes_account_id',
|
|
||||||
'CREATE INDEX IF NOT EXISTS mailboxes_account_id ON mailboxes (account_id, path);',
|
|
||||||
),
|
|
||||||
);
|
|
||||||
// For observeThreads: filter by account_id+mailbox_path, sort by latest_date.
|
|
||||||
await m.createIndex(
|
|
||||||
Index(
|
|
||||||
'threads_latest_date',
|
|
||||||
'CREATE INDEX IF NOT EXISTS threads_latest_date ON threads (account_id, mailbox_path, latest_date DESC);',
|
|
||||||
),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ void main() {
|
|||||||
group('Migration', () {
|
group('Migration', () {
|
||||||
test('schemaVersion matches expected value', () async {
|
test('schemaVersion matches expected value', () async {
|
||||||
final db = AppDatabase(NativeDatabase.memory());
|
final db = AppDatabase(NativeDatabase.memory());
|
||||||
expect(db.schemaVersion, 25);
|
expect(db.schemaVersion, 24);
|
||||||
await db.close();
|
await db.close();
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -141,23 +141,6 @@ void main() {
|
|||||||
]),
|
]),
|
||||||
);
|
);
|
||||||
|
|
||||||
// v18, v22, v25: indexes.
|
|
||||||
final allIndexes = await db
|
|
||||||
.customSelect("SELECT name FROM sqlite_master WHERE type='index'")
|
|
||||||
.get();
|
|
||||||
final indexNames = allIndexes.map((r) => r.read<String>('name')).toSet();
|
|
||||||
expect(
|
|
||||||
indexNames,
|
|
||||||
containsAll([
|
|
||||||
'emails_received_at', // v18
|
|
||||||
'emails_thread_id', // v18
|
|
||||||
'pending_changes_account_id', // v18
|
|
||||||
'emails_snoozed_until', // v22
|
|
||||||
'mailboxes_account_id', // v25
|
|
||||||
'threads_latest_date', // v25
|
|
||||||
]),
|
|
||||||
);
|
|
||||||
|
|
||||||
await db.close();
|
await db.close();
|
||||||
if (dbFile.existsSync()) dbFile.deleteSync();
|
if (dbFile.existsSync()) dbFile.deleteSync();
|
||||||
});
|
});
|
||||||
@@ -203,17 +186,6 @@ void main() {
|
|||||||
updated_at INTEGER NOT NULL
|
updated_at INTEGER NOT NULL
|
||||||
);
|
);
|
||||||
''');
|
''');
|
||||||
rawDb.execute('''
|
|
||||||
CREATE TABLE mailboxes (
|
|
||||||
id TEXT NOT NULL PRIMARY KEY,
|
|
||||||
account_id TEXT NOT NULL,
|
|
||||||
path TEXT NOT NULL,
|
|
||||||
name TEXT NOT NULL,
|
|
||||||
unread_count INTEGER NOT NULL DEFAULT 0,
|
|
||||||
total_count INTEGER NOT NULL DEFAULT 0,
|
|
||||||
role TEXT NULL
|
|
||||||
);
|
|
||||||
''');
|
|
||||||
rawDb.execute('''
|
rawDb.execute('''
|
||||||
CREATE TABLE emails (
|
CREATE TABLE emails (
|
||||||
id TEXT NOT NULL PRIMARY KEY,
|
id TEXT NOT NULL PRIMARY KEY,
|
||||||
@@ -238,23 +210,6 @@ void main() {
|
|||||||
snoozed_from_mailbox_path TEXT NULL
|
snoozed_from_mailbox_path TEXT NULL
|
||||||
);
|
);
|
||||||
''');
|
''');
|
||||||
rawDb.execute('''
|
|
||||||
CREATE TABLE threads (
|
|
||||||
account_id TEXT NOT NULL,
|
|
||||||
mailbox_path TEXT NOT NULL,
|
|
||||||
id TEXT NOT NULL,
|
|
||||||
subject TEXT NULL,
|
|
||||||
latest_date INTEGER NOT NULL,
|
|
||||||
message_count INTEGER NOT NULL DEFAULT 1,
|
|
||||||
has_unread INTEGER NOT NULL DEFAULT 0 CHECK ("has_unread" IN (0, 1)),
|
|
||||||
is_flagged INTEGER NOT NULL DEFAULT 0 CHECK ("is_flagged" IN (0, 1)),
|
|
||||||
participants_json TEXT NOT NULL DEFAULT '[]',
|
|
||||||
preview TEXT NULL,
|
|
||||||
latest_email_id TEXT NOT NULL,
|
|
||||||
email_ids_json TEXT NOT NULL DEFAULT '[]',
|
|
||||||
PRIMARY KEY (account_id, mailbox_path, id)
|
|
||||||
);
|
|
||||||
''');
|
|
||||||
rawDb.execute('PRAGMA user_version = 22;');
|
rawDb.execute('PRAGMA user_version = 22;');
|
||||||
rawDb.close();
|
rawDb.close();
|
||||||
|
|
||||||
@@ -268,19 +223,11 @@ void main() {
|
|||||||
final draftColumns = await _tableColumns(db, 'drafts');
|
final draftColumns = await _tableColumns(db, 'drafts');
|
||||||
expect(draftColumns, contains('imap_server_id'));
|
expect(draftColumns, contains('imap_server_id'));
|
||||||
|
|
||||||
// v25: new indexes on mailboxes and threads.
|
|
||||||
final allIndexes = await db
|
|
||||||
.customSelect("SELECT name FROM sqlite_master WHERE type='index'")
|
|
||||||
.get();
|
|
||||||
final indexNames = allIndexes.map((r) => r.read<String>('name')).toSet();
|
|
||||||
expect(indexNames, contains('mailboxes_account_id'));
|
|
||||||
expect(indexNames, contains('threads_latest_date'));
|
|
||||||
|
|
||||||
await db.close();
|
await db.close();
|
||||||
if (dbFile.existsSync()) dbFile.deleteSync();
|
if (dbFile.existsSync()) dbFile.deleteSync();
|
||||||
});
|
});
|
||||||
|
|
||||||
test('fresh install creates all tables at schemaVersion 25', () async {
|
test('fresh install creates all tables at schemaVersion 24', () async {
|
||||||
final db = AppDatabase(NativeDatabase.memory());
|
final db = AppDatabase(NativeDatabase.memory());
|
||||||
await db.select(db.accounts).get();
|
await db.select(db.accounts).get();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user