将数据解析为Vec<T>，并将向量插入postgresql

use serde::Deserialize;

#[derive(Debug, Deserialize)]
struct Data {
    // 定义数据结构，根据实际情况进行调整
    field1: String,
    field2: i32,
    // ...
}

fn parse_data<T: Deserialize<'static>>(data: &str) -> Result<Vec<T>, Box<dyn std::error::Error>> {
    let parsed_data: Vec<T> = serde_json::from_str(data)?;
    Ok(parsed_data)
}

fn main() {
    let data_str = r#"
        [
            {"field1": "value1", "field2": 123},
            {"field1": "value2", "field2": 456}
        ]
    "#;

    let parsed_data: Vec<Data> = parse_data(data_str).unwrap();
    println!("{:?}", parsed_data);
}

use tokio_postgres::{NoTls, Error};

#[derive(Debug)]
struct Data {
    field1: String,
    field2: i32,
    // ...
}

async fn insert_data(data: Vec<Data>) -> Result<(), Error> {
    let (client, connection) = tokio_postgres::connect("host=localhost user=postgres", NoTls).await?;
    tokio::spawn(async move {
        if let Err(e) = connection.await {
            eprintln!("connection error: {}", e);
        }
    });

    for item in data {
        let query = format!("INSERT INTO table_name (field1, field2) VALUES ('{}', {})", item.field1, item.field2);
        client.execute(&query, &[]).await?;
    }

    Ok(())
}

#[tokio::main]
async fn main() {
    let data = vec![
        Data { field1: "value1".to_string(), field2: 123 },
        Data { field1: "value2".to_string(), field2: 456 },
    ];

    if let Err(e) = insert_data(data).await {
        eprintln!("error inserting data: {}", e);
    }
}