use sqlx::postgres::PgPoolOptions;
// use sqlx::mysql::MySqlPoolOptions;// etc.#[async_std::main]// or #[tokio::main]
async fnmain() -> 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 parameterlet 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）持有，需要的时候用提取器拿
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(()) }