serde_postgres example

Example.rs

use postgres::{Connection, TlsMode};
use std::error::Error;
use serde::Deserialize;

#[derive(Clone, Debug, Deserialize)]
struct Person {
    name : String,
    data : Vec<u8>,
}


fn main() -> Result<(), Box<Error>> {
    let connection = Connection::connect("postgres://postgres@localhost:5432", TlsMode::None)?;

    connection.execute("CREATE TABLE IF NOT EXISTS person (
    id INTEGER NOT NULL,
    name VARCHAR NOT NULL,
    data BYTEA
    );", &[])?;

    connection.execute("INSERT INTO person (name, data) VALUES ($1, $2)", &[&"Jane", &"My data".as_bytes()])?;

    connection.execute("INSERT INTO person (name, data) VALUES ($1, $2)", &[&"Alice", &"Alice's data".as_bytes()])?;

    let rows = connection.query("SELECT name, data FROM person", &[])?;

    let people = serde_postgres::from_rows::<Person>(&rows)?;

    for person in people {
        dbg!(person);
    }

    Ok(())
}