php - Mysql:插入后选择找不到刚插入的行

Question

我没有在我的程序中使用事务，所以我认为所有数据库操作都会立即提交。

我有一个 php 程序在表中查找值，如果找到则返回 id。如果没有找到，它会写一个新行。稍后它会重复，它应该会找到我刚刚插入的数据，但实际上并没有，所以我得到了一个重复的错误。

如何强制 mysql 写入数据以便在插入后返回有效结果？我尝试过刷新表格，但这并没有改变我的结果。

更多详情:

我以为是mysql的一般问题，但似乎与使用Cakephp的模型查询有关。

我正在使用 Controller 将一个 CSV 文件解析为多个表，然后动态绑定(bind)一个模型，并在遇到数据时使用查询调用将数据插入表中。我在应用程序的其余部分使用 CakePHP，但解析能力是一种一次性功能，因此我没有花很多时间试图让它变得优雅。

Import 模型没有关联表，所以我手动绑定(bind)到 Tracking 模型。

将代码解释为相关查询:

    $this->Import->bindModel(array('hasOne' => array('Tracking')));

    $insert =<<<DONE
INSERT INTO tracking (id, created, employee_id, client_id, borrower_name, loan_number,
                  loan_amount, activity_id, program_id, rate_id, lock_period,
                  lo_price, investor_price,  committed_price, purchase_advice_price,
                  lock_type, investor_id, time_taken, notes,audited,audit_notes,
                  import_notes, import_error, uniqueness)
                  VALUES (NULL, '%s', %d,  %d,  '%s', '%s',
                          %.2f, %d, %d,  %d, %d,
                          %.5f, %.5f, %.5f, %.5f,
                          %d, %d, %d, '%s', %d, '%s',
                          '%s', %d, %d)
DONE;
while ($row = fgetscsv($fh))
    # Lots of processing deleted

    if (! $this->_exists($row))
    {
       $sql = vsprint($insert, $row);
       $this->Import->Tracking->query($sql); # This is where I'll get a duplicate error
    }
} # end of function

# I've created a unique index on columns that should be unique and I do the query on    
# them here.
private _exists($mydata)
{
       $find = "SELECT id FROM tracking WHERE created = '%s' AND employee_id = %d" AND
            activity_id = $d AND ...";
       $sql = sprintf($find, $mydata[0], $mydata[1]);
       return $this->Import->Tracking->query($sql);
}

所以，问题似乎出在 Cakephp 及其对模型查询的处理上。

我可能可以从 Cake 中提取这段代码并使用独立的 php 程序，但由于我已经在使用 Cakephp，所以我想我应该将导入模型放入其中。

补充说明:选择是对的，但是我没有逐字抄写，因为它很长，我用省略号来表示。它确实有效，因为我可以复制/粘贴到 mysql session 中并选择数据。第二次运行它，它会找到数据。

其他人是否觉得 Cakephp 可能将整个事情包装到一个大事务中，直到您退出 Controller 才提交？这难道不能解释为什么它第二次运行时会找到那些行吗？

我想我要么需要弄清楚如何让 Cakephp 提交这些插入，要么我不应该为此使用 Model->query 并以其他方式进行，或者不为我的项目的这一部分使用 Cakephp。

====

谢谢!

Answer 1

在 CakePHP 2.5.5 上，仅供将来引用(即使是我自己，如果我忘记了解决方案并在将来找到自己的答案......嗨!)，好吧，这个问题是由于查询缓存引起的。修复:

$this->Import->Tracking->query($sql, false);

添加false 参数将关闭查询缓存。只需阅读关于方法的评论 http://api.cakephp.org/2.5/source-class-Model.html#3363-3366