PHP中动态SQL查询与日期范围迭代的最佳实践

<?php

// 假设我们已经有一个PDO数据库连接对象 $pdo
// $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');
// $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 开启错误模式

// 定义需要查询的日期区间
$dateIntervals = [
    [
        'date_from' => '2019-10-29',
        'date_till' => '2020-10-28',
    ],
    [
        'date_from' => '2020-10-29',
        'date_till' => '2021-10-28',
    ],
    [
        'date_from' => '2021-10-29',
        'date_till' => '2022-10-28',
    ],
    // 更多日期区间...
];

/**
 * 根据给定的日期区间数组，迭代执行SQL查询。
 *
 * @param PDO $database PDO数据库连接对象。
 * @param array $intervals 包含日期区间的数组，每个元素应包含 'date_from' 和 'date_till' 键。
 * @return array 返回一个包含所有查询结果的数组。
 */
function queryDataByIntervals(PDO $database, array $intervals): array
{
    // 定义SQL查询模板，使用命名占位符进行参数绑定
    $sql = "SELECT id, order_date, total_amount FROM orders WHERE order_date BETWEEN :date_from AND :date_till";

    // 准备SQL语句，只需准备一次
    $stmt = $database->prepare($sql);

    $allResults = [];

    foreach ($intervals as $interval) {
        // 绑定参数并执行查询
        $result = $stmt->execute([
            ':date_from' => $interval['date_from'],
            ':date_till' => $interval['date_till'],
        ]);

        if ($result === false) {
            // 错误处理：记录日志或抛出异常
            error_log("SQL execution failed for interval: " . json_encode($interval));
            // 根据实际需求决定是否继续或中断
            continue; 
        }

        // 获取所有匹配的行
        $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

        // 可选：在此处对获取到的行集进行进一步处理，例如更新、汇总等
        // foreach ($rows as &$row) {
        //     $row['processed_at'] = date('Y-m-d H:i:s');
        // }

        $allResults[] = $rows;
    }

    return $allResults;
}

// 调用函数执行查询
// $queryResults = queryDataByIntervals($pdo, $dateIntervals);

// 打印结果（示例）
// foreach ($queryResults as $intervalResult) {
//     echo "--- New Interval Results ---" . PHP_EOL;
//     foreach ($intervalResult as $row) {
//         print_r($row);
//     }
// }
?>

/**
 * 通过一个复杂的SQL查询一次性获取所有日期区间的数据。
 * 这种方法适用于SQL逻辑允许且数据量适中的情况。
 *
 * @param PDO $database PDO数据库连接对象。
 * @param array $intervals 包含日期区间的数组。
 * @return array 返回所有查询结果的数组。
 */
function queryAllDataWithComplexSql(PDO $database, array $intervals): array
{
    $whereClauses = [];
    $params = [];

    foreach ($intervals as $index => $interval) {
        $dateFromKey = ":date_from_" . $index;
        $dateTillKey = ":date_till_" . $index;

        $whereClauses[] = "(order_date BETWEEN $dateFromKey AND $dateTillKey)";
        $params[$dateFromKey] = $interval['date_from'];
        $params[$dateTillKey] = $interval['date_till'];
    }

    if (empty($whereClauses)) {
        return []; // 没有区间，直接返回空
    }

    $sql = "SELECT id, order_date, total_amount FROM orders WHERE " . implode(" OR ", $whereClauses);

    $stmt = $database->prepare($sql);
    $stmt->execute($params);

    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}

// 调用函数
// $allCombinedResults = queryAllDataWithComplexSql($pdo, $dateIntervals);
// print_r($allCombinedResults);