我已经创建了一个数据库类:
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-推荐答案 strong>
您的 func createTable() 和 func addRow() 方法不是线程安全的。多个线程可以同时访问它。
在您的 Singleton 类中创建一个私有(private)串行 DispatchQueue 并通过此串行队列执行上述功能。这样可以防止多个线程同时访问数据库,串行队列会将并发任务排队。
关于ios - 使用事务插入会引发错误 Sqlite.swift,我们在Stack Overflow上找到一个类似的问题:
https://stackoverflow.com/questions/43388443/
|