在Rust的Tauri后端中如何将postgres的Vec<Row>转为Vec<String>

核心思路 #

由于PostgreSQL查询的列数、类型完全由前端传入的SQL决定，无法提前固定结构，最适配的方案是将查询结果转换为通用JSON结构（Vec<serde_json::Value>）。Tauri命令支持返回实现serde::Serialize的类型，而serde_json::Value天生满足序列化要求，能完美适配任意结构的查询结果。

步骤1：添加必要依赖 #

在Cargo.toml中补充serde及postgres的相关特性：

[dependencies]
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"
postgres = { version = "0.19", features = ["with-serde_json"] }

开启postgres的with-serde_json特性后，可直接将数据库行转换为JSON值。

步骤2：改造查询处理函数 #

利用postgres的serde_json集成，动态遍历每一行的所有列，转换为JSON对象：

use serde_json::Value;
use postgres::Row;

#[tauri::command]
fn run_query(query: String) -> Result<Vec<Value>, String> {
    let mut conn = database_util::get_db_connection();
    
    match conn.query(query.as_str(), &[]) {
        Ok(rows) => {
            let result_rows: Vec<Value> = rows.into_iter()
                .map(|row| row_to_json(row))
                .collect();
            
            Ok(result_rows)
        },
        Err(err) => Err(err.to_string())
    }
}

// 辅助函数：将postgres Row转换为serde_json对象
fn row_to_json(row: Row) -> Value {
    let mut json_obj = serde_json::Map::new();
    
    // 动态遍历所有列，获取列名与对应值
    for col in row.columns() {
        let col_name = col.name();
        // 自动适配字段类型，转换失败则返回Null
        let value: Value = row.get_with(col_name, &()).unwrap_or(Value::Null);
        json_obj.insert(col_name.to_string(), value);
    }
    
    Value::Object(json_obj)
}

更简洁的替代方案：让数据库直接返回JSON #

如果不想在Rust中处理类型转换，可以直接修改查询语句，让PostgreSQL自行将结果转为JSON：

use serde_json::Value;

#[tauri::command]
fn run_query(query: String) -> Result<Vec<Value>, String> {
    let mut conn = database_util::get_db_connection();
    // 包装原查询，让数据库返回每行的JSON结构
    let wrapped_query = format!("SELECT row_to_json(t) FROM ({}) t", query);
    
    match conn.query(&wrapped_query, &[]) {
        Ok(rows) => {
            let result_rows: Vec<Value> = rows.into_iter()
                .map(|row| row.get(0))
                .collect();
            
            Ok(result_rows)
        },
        Err(err) => Err(err.to_string())
    }
}

该方案将类型转换逻辑完全交给数据库，代码更简洁。

之前尝试失败的原因 #

• 第一次尝试中row.get(i)要求提前指定具体类型（如Option<String>），但动态列场景下无法预知字段类型，导致编译报错。
• 第二次尝试硬编码列数与类型，无法适配任意查询，扩展性极差。

重要注意事项 #

• SQL注入风险：直接接收前端传入的完整SQL语句极度危险，仅适合本地桌面应用（用户为可信主体）。若面向外部用户，必须改用参数化查询，禁止直接传递完整SQL。
• 错误处理：示例中unwrap_or(Value::Null)为简化处理，实际项目可根据需求添加更细致的错误捕获逻辑。

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