PostgreSQL中COPY(...) TO STDOUT二进制模式下如何绑定参数

PostgreSQL的COPY属于实用命令（Utility Command），而非可优化的DML查询语句，预编译阶段不会解析其内部嵌套子查询中的$1类参数占位符，因此你预编译的COPY语句会被识别为无参数需求，传入参数就会触发报错。

你可以使用libpq提供的PQescapeLiteral函数对参数进行安全转义后构造COPY语句，无需手动处理类型格式化、字符串裁剪拼接，也能完全避免SQL注入风险。

TEST(TSStorage, CopyParamTest)
{
    auto connPtr = PQconnectdb("postgresql://postgres:pswd@localhost/some_db");
    if (PQstatus(connPtr) != CONNECTION_OK) {
        auto errorMsg = PQerrorMessage(connPtr);
        PQfinish(connPtr);
        throw std::runtime_error(errorMsg);
    }

    // 处理参数：libpq自动完成转义、类型适配，完全避免SQL注入
    int seriesId = 5;
    std::string seriesIdStr = std::to_string(seriesId);
    char* escapedId = PQescapeLiteral(connPtr, seriesIdStr.c_str(), seriesIdStr.size());
    if (!escapedId) {
        auto errorMsg = PQerrorMessage(connPtr);
        PQfinish(connPtr);
        throw std::runtime_error(errorMsg);
    }

    // 构造COPY语句
    std::string sql = R"(
        COPY (
                SELECT version_ts
                FROM test_point 
                WHERE 
                    serie_id = )" + std::string(escapedId) + R"(
            ) TO STDOUT (FORMAT binary);
      )";
    PQfreemem(escapedId); // 释放libpq分配的转义字符串内存

    // 直接执行语句，指定输出为二进制格式
    auto result = PQexecParams(connPtr, sql.c_str(), 0, nullptr, nullptr, nullptr, nullptr, 1);

    // 结果校验逻辑
    auto testRes = [&](ExecStatusType status)
    {
        if (PQresultStatus(result) != status)
        {
            PQclear(result);
            auto errorMsg = PQerrorMessage(connPtr);
            PQfinish(connPtr);
            throw std::runtime_error(errorMsg);
        }
    };

    testRes(PGRES_COPY_OUT);

    // 后续可正常通过PQgetCopyData读取二进制结果

    PQclear(result);
    PQfinish(connPtr);
}

如果需要处理时间戳等复杂类型参数，只需要将参数转换为合法的字符串形式后传入PQescapeLiteral即可，libpq会自动完成所有转义、格式适配工作，不需要你手动处理任何格式裁剪、拼接逻辑。

内容的提问来源于stack exchange，提问作者Aleksander Stankiewicz