我为 MySQL 数据库创建了一个池,如下所示:
let database_url = env::var("DATABASE_URL").expect("set DATABASE_URL");
let manager = ConnectionManager::<MysqlConnection>::new(database_url);
let pool = r2d2::Pool::builder()
.build(manager)
.expect("Failed to create pool.");
像这样包含在actix中:
HttpServer::new(move || App::new()
.data(pool.clone()) // <-- HERE
.service(
web::resource("/infos")
.route(web::post().to(get_infos))
))
.bind("127.0.0.1:8080")?
.start();
println!("Starting http server: 127.0.0.1:8080");
问题来了,如何在这个 info 函数中使用它:
pub fn get_infos(conn: &MysqlConnection) -> Vec<Book> {
all_books
.order(books::id.desc())
.load::<Book>(conn)
.expect("error loading the books")
}
直接将 MySQL 连接的一个实例传递给 get_infos 运行良好,但使用池我不知道如何处理它?!请问有什么帮助吗?
为了更清楚地说明,我的目标是使用 POOLING 而不是只使用一个实例,就像这段代码中的情况一样:
let database_url = env::var("DATABASE_URL").expect("set DATABASE_URL");
let conn = MysqlConnection::establish(&database_url).unwrap();
// And then passing as argument "conn" to get_infos function.
我在前面的代码中启动了 POOL to actix:
.data(pool.clone()) // <-- HERE
但是如何将它作为参数传递给get_infos
函数。
再次感谢您的帮助。