Rust – mysql 增删改查 - CSDN文库

148 浏览量更新于2023-05-04 1 收藏 50KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源推荐

Rust – mysql 增删改查增删改查

一、添加一、添加mysql依赖依赖

mysql_async 是基于tokio2.0的异步mysql

[dependencies] mysql_async = "0.22.2"

tokio = "0.2.13"

二、设置二、设置database_url，创建连接池，创建连接池

DSN：mysql://root:root@127.0.0.1:3306/testdb?pool_min=10&pool_max=100&conn_ttl=10

?后面的参数列表：

pool_min：连接池最小值，默认10

pool_max：连接池最大值，默认100

inactive_connection_ttl：默认0秒，如果空闲连接时长大于ttl，连接数也大于pool_min，就关闭

ttl_check_interval：默认30秒，ttl检测周期，每隔30秒检查一下空间连接的状态

conn_ttl：默认为wait_timeout，如果最后一次IO执行的时长大于ttl，则关闭该连接

tcp_keepalive：默认为None，tcp保持连接状态的时长，毫秒单位

tcp_nodelay：默认为true，是否启用TCP_NODELAY选项

stmt_cache_size：默认10条，缓存准备好的stmt语句

prefer_socket：是否查询@@socket变量

socket：默认为None，Unix套接字（或Windows上的命名管道）的路径

compression：默认None，压缩快慢，（fast = 1、on = true、best = 9，0~9）

创建连接池

let pool = mysql_async::Pool::new(database_url);

从连接池获取一个connect，当离开作用域，调用drop自动返还给pool

let conn = pool.get_conn().await?;

程序退出，需要手动关闭连接池

pool.disconnect().await?;

三、执行三、执行sql的几种函数调用的几种函数调用

1、ping，判断mysql服务器是否可用

let conn = conn.ping().await?;

2、query，普通的查询，需要自己判断sql参数是否正确

let result = conn.query("SELECT * FROM t_user").await?;

3、prep_exec，使用stmt语句查询

let result = conn.prep_exec("SELECT * FROM user where id = :id", params! {

"id" => 1

}).await?;

4、只查询一条结果集

let (conn, row): (_, Option) = conn.first_exec("SELECT * FROM user where id = :id", params! {

"id" => 1

}).await?;

5、执行sql，不关心result结果集

let conn = conn.drop_query(r"SET NAMES utf8").await?;

let conn = conn.drop_exec(r"SET NAMES utf8", ()).await?;

6、批量执行sql

// params是param!参数的集合

let conn = conn.batch_exec(r"INSERT INTO payment (customer_id, amount, account_name) VALUES (:customer_id, :amount, :account_name)",

params).await?;

7、事务处理

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

weixin_38677255

粉丝: 6
资源: 931

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈