use sqlx::postgres::PgPoolOptions;
// use sqlx::mysql::MySqlPoolOptions;
// etc.
#[async_std::main]
// or #[tokio::main]
async fn main() -> Result<(), sqlx::Error> {
// 这里的pool是做成全局变量嘛
let pool = PgPoolOptions::new()
.max_connections(5)
.connect("postgres://postgres:password@localhost/test").await?;
// Make a simple query to return the given parameter
let row: (i64,) = sqlx::query_as("SELECT $1")
.bind(150_i64)
.fetch_one(&pool).await?;
assert_eq!(row.0, 150);
Ok(())
}
评论区
写评论好的,谢谢!
--
👇
gwy15: 一般是由 app 实例(比如 actix 或者 rocket)持有,需要的时候用提取器拿
一般是由 app 实例(比如 actix 或者 rocket)持有,需要的时候用提取器拿