1

下面的函数返回一条Ledgers记录。大多数时候，它会在可选_currentReceipt变量中找到它，或者通过搜索数据库，不需要在那里写。我想使用只读的 GRDB 数据库连接。只读数据库连接可以在不同线程上并行运行。

在极少数情况下，前两个步骤失败，我可以创建一个默认分类帐。调用try FoodyDataStack.thisDataStack.dbPool.write { writeDB in ...会抛出致命错误，数据库连接不可重入。我正在寻找一种方法来保存该默认分类帐，而不必将整个函数包装在读写连接中。

我可以在 GRDB .read 块中的单独队列上调用 NSOperation 吗？

class func getCurrentReceipt(db: Database) throws -> Ledgers {
        if let cr = FoodyDataStack.thisDataStack._currentReceipt {
            return cr
        }
        // Fall through
        do {
            if let cr = try Ledgers.filter(Ledgers.Columns.receiptClosed == ReceiptStatus.receiptOpen.rawValue).order(Ledgers.Columns.dateModified.desc).fetchOne(db) {
                FoodyDataStack.thisDataStack._currentReceipt = cr
                return cr
            } else {
                throw FoodyDataStack.myGRDBerrors.couldNotFindCurrentReceipt
            }
        } catch FoodyDataStack.myGRDBerrors.couldNotFindCurrentReceipt {
            // Create new receipt with default store
            let newReceipt = Ledgers()
            newReceipt.dateCreated = Date()
            newReceipt.dateModified = Date()
            newReceipt.receiptStatus = .receiptOpen
            newReceipt.receiptUrgency = .immediate
            newReceipt.dateLedger = Date()
            newReceipt.uuidStore = Stores.defaultStore(db).uuidKey
            FoodyDataStack.thisDataStack._currentReceipt = newReceipt
            return newReceipt
        } catch  {
            NSLog("WARNING: Unhandled error in Ledgers.getCurrentReceipt() \(error.localizedDescription)")
        }
    }

编辑：我把这个问题留在这里，但我想我可能会进行过早的优化。我将尝试使用 dbQueue 而不是 dbPool，看看性能如何。如果速度需要，我会回到 dbPool。

4

1 回答 1

1

GRDB 数据库访问方法是不可重入的（DatabaseQueue 和 DatabasePool 的读写方法）。

为了帮助您解决问题，请尝试将您的数据库访问方法分为两个级别。

第一级不暴露给应用程序的其余部分。它的方法都需要一个db: Database参数。

class MyStack {
    private var dbQueue: DatabaseQueue

    private func fetchFoo(_ db: Database, id: Int64) throws -> Foo? {
        return try Foo.fetchOne(db, key: id)
    }

    private func setBar(_ db: Database, foo: Foo) throws {
        try foo.updateChanges(db) {
            $0.bar = true
        }
    }
}

来自第二层的方法暴露给应用程序的其余部分。它们将第一级方法read和write数据库访问方法包装起来：

class MyStack {
    func fetchFoo(id: Int64) throws -> Foo? {
        return try dbQueue.read { db in
            try fetchFoo(db, id: id)
        }
    }

    func setBar(id: Int64) throws {
        try dbQueue.write { db in
            guard let foo = try fetchFoo(db) else {
                throw fooNotFound
            }
            try setBar(foo: foo)
        }
    }
}

第一层的方法可以根据需要尽可能低，并且可以组合。

第二级的方法是高级的，并且不可组合：由于“数据库连接不可重入”致命错误，它们不能相互调用。它们提供了保证数据库一致性的线程安全数据库方法。

有关详细信息，请参阅并发指南。

于 2019-07-23T07:08:45.297 回答