在同一个数据库上使用两个 FMDB 队列（读/写）

Question

我相信我的用例相当普遍，但我找不到对此的权威答案。

我有一个在后台运行并将数据写入我的数据库的同步机制。这种同步可能需要很长时间（我使用 FTS）。为此，我使用FMDatabaseQueue。当我想读取数据库时，我使用同一个队列进行查询。

现在，当同步进程已经将大量事务排入队列时，应用想要执行读取操作，它必须等待所有写入事务完成才能执行查询，因为这是一个串行队列。代码可能如下所示：

FMDatabaseQueue *queue = [self getDatabaseQueue];

[queue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[queue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[queue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[queue inDatabase:^(FMDatabase *db) {
    FMResultSet *resultSet = [db executeQuery:@"SELECT name..."];
}];

我想立即获得查询结果（即使未完成同步），而不是等待UPDATE 完成。

我可以创建两个FMDatabaseQueues，一个用于写查询，一个用于读查询吗？如果读查询在写事务的中间开始会发生什么？

代码可能如下所示：

FMDatabaseQueue *writeQueue = [self getWriteDatabaseQueue];
FMDatabaseQueue *readQueue = [self getReadDatabaseQueue];

[writeQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[writeQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[writeQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
    // Very slow process
    [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
}];

[readQueue inDatabase:^(FMDatabase *db) {
    FMResultSet *resultSet = [db executeQuery:@"SELECT name..."];
}];

编辑：

此外，让我感到困惑的是文档中的说明：

每个线程都可以创建一个 FMDatabase 对象。只是不要跨线程共享单个实例。

所以我的理解是，我可以创建两个实例使用同一个数据库，但我只需要将其保留在自己的线程上。

Answer 1

不，您不想让两个FMDatabaseQueue 与同一个数据库进行交互。 FMDatabaseQueue 的全部目的是提供一个队列，用于通过共享的单个串行队列协调来自不同线程的数据库调用。

不过，我想知道您的代码在“非常慢的过程”块中。如果这不是特定于数据库的内容，那么它不应该在 inTransaction 和/或 inDatabase 调用中。

NSOperationQueue *backgroundQueue = [[NSOperationQueue alloc] init]; 
FMDatabaseQueue *databaseQueue = [FMDatabaseQueue databaseWithPath:path]; 

[backgroundQueue addOperationWithBlock:^{
    // very slow process

    [databaseQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
        [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
    }];
}];

[backgroundQueue addOperationWithBlock:^{
    // very slow process

    [databaseQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
        [db executeUpdate:@"UPDATE docs SET name = ?", "value..."];
    }];
}];

当它们排队并运行时，主队列可以进行自己的databaseQueue 调用，使用FMDatabaseQueue 以确保以不会与@987654328 同时发生的方式进行协调上面的@块：

[databaseQueue inDatabase:^(FMDatabase *db) {
    FMResultSet *resultSet = [db executeQuery:@"SELECT name..."];
    while (![resultSet next]) {
        ....
    }
}];

显然，您应该管理您的后台任务，但它适合您的应用程序（我使用了并发操作队列，但您可以使用串行队列或调度队列或任何您想要的）。不要被上述backgroundQueue 的细节所困扰，因为您的实现会有所不同。

关键的观察是你不应该使用databaseQueue 来管理你的“非常慢的进程”任务以及数据库交互。从inTransaction 和inDatabase 调用中取出任何与数据库无关的内容。使用您自己的队列来管理您自己的非数据库相关代码。始终尽快进出databaseQueue，让单个共享的FMDatabaseQueue 协调与数据库的多线程交互。