使用PDO在2个不同数据库中重复行

Question

我正在使用PDO(mysql)创建2个不同的数据库连接.我想在一个不同的数据库中将一行数据从一个表传输到另一个表.这不是行的重复,只选择了某些行.

我无法让它工作,任何想法？

  private function moveCallToProduction() {
    try {
        $sql = "SELECT * FROM `calls` WHERE `id`=':id'";
        $query = $this->staging->prepare($sql);
        $query->execute($array);
        $results = $query->fetchAll(PDO::FETCH_ASSOC);
        try {
            $sql = "INSERT INTO `calls` (`id`,`sip_id`,`extension`,`caller_id`,`stage`,`status`,`survey_id`,`start`,`answer`,`hangup`,`end`) VALUES ('?','?','?','?','?','?','?','?','?','?','?')";
            $query = $this->production->prepare($sql);
            $query->execute($results);
        }
        catch(PDOException $e) {
            $this->informer("FATAL","There was a problem");
        }

    }
    catch(PDOException $e) {
        $this->informer("FATAL","We're unable to transport the call from the staging to production server. Error: ".$e->getMessage());
    }
}

Answer 1

fetchAll()返回包含所有结果集行的数组.您需要迭代每一行并单独插入它.例如:

...
$sql = "SELECT * FROM `calls` WHERE `id`=':id'";
$query = $this->staging->prepare($sql);
$query->execute($array);
$results = $query->fetchAll(PDO::FETCH_ASSOC);
foreach($results as $row) {
    try {
        $sql = "INSERT INTO `calls` (`id`,`sip_id`,`extension`,`caller_id`,`stage`,`status`,`survey_id`,`start`,`answer`,`hangup`,`end`) VALUES ('?','?','?','?','?','?','?','?','?','?','?')";
        $query = $this->production->prepare($sql);
        $query->execute($row);
    }
    catch(PDOException $e) {
        $this->informer("FATAL","There was a problem");
    }
}
...

您还可以使用以下语句:while($result = $query->fetch(PDO::FETCH_ASSOC))而不是fetchAll()迭代结果而不必将它们存储在内存中.

要考虑的一件事是,如果遇到异常,您想要做什么.由于您多次插入PDO::beginTransation(),因此PDO::commit()如果没有异常发生,您可以考虑在开始时使用,并PDO::rollBack()在发生异常时取消任何更改.通过这种方式,您可以确保所有内容都可以进行转移.