2

我想遍历一个对象数组并根据 ID 更新 SQLite 数据库中的相应行。我想在一笔交易中做到这一点。我知道我可以使用：

sqlite3_exec(db, "BEGIN", 0, 0, 0);
sqlite3_exec(db, "COMMIT", 0, 0, 0);

但是，我不确定如何在事务中编写更新语句。我需要将不同的变量绑定到语句。现在代码如下所示： 

-(void)someUpdateMethod
{
    sqlite3 *db;

    //Establish connection to db
    if (sqlite3_open([[self dbFilePath] UTF8String], &db) == SQLITE_OK)
    {
        const char *query = "UPDATE Table SET Value1 = ?, Value2 = ?";

        sqlite3_stmt *compiledStatement = nil;

        sqlite3_exec(db, "BEGIN EXCLUSIVE TRANSACTION", 0, 0, 0);
        for (someObject *obj in uArray)
        {
            // Repeated statement - This is what I'm not sure of...
            if(sqlite3_prepare(db, query, -1, &compiledStatement, NULL) == SQLITE_OK)
            {
                sqlite3_bind_int(compiledStatement, 1, [obj value1]);
                sqlite3_bind_int(compiledStatement, 2, [obj value2]);
            }
            if (sqlite3_step(compiledStatement) != SQLITE_DONE) NSLog(@"DB not updated. Error: %s",sqlite3_errmsg(db));
            if (sqlite3_finalize(compiledStatement) != SQLITE_OK) NSLog(@"SQL Error: %s",sqlite3_errmsg(db));
        }
        if (sqlite3_exec(db, "COMMIT TRANSACTION", 0, 0, 0) != SQLITE_OK) NSLog(@"SQL Error: %s",sqlite3_errmsg(db));
        sqlite3_close(db);
    }
    else
    NSLog(@"sql-error: %s", sqlite3_errmsg(db));
}

无论 Begin 和 Commit 语句如何，每次更新都会访问数据库。我很确定这是因为 step 语句，但如果我删除它，更新就不会发生。我希望一次编写所有更新。是否可以使用 sqlite3_exec 并且仍然为数组中的每个对象绑定变量？还是我应该以不同的方式准备声明？任何交易内部应该是什么样子的例子都会对我有很大的帮助！

4

1 回答 1

14

你的方法会如你所愿；即使 sqlite 正在访问磁盘，在您提交之前，其他事务也看不到更新。因此，从这个意义上说，它们是“一次全部编写的”。

如果将 prepare 移到循环之外，您的代码可能会更有效率。如果这样做，请sqlite3_reset在循环内部和循环sqlite3_finalize之后使用。

  sqlite3_exec(db, "BEGIN EXCLUSIVE TRANSACTION", 0, 0, 0);
  if(sqlite3_prepare(db, query, -1, &compiledStatement, NULL) == SQLITE_OK)
  {
    for (someObject *obj in uArray)
    {
        sqlite3_bind_int(compiledStatement, 1, [obj value1]);
        sqlite3_bind_int(compiledStatement, 2, [obj value2]);
        if (sqlite3_step(compiledStatement) != SQLITE_DONE) NSLog(@"DB not updated. Error: %s",sqlite3_errmsg(db));
        if (sqlite3_reset(compiledStatement) != SQLITE_OK) NSLog(@"SQL Error: %s",sqlite3_errmsg(db));
    }
  }
  if (sqlite3_finalize(compiledStatement) != SQLITE_OK) NSLog(@"SQL Error: %s",sqlite3_errmsg(db));
  if (sqlite3_exec(db, "COMMIT TRANSACTION", 0, 0, 0) != SQLITE_OK) NSLog(@"SQL Error: %s",sqlite3_errmsg(db));
  sqlite3_close(db);
于 2012-08-27T01:59:57.813 回答