rust sqlx 使用---增删改查

SQLx 是一个异步的、纯粹的 Rust SQL 板条箱，其特点是没有 DSL 的编译时检查查询。

• 真正的异步：从头开始使用异步/等待构建，以实现最大的并发性。
• 编译时检查查询：
• 支持： PostgreSql，Mysql，Sqlite，MSSSQL
• 纯rust编写
• 在不同的运行时:async-std、tokio、actix和TLS natice-tls、tustls
• 跨平台，SQLx 将在任何支持 Rust 的地方编译。
• 使用 sqlx: : Pool 的内置连接池。
• 行流: 从数据库异步读取数据并按需解码
• 自动语句准备和缓存。当使用高级查询 API (sqlx: : query)时，每个连接准备和缓存语句。
• 支持的传输层安全性(TLS)(MySQL 和 PostgreSQL)。
• 对 PostgreSQL 使用 LISTEN 和 NOTIFY 的异步通知。
• 支持保存点的嵌套事务
• 任何用于在运行时更改数据库驱动程序的数据库驱动程序。AnyPool 连接到 URI 方案指示的驱动程序。

数据库的格式(user表)

id    varchar 64
user_name varchar 30
create_time timestamp 
age int 2
height float4 24

编写查询的代码，因为我们的数据库字段中存在时间类型，所以需要先引入chrono的包，和sqlx的shrono的feature，完整的toml

[dependencies]
sqlx = { version = "0.5", features = [ "runtime-tokio-native-tls" , "postgres","all-types","macros" ] }
tokio = { version = "1", features = ["full"] }
#时间
chrono = {version = "0.4.19",features=["serde"]}
#序列化
serde = {version = "1.0.140",features=["derive"]}
serde_json = "1.0.82"

需要用到的引用

use sqlx::{postgres::PgConnection, Connection, Postgres};
use serde::{Deserialize,Serialize};

创建user结构体

#[derive(Deserialize,Serialize,Debug,sqlx::FromRow)]
struct User{
    id:String,
    nick_name:String,
    age:i16,
    create_time:chrono::NaiveDateTime,
    height:f32
}

创建单链接

async fn sql_connect() -> Option<PgConnection>{
    let connect = PgConnection::connect("postgres://postgres:joyspace2_pwd@localhost:5432/test").await;
    match connect {
        Ok(conn) => {
            Some(conn)
        },
        Err(err) => {
            println!("err message: {:?}",err);
            None
        }
    }
}

增加

async fn _insert_user(connect: &mut PgConnection,user: User){

    let sql = sqlx::query::<Postgres>("insert into sys_user (id,nick_name,age,create_time,height) values ( $1,$2,$3,$4,$5 )")
        .bind(user.id)
        .bind(user.nick_name)
        .bind(user.age)
        .bind(user.create_time)
        .bind(user.height)
        .execute(connect).await;
    match sql {
        Ok(result) => {
            println!("{:?}",result);
        },
        Err(err) => {
            println!("{:?}",err);
        }
    }
}

查询

async fn _select_user(connect: &mut PgConnection){
    let res = sqlx::query_as::<Postgres,User>("select id,nick_name,age,create_time,height from sys_user").fetch_all(connect).await;
    match res {
        Ok(result) => {
            println!("{:?}",result);
        },
        Err(err) => {
            println!("err = {:?}",err);
        }
    }
}

修改

async fn update_user(connect: &mut PgConnection,nick_name:String,id:String){
    let res = sqlx::query("update sys_user set nick_name = $1 where id = $2")
        .bind(nick_name)
        .bind(id)
        .execute(connect).await;

    match res {
        Ok(result) => {
            println!("{:?}",result);
        },
        Err(err) => {
            println!("{:?}",err);
        }
    }
}

删除

async fn _delete_user(connect: &mut PgConnection,id:String){
    let res = sqlx::query("delete from sys_user where id = $1").bind(id).execute(connect).await;
    match res {
        Ok(result) => {
            println!("{:?}",result);
        },
        Err(err) => {
            println!("err= {:?}",err);
        }
    }
}

main方法

#[tokio::main]
async fn main() {
    let user = User {
        id:"".to_string(),
        nick_name:"".to_string(),
        age:19,
        create_time:chrono::NaiveDate::from_ymd(2016, 7, 8).and_hms(9, 10, 11),
        height:175.1
    };
    let connect = sql_connect().await;
    if let Some(mut conn) = connect {
        //调用方法
        update_user(&mut conn, "新昵称".to_string(), "123".to_string()).await;
    }
    println!("Hello, world!");
}

本作品采用《CC 协议》，转载必须注明作者和本文链接