Axum通过共享状态的pgconnection
创始人
2024-09-29 09:30:03
0

要使用Axum通过共享状态的pgconnection,您需要按照以下步骤进行操作:

  1. 安装Axum和pg连接器。
[dependencies]
axum = "0.2"
tokio = { version = "1", features = ["full"] }
postgres = "0.17"
  1. 创建一个共享状态的pg连接器结构。
use std::sync::Arc;
use axum::prelude::*;
use axum::AddExtensionLayer;
use tokio_postgres::{Client, NoTls};

#[tokio::main]
async fn main() {
    // 创建数据库连接
    let (client, connection) = tokio_postgres::connect("host=localhost user=postgres", NoTls)
        .await
        .expect("Failed to connect to database");

    // 转换为Arc以进行共享
    let client = Arc::new(client);

    // 创建Axum应用程序
    let app = route("/", get(handler)).layer(AddExtensionLayer::new(client));

    // 启动服务器
    axum::Server::bind(&"127.0.0.1:3000".parse().unwrap())
        .serve(app.into_make_service())
        .await
        .unwrap();
}

async fn handler(
    client: extract::Extension>,
) -> Result {
    let client = client.0.clone();

    // 执行数据库查询
    let rows = client.query("SELECT * FROM users", &[]).await.unwrap();

    // 处理查询结果
    let mut result = String::new();
    for row in &rows {
        let id: i32 = row.get(0);
        let name: &str = row.get(1);
        result.push_str(&format!("id: {}, name: {}\n", id, name));
    }

    Ok(result)
}

在这个示例中,我们首先创建一个与PostgreSQL数据库的连接。然后,我们使用Arc将连接转换为一个可共享的引用。接下来,我们创建了一个Axum应用程序,并使用AddExtensionLayerArc添加到应用程序的状态中。最后,我们定义了一个处理程序函数,该函数从状态中提取连接,并执行数据库查询。

请确保根据实际的数据库连接字符串进行更改。此示例仅适用于本地PostgreSQL数据库。

相关内容

热门资讯

四分钟辅助!wepoker黑侠... 四分钟辅助!wepoker黑侠辅助器正版下载,创思维激k辅助工具(透视辅助开挂辅助插件);大家肯定在...
第十分钟辅助!顺欣茶楼辅助软件... 第十分钟辅助!顺欣茶楼辅助软件,上品游戏辅助软件(一分钟了解开挂辅助工具);1、超多福利:超高返利,...
1分钟辅助!潮汕汇鱼虾蟹辅助,... 1分钟辅助!潮汕汇鱼虾蟹辅助,潮友潮汕木虱辅助(透视教程开挂辅助下载);潮友潮汕木虱辅助免费下载原版...
第9分钟辅助!蘑菇云辅助怎么使... 第9分钟辅助!蘑菇云辅助怎么使用,微信呢小程序微乐房间怎么开挂(我来分享开挂辅助工具);大家肯定在之...
第七分钟辅助!wepoker辅... 【福星临门,好运相随】;第七分钟辅助!wepoker辅助器是真的吗,闲逸斗地主辅助(透视app开挂辅...
八分钟辅助!智星菠萝可以辅助吗... 【福星临门,好运相随】;八分钟辅助!智星菠萝可以辅助吗,新道游开挂辅助透视(重大通报开挂辅助神器);...
辅助开挂!四川游戏家园辅助软件... 辅助开挂!四川游戏家园辅助软件,hhpkoer辅助器(透视)开挂辅助软件(有人有挂);1、不需要AI...
辅助开挂!博雅红河西元红河破解... 辅助开挂!博雅红河西元红河破解版,德州透视是真的吗(透视)开挂辅助平台(新版有挂);博雅红河西元红河...
开挂辅助!好友赣南新版本可以作... 开挂辅助!好友赣南新版本可以作假吗,hhpoker免费透视脚本(透视)开挂辅助神器(讲解有挂);小薇...
开挂辅助!微乐小程序辅助,德州... 开挂辅助!微乐小程序辅助,德州局hhpoker(透视)开挂辅助工具(有挂辅助);1、让任何用户在无需...