如何在Rust Actix中传递ScyllaDB连接

[dependencies]
actix-web = "x.x.x"
scylla-rust-driver = "x.x.x"

use actix_web::{web, App, HttpServer};
use scylla::Session;

#[actix_rt::main]
async fn main() -> std::io::Result<()> {
    // 创建ScyllaDB连接池
    let session = Session::connect("127.0.0.1:9042").await.expect("连接ScyllaDB失败");
    let pool = web::Data::new(session);

    // 启动应用并将连接池传递给应用
    HttpServer::new(move || {
        App::new()
            .app_data(pool.clone())  // 将连接池传递给应用
            .route("/", web::get().to(index))
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}

use actix_web::{web, Responder};
use scylla::{Query, Session};
use scylla_rust_driver::IntoTypedRows;

async fn index(pool: web::Data<Session>) -> impl Responder {
    let query = "SELECT * FROM my_table";
    let prepared_query = Query::new(query);

    match pool.query(prepared_query).await {
        Ok(query_result) => {
            // 处理查询结果
            for row in query_result.into_typed::<YourRowStruct>() {
                // 处理每一行的数据
            }
            "查询成功"
        }
        Err(err) => {
            eprintln!("查询出错：{}", err);
            "查询出错"
        }
    }
}