动态SQL查询与参数化执行最佳实践

function my_try($SQL_SELECTION){
    global $conn, $date1, $date2; // 依赖全局变量
    // ...
    $orders_completed = $conn->query($SQL_SELECTION($date1, $date2)); // 动态调用SQL生成函数
    // ...
}

// 示例：定义多个日期区间
$dateIntervals = [
    [
        'date_from' => '2019-10-29',
        'date_till' => '2020-10-28',
    ],
    [
        'date_from' => '2020-10-29',
        'date_till' => '2021-10-28',
    ],
    // 更多日期区间...
];

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

    // 预处理SQL语句，一次预处理可重复执行
    $stmt = $database->prepare($sql);

    $allRowsets = []; // 存储所有查询的结果

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

        if ($result === false) {
            // 处理执行错误，例如记录日志或抛出异常
            error_log("SQL execution failed for interval " . json_encode($interval) . ": " . implode(", ", $stmt->errorInfo()));
            continue; // 跳过当前区间，继续下一个
        }

        // 获取查询结果
        // 如果预期是多行，使用 fetchAll()
        // 如果预期是单行，使用 fetch()
        $rowset = $stmt->fetchAll(PDO::FETCH_ASSOC); // 假设每次查询可能返回多行

        if ($rowset === false) {
            // 处理获取结果错误
            error_log("Failed to fetch results for interval " . json_encode($interval));
            continue;
        }

        // 在这里可以对获取到的结果进行进一步处理或更新
        // 例如：$updatedRowset = some_processing_function($rowset);

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

    return $allRowsets;
}

// 假设您已经建立了PDO连接
try {
    $dsn = 'mysql:host=localhost;dbname=your_database;charset=utf8mb4';
    $user = 'your_user';
    $password = 'your_password';
    $pdo = new PDO($dsn, $user, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 开启异常模式
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认关联数组
    ]);
} catch (PDOException $e) {
    die("数据库连接失败: " . $e->getMessage());
}

// 准备日期区间数据
$dateIntervals = [
    ['date_from' => '2019-10-01', 'date_till' => '2019-10-31'],
    ['date_from' => '2019-11-01', 'date_till' => '2019-11-30'],
    ['date_from' => '2019-12-01', 'date_till' => '2019-12-31'],
];

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

// 打印所有结果
foreach ($results as $index => $intervalResult) {
    echo "<h3>区间 " . ($index + 1) . " 的结果:</h3>";
    if (empty($intervalResult)) {
        echo "无数据。<br>";
    } else {
        echo "<pre>";
        print_r($intervalResult);
        echo "</pre>";
    }
}