cs97 / easy-postgres-example

Cargo.toml

[dependencies]
tokio = { version = "1.0", features = ["full"] }
sqlx = { version = "0.7.4", default-features = false, features = ["runtime-tokio-rustls", "postgres"] }

connect to pool

use std::error::Error;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
  let url = "postgres://postgres:[email protected]:5432";
	let conn = sqlx::postgres::PgPool::connect(url).await?;
	Ok(())
}

migrate

async fn migrate(pool: &sqlx::PgPool) -> Result<(), Box<dyn Error>> {
	let query = "create table table_name (var1 varchar not null, var2 varchar not null, var3 varchar not null);";
	sqlx::query(query)
		.execute(pool)
		.await?;
	Ok(())
}

INSERT

async fn create(kunde: &Kunde, pool: &sqlx::PgPool) -> Result<(), Box<dyn Error>> {
	let query = "INSERT INTO table_name (var1, var2, var3) VALUES ($1, $2, $3)";

	sqlx::query(query)
		.bind(&data.var1)
		.bind(&data.var2)
		.bind(&data.var3)
		.execute(pool)
		.await?;
	
	Ok(())
}