OGeek|极客世界-中国程序员成长平台

标题: ios - 使用事务插入会引发错误 Sqlite.swift [打印本页]

---

作者: 菜鸟教程小白    时间: 2022-12-11 19:29
标题: ios - 使用事务插入会引发错误 Sqlite.swift

我已经创建了一个数据库类:

class Database {
    static let instance = Database()
    private let categories = Table("Category")
    private var db: Connection?

    let cat_id = Expression<String>("id")
    let cat_name = Expression<String>("name")


    private init() {
        let path = NSSearchPathForDirectoriesInDomains(
            .documentDirectory, .userDomainMask, true
            ).first!
        do {
            db = try Connection("\(path)/SalesPresenterDatabase.sqlite3")
            createTable()
        } catch {
            print("error")
        }
    }
    func createTable() {
        do{
            try self.db!.run(self.categories.create(ifNotExists: true) { table in
                table.column(self.cat_id)
                table.column(self.cat_name)
            })
        }catch{
             print("error")
        }
    }

    func addRow(table: DBTableNames, object: [Any]) -> Int64? {
      do {
         try self.db!.transaction() {
            for obj in object{
                if table.rawValue == DBTableNames.Category.rawValue{
                    let cats : CategoryObject = obj as! CategoryObject
                    let insert = self.categories.insert(self.cat_id <- cats.id,
                                                        self.cat_name <- cats.name)
                    try self.db!.run(insert)

                }
             }
          }
        }catch{
           print("Insert failed \(error)")
           return -1
        }
        return 1
         }
}

然后我继续调用我的代码，通过运行以下命令添加一行:

    let returnValue = Database.instance.addRow(table: DBTableNames(rawValue: entity)!,
                                               object: databaseObject)

我的问题是它总是抛出一个错误说:

Insert failed The operation couldn’t be completed. (SQLite.Result error 0.) and full: cannot rollback - no transaction is active (code: 1)

如果我再次看到此错误，我的 Mac 将会弹出窗口!

整个操作在后台线程中，但我也尝试了以下操作:

    DispatchQueue.main.async{
    let returnValue = Database.instance.addRow(table: DBTableNames(rawValue: entity)!,
                                                   object: databaseObject)
}

没有用。这没有任何意义，因为我也尝试在事务中创建表并且效果很好。

任何帮助将不胜感激!

---

Best Answer-推荐答案

您的 func createTable() 和 func addRow() 方法不是线程安全的。多个线程可以同时访问它。

在您的 Singleton 类中创建一个私有(private)串行 DispatchQueue 并通过此串行队列执行上述功能。这样可以防止多个线程同时访问数据库，串行队列会将并发任务排队。

关于ios - 使用事务插入会引发错误 Sqlite.swift，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/43388443/

---

欢迎光临 OGeek|极客世界-中国程序员成长平台 (http://ogeek.cn/)

Powered by Discuz! X3.4