如何在cassandra-sys-rs连接池中使用actix_web？

[dependencies]
actix-web = "3.0"
cassandra-sys-rs = "0.4"

use actix_web::{web, App, HttpServer};
use cassandra_sys_rs::cassandra::CassSession;
use cassandra_sys_rs::cassandra::CassCluster;
use cassandra_sys_rs::cassandra::CassError;
use std::ptr;

fn create_cassandra_connection() -> Result<CassSession, CassError> {
    unsafe {
        let cluster = CassCluster::new();
        let session = CassSession::new();
        
        let contact_points = "127.0.0.1"; // Cassandra节点的IP地址
        let keyspace = "my_keyspace"; // Cassandra中的键空间
        
        let contact_points_ptr = contact_points.as_ptr() as *const i8;
        let keyspace_ptr = keyspace.as_ptr() as *const i8;
        
        CassCluster::set_contact_points(cluster, contact_points_ptr)?;
        
        let connect_future = CassSession::connect(session, cluster);
        let connect_future_ptr = Box::into_raw(Box::new(connect_future));
        
        let connect_future_result = CassSession::connect_wait(connect_future_ptr);
        Box::from_raw(connect_future_ptr);
        
        let connect_future_result = connect_future_result?;
        
        CassSession::set_keyspace(session, keyspace_ptr)?;
        
        Ok(session)
    }
}

#[actix_rt::main]
async fn main() -> std::io::Result<()> {
    let cassandra_session = create_cassandra_connection().expect("Failed to create Cassandra connection");
    
    HttpServer::new(move || {
        App::new()
            .data(cassandra_session.clone()) // 将Cassandra连接池作为应用程序数据
            .route("/", web::get().to(index))
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}

async fn index(session: web::Data<CassSession>) -> impl Responder {
    let query = "SELECT * FROM my_table";
    
    let query_result = unsafe {
        let query_ptr = query.as_ptr() as *const i8;
        let statement = CassStatement::new(query_ptr, 0);
        
        let future = CassSession::execute(session.get_ref(), statement);
        let future_ptr = Box::into_raw(Box::new(future));
        
        let future_result = CassSession::execute_wait(future_ptr);
        Box::from_raw(future_ptr);
        
        future_result
    };
    
    match query_result {
        Ok(result) => {
            // 处理查询结果
            HttpResponse::Ok().body("Query executed successfully")
        },
        Err(error) => {
            // 处理错误
            HttpResponse::InternalServerError().body(format!("Query execution failed: {:?}", error))
        }
    }
}