如何使用Postgres-nio客户端执行预准备语句？执行报错求助

错误原因分析 #

你当前的写法存在两个核心问题：

1. 字符串插值传递参数错误：直接用\(storeLevel.id)进行字符串插值，会破坏预准备语句的参数绑定逻辑，还可能引发SQL语法错误或注入风险。
2. EXECUTE语句的参数传递不符合Postgres规范：Postgres执行预准备语句时，参数需要通过占位符（如$1）绑定，而非直接嵌入SQL字符串。

另外PSQLError error 1是通用错误码，通常对应语法错误、预准备语句未定义或参数类型不匹配。

修正方案 #

方案1：正确执行已创建的预准备语句 #

改用Postgres参数占位符语法，通过query方法的values参数传递实际参数：

do {
    // 使用$1作为参数占位符，通过values数组传递参数
    let rows = try await client.query("EXECUTE prepared_statement($1)", values: [storeLevel.id])
    
    for try await (id, tstamp) in rows.decode((String, Date).self) {
        let object = NewObj(id: id, tstamp: tstamp)
        objectBuf.append(object)
    }
} catch let error as PSQLError {
    // 捕获具体错误信息，便于排查问题
    print("Postgres错误详情：\(error.message)，错误码：\(error.code)")
}

方案2：使用Postgres-nio原生预准备语句API（推荐） #

直接通过框架的prepare方法创建预准备语句再执行，更符合规范且安全：

do {
    // 提前创建可复用的预准备语句
    let preparedStmt = try await client.prepare("SELECT id, tstamp FROM your_table WHERE level_id = $1")
    // 传递参数执行语句
    let rows = try await preparedStmt.query([storeLevel.id])
    
    for try await (id, tstamp) in rows.decode((String, Date).self) {
        let object = NewObj(id: id, tstamp: tstamp)
        objectBuf.append(object)
    }
} catch let error as PSQLError {
    print("Postgres错误详情：\(error.message)，错误码：\(error.code)")
}

额外排查点 #

• 确认prepared_statement已通过PREPARE语句正确创建，且参数类型与storeLevel.id完全匹配（比如前者是uuid类型，后者不能是字符串）。
• 通过捕获PSQLError打印具体错误信息，定位是否是预准备语句不存在、参数类型不匹配等具体问题。

内容的提问来源于stack exchange，提问作者Duncan Groenewald