使用 PDO 对基于另一个查询结果的查询执行功能 [重复]

Question

我目前正在使用 PDO 对 MySQL 表进行选择，并让它打印结果，这在终端中是正确的。

我正在尝试对其应用“while”循环，以从 odbc 数据库中选择记录，其中第一个查询中的 order_id 等于第二个查询中的 invnoc。我认为我的问题是我如何调用order_id 并执行 DB2 部分中的语句。

如果我运行这个：

$ordStatSql = 'SELECT order_id, order_status, is_placement, date_updated 
            FROM order_status';
try{
$ordStat = $MysqlConn->prepare($ordStatSql);
$result = $ordStat->execute();
}
 catch(PDOException $ex)
{
  echo "QUERY FAILED!: " .$ex->getMessage();
 }

while($row = $ordStat->fetch(PDO::FETCH_ASSOC))

{
    echo $row['order_id'] . $row['order_status'] . $row['is_placement'] . $row['date_updated'] . "\n";

}

它运行良好，没有错误，并且打印出我预期的每一行。

但完整的脚本：

 $ordStatSql = 'SELECT order_id, order_status, is_placement, date_updated 
            FROM order_status';
try{
$ordStat = $MysqlConn->prepare($ordStatSql);
$result = $ordStat->execute();
}
 catch(PDOException $ex)
{
  echo "QUERY FAILED!: " .$ex->getMessage();
 }

while($row = $ordStat->fetch(PDO::FETCH_ASSOC))

{
    echo $row['order_id'] . $row['order_status'] . $row['is_placement'] . $row['date_updated'] . "\n";

    $detailStatCheck = '
        SELECT 
             invnoc as INVOICE,
             fstatc as STATUS,
             cstnoc AS DEALER,
             framec AS FRAME,
             covr1c AS COVER,
             colr1c AS COLOR ,
             extd2d AS SHIPDATE,
             orqtyc AS QUANTITY
        FROM GPORPCFL
        WHERE invnoc IN ?
        ORDER BY invnoc asc 
    ';

    try{
    $detailCheck = $DB2conn->prepare($detailStatCheck);
    $detailRslt = $detailCheck->execute(['order_id']);
    $count2 = $detailCheck->rowcount();
    }
    catch(PDOException $ex)
    {
        echo "QUERY FAILED!: " .$ex->getMessage();
    }
}
echo "Matches:" . $count2

它打印相同的 order_id 数字，显然需要更长的时间，但匹配显示 -1。我知道它正在拉匹配，因为我手动运行它并且它匹配每条记录。我想知道是我循环不正确还是归结为 PDO 错误。

非常感谢任何帮助。

Answer 1

首先，WHERE invnoc IN ? 应该是 = ?。 IN 用于匹配列表中的值，而不是单个值。

其次，您需要将调用中的行中的值提供给execute()：

$detailRslt = $detailCheck->execute($row['order_id']);

第三，使用ORDER BY invnoc 没有意义，因为您只是匹配一个invnoc 值。

第四，每次循环都会覆盖$count2 变量。你应该在循环之前将它初始化为0，然后递增它，这样你就得到了总数：

$count2 += $detailCheck->rowCount();

您也不需要在每次循环中都准备查询。查询不会改变，所以你可以在循环之前准备一次，然后在循环中执行。

另一种选择是将所有order_id 值收集到一个数组中，并准备一个查询，将它们与IN 一次性匹配。

$order_ids = [];
while ($row = $ordStat->fetch(PDO::FETCH_ASSOC)) {
    $order_ids[] = $row['order_id'];
}
if (count($order_ids) > 0) {
    $placeholders = implode(',', array_fill(0, count($order_ids), '?'));
    $detailStatCheck = "
        SELECT 
             invnoc as INVOICE,
             fstatc as STATUS,
             cstnoc AS DEALER,
             framec AS FRAME,
             covr1c AS COVER,
             colr1c AS COLOR ,
             extd2d AS SHIPDATE,
             orqtyc AS QUANTITY
        FROM GPORPCFL
        WHERE invnoc IN ($placeholders)
        ORDER BY invnoc asc 
    ";
    try {
        $detailCheck = $DB2conn->prepare($detailStatCheck);
        $detailRslt = $detailCheck->execute($order_ids);
        $count2 = $detailCheck->rowCount();
        echo "Matches: $count2";
    } catch(PDOException $ex) {
        echo "QUERY FAILED!: " .$ex->getMessage();
    }
}

Answer 2

您的查询工作正常（除了其他答案/cmets 所说的）。您的问题实际上是在 ODBC 数据库上的 SELECT 查询上使用 rowCount()。来自the manual：

使用 odbc_num_rows() 来确定 SELECT 后可用的行数将返回 -1 与许多驱动程序。

所以如果需要计数，需要选择COUNT(*)作为字段，然后查看值：

while($row = $ordStat->fetch(PDO::FETCH_ASSOC))
{
    echo $row['order_id'] . $row['order_status'] . $row['is_placement'] . $row['date_updated'] . "\n";

    $detailStatCheck = '
        SELECT 
            COUNT(*)
        FROM GPORPCFL
        WHERE invnoc = ?
    ';

    try {
        $detailCheck = $DB2conn->prepare($detailStatCheck);
        $detailRslt = $detailCheck->execute(['order_id']);
        $count2 = $detailCheck->fetch()[0]; // <---- correct count
    }
        catch(PDOException $ex)
    {
        echo "QUERY FAILED!: " .$ex->getMessage();
    }
}