db_pools

为Rocket提供异步数据库驱动集成。有关完整用法详情，请参阅库文档。

用法

1. 将 rocket_db_pools 作为依赖项添加，并启用一个或多个 数据库驱动功能

   [dependencies.rocket_db_pools]
   version = "0.2.0"
   features = ["sqlx_sqlite"]
   

2. 为您的数据库选择一个名称，此处为 sqlite_logs。 配置 至少一个数据库的URL

   [default.databases.sqlite_logs]
   url = "/path/to/database.sqlite"
   

3. 为单元类型（此处为 Logs）派生 Database，该类型包装所选驱动程序的 Pool 类型，并带有装饰 #[database("name")]。将 Type::init() 添加到您的应用 Rocket 中以初始化数据库池

   use rocket_db_pools::{Database, Connection};
   
   #[derive(Database)]
   #[database("sqlite_logs")]
   struct Logs(sqlx::SqlitePool);
   
   #[launch]
   fn rocket() -> _ {
       rocket::build().attach(Logs::init())
   }
   

4. 使用 Connection<Type> 作为请求守卫来检索一个活动的数据库连接

   #[get("/<id>")]
   async fn read(mut db: Connection<Logs>, id: i64) -> Result<Log> {
       sqlx::query!("SELECT content FROM logs WHERE id = ?", id)
           .fetch_one(&mut *db)
           .map_ok(|r| Log(r.content))
           .await
   }