Lib.rs

一个简单的库，可以将 tokio_postgres::row::Row 数据消费到实现了 RowConsumer 特性的结构体。

该包提供了一系列可衍生的实现，可以用来根据偏好消费 PostgreSQL 数据。

• from_row
• from_rows
• consume
• consume_json 如果启用了 consume_json 功能

后者的实现是从 from_row 构建的。

功能

各种功能提供对附加实现和类型的支持。

示例

您可以使用 consume 来将 PostgreSQL 行数据消费到一个结构体中，如下所示。

# tokio_test::block_on(async {
use pgde::ConsumeError;
use pgde::RowConsumer;
use pgde_derive::RowConsumer;
use tokio_postgres::{NoTls, Row};

#[derive(RowConsumer)]
struct Foo {
    Id: i32,
    Data: String,
}

match tokio_postgres::connect("host=localhost user=postgres password=password dbname=postgres", NoTls).await {
    Ok(v) => {
        let client = v.0;
        let conn = v.1;

        tokio::spawn(async move {
            if let Err(e) = conn.await {
                eprintln!("connection error: {}", e);
            }
        });

        let query = "select * from public.\"Foo\";";

        match Foo::consume(&client, query, &[]).await {
            Ok(v) => { // v is of type Vec<Foo>
                match v.first() {
                    Some(v) => println!("Id {} has Data {}", v.Id, v.Data),
                    None => eprintln!("No data in table"),
                }
            },
            Err(v) => match v {
                ConsumeError::ConversionError => eprintln!("Could not convert data"),
                ConsumeError::DatabaseConnectionError => eprintln!("Database errored on processing the query"),
            },
        };
    },
    Err(_) => eprintln!("Could not connect to database"),
};
# })

支持 Vec<T> 和 Option<T> 类型的类型，其中 T 实现 FromSql，可以在结构体中使用，也可以作为独立的消费类型，继承 RowConsumer。查询可空字段时，最好将字段类型包裹在 Option<> 中。请参阅 RowConsumer trait 以了解 from_row 和 from_rows 的使用示例。

此 crate 还提供对各种数据类型的实现，其中一些通过启用功能提供。

测试

测试需要访问没有表的 PostgreSQL 数据库。设置以下环境变量将允许您进行测试。