PHP动态SQL查询与日期区间处理的最佳实践

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

/**
 * 迭代日期区间并执行数据库查询
 *
 * @param PDO $database PDO数据库连接对象
 * @param array $dateIntervals 包含日期区间的数组，每个元素是一个关联数组，包含 'date_from' 和 'date_till'
 * @return array 查询结果的集合
 */
function intervalIteration(PDO $database, array $dateIntervals): array
{
    // 定义基础SQL查询语句，使用命名占位符
    $sql = "SELECT row.id, row.name FROM your_table row WHERE row.date BETWEEN :date1 AND :date2";

    // 准备SQL语句，这将只执行一次，提高效率并防止SQL注入
    $stmt = $database->prepare($sql);

    $rowsets = []; // 用于存储所有查询结果的数组

    // 遍历每个日期区间
    foreach ($dateIntervals as $interval) {
        // 绑定参数并执行预处理语句
        $result = $stmt->execute([
            ':date1' => $interval['date_from'],
            ':date2' => $interval['date_till'], // 注意：原问题中使用了 'date_until'，这里统一为 'date_till'
        ]);

        // 错误处理：检查执行是否成功
        if ($result === false) {
            // 实际应用中应记录错误日志或抛出异常
            error_log("SQL execution failed for interval: " . json_encode($interval));
            continue; // 跳过当前区间，继续下一个
        }

        // 获取查询结果
        // 如果期望获取多行，可以使用 fetchAll()
        // 如果期望获取单行，可以使用 fetch()
        $rowset = $stmt->fetchAll(PDO::FETCH_ASSOC); // 获取所有匹配的行，以关联数组形式返回

        // 错误处理：检查是否成功获取结果
        if ($rowset === false) {
            error_log("Failed to fetch results for interval: " . json_encode($interval));
            continue;
        }

        // 将当前区间的查询结果添加到总结果集中
        $rowsets[] = $rowset;
    }

    return $rowsets;
}

// 示例：如何调用上述函数
// 假设你已经有了一个PDO数据库连接实例 $pdo
try {
    $dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8';
    $username = 'root';
    $password = 'password';
    $pdo = new PDO($dsn, $username, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 启用异常模式
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 默认获取关联数组
    ]);
} catch (PDOException $e) {
    die("数据库连接失败: " . $e->getMessage());
}

$allResults = intervalIteration($pdo, $dateIntervals);

// 处理 $allResults
foreach ($allResults as $intervalResults) {
    foreach ($intervalResults as $row) {
        echo "ID: " . $row['id'] . ", Name: " . $row['name'] . "\n";
    }
}