在Rust中使用sqlx与PostgreSQL实现动态SQL查询的问题

要实现完全动态的SQL查询（表、列、WHERE子句都在运行时确定），你可以通过SQLx提供的PgRow元数据和原始值提取API来实现，核心思路是先获取列信息，再逐行遍历提取每个字段的值：

核心步骤 #

1. 执行动态SQL并获取所有结果行
2. 从结果行中提取列名列表
3. 逐行遍历，针对每个列提取原始值并转换为通用格式

代码实现示例 #

use sqlx::{postgres::PgRow, Postgres, Row};
use serde_json::Value;
use sqlx::Error;

async fn run_dynamic_query(pool: &sqlx::Pool<Postgres>, sql: &str) -> Result<(Vec<String>, Vec<Vec<Value>>), Error> {
    // 执行动态SQL，获取所有结果行
    let rows = sqlx::query(sql).fetch_all(pool).await?;

    if rows.is_empty() {
        return Ok((vec![], vec![]));
    }

    // 从第一行提取所有列的名称
    let column_names: Vec<String> = rows[0]
        .columns()
        .iter()
        .map(|col| col.name().to_string())
        .collect();

    // 处理每一行，将字段值转换为serde_json::Value（通用格式）
    let mut parsed_rows = Vec::new();
    for row in rows {
        let mut row_values = Vec::new();
        for col_name in &column_names {
            // 获取原始字段值，避开编译时类型检查
            let raw_val = row.try_get_raw(col_name)?;
            // 根据PostgreSQL类型转换为通用Value
            let value = match raw_val.type_info().name() {
                "text" | "varchar" | "bpchar" => Value::String(raw_val.try_get::<String>()?),
                "int4" => Value::Number(raw_val.try_get::<i32>()?.into()),
                "int8" => Value::Number(raw_val.try_get::<i64>()?.into()),
                "float4" => Value::Number(serde_json::Number::from_f64(raw_val.try_get::<f32>()? as f64).unwrap()),
                "float8" => Value::Number(serde_json::Number::from_f64(raw_val.try_get::<f64>()?).unwrap()),
                "bool" => Value::Bool(raw_val.try_get::<bool>()?),
                "date" | "timestamp" => Value::String(raw_val.try_get::<chrono::NaiveDateTime>()?.to_string()),
                // 可根据业务需求扩展更多类型
                _ => Value::String(format!("Unsupported type: {:?}", raw_val.type_info().name())),
            };
            row_values.push(value);
        }
        parsed_rows.push(row_values);
    }

    Ok((column_names, parsed_rows))
}

关键细节说明 #

• 获取列元数据：通过PgRow::columns()可以拿到当前结果集的所有列信息，包括列名、类型等，完全不需要编译时提前定义结构
• 原始值提取：try_get_raw方法允许你在不知道具体类型的情况下获取字段的原始数据，避开SQLx的编译时类型检查
• 类型转换：根据PostgreSQL的类型名称（通过type_info().name()获取），将原始值转换为通用的serde_json::Value，方便后续处理或序列化

注意事项 #

• 处理空结果时要提前判断，避免访问rows[0]引发panic
• 类型匹配需要覆盖你业务中用到的所有PostgreSQL类型，未覆盖的类型会被转换为提示字符串
• 如果不需要JSON格式，也可以直接将所有值转换为String，或者根据需求自定义通用类型

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