首页 > 资讯 > 数据库 >Rust操作MySQL

576

分享到

Rust操作MySQL

后端 2023-10-12 10:10:32 576人浏览薄情痞子

摘要

查询本部分是对「Rust入门系列」Rust 中使用 Mysql[1]的学习与记录经常使用的时间处理库： chrono 流式查询使

查询

本部分是对「Rust入门系列」Rust 中使用 Mysql^[1]的学习与记录

经常使用的时间处理库： chrono
流式查询使用： query_iter
输出到Vec使用： query
映射到结构体使用： query_map

获取单条数据使用： query_first
命名参数查询使用： exec_first

CREATE TABLE `student` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(128) NOT NULL,
  `age` int(11) NOT NULL,
  `id_card` varchar(128) NOT NULL,
  `last_update` date NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- 插入测试数据
insert into student (name, age, id_card, last_update) values ('张三', 23, '123456789X', CURRENT_DATE());
insert into student (name, age, id_card, last_update) values ('李四', 24, '8382353902', CURRENT_DATE())

注意，mysql^[2]这个crate新版本demo有问题，文档的更新速度跟不上代码的修改脚步..

需要指定版本：

[dependencies]mysql = "20.0.0" #通配符*表示可以使用任何版本，通常会拉取最新版本；此处需要指定，不使用最新版本

流式查询

use chrono::prelude::*;// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接

    conn.query_iter("select * from student")
        .unwrap()
        .for_each(|row| {
            let r: (i32, String, i32, String, NaiveDate) = from_row(row.unwrap());
            println!("{}, {},{},{}, {:?}", r.0, r.1, r.2, r.3, r.4);
        });
}

row的类型是mysql_common::row::Row，其把数据以字节的形式存储。

所以需将低级的字节转换成想要的类型如i32,String，这里使用了from_row。注意，转换后的数据以元组的形式返回，其中每一项和选择列的顺序相同。

输出：

1, 张三,23,123456789X, 2022-04-26
2, 李四,24,8382353902, 2022-04-26

流式查询

其实还可以将查询结果收集到Vec中。 Vec中的每个元素都是一个元组。

query函数已经将字节转换为选择的数据类型，因此不需要再转换了。需要注意的是，这里必须明确元组的数据类型(如此处是 Vec<(i32, String, i32, String, NaiveDate)>)。否则，编译器没办法做转换。

use chrono::prelude::*;// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接

// 输出到Vec
    let res: Vec<(i32, String, i32, String, NaiveDate)> =
        conn.query("select * from student").unwrap();
    for r in res {
        println!("{}, {},{},{}, {:?}", r.0, r.1, r.2, r.3, r.4);
    }
}

映射结果到结构体

如果表的列数很多，使用元组容易混淆，更普遍的做法是定义一个结构体。

如下定义一个Student结构体, 然后可以用query_map将查询结果映射到Student中。

不需要指定数据类型，编译器会根据Student类型自动推导

use chrono::prelude::*;// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接

    // 将结果映射到提前定义好的结构体
    struct Student {
        id: u64,
        name: String,
        age: u16,
        id_card: String,
        last_changed_on: NaiveDate,
    }

    let res = conn.query_map(
        "select * from student",
        |(id, name, age, id_card, update)| Student {
            id: id,
            name: name,
            age: age,
            id_card: id_card,
            last_changed_on: update,
        },
    ).expect("Query failed.");

    for i in res {
        println!(
            "{}, {},{},{}, {:?}",
            i.id, i.name, i.age, i.id_card, i.last_changed_on
        )
    }
}

单条数据查询

查询特定数据行，可能会出现下面几种情况:

找到，返回实际数据
没有找到行
发生错误

所以，使用query_first函数返回的是Option的结果。需要将其解包两次才可以获取实际的行数据:

use chrono::prelude::*;// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接


    struct Student {
        id: u64,
        name: String,
        age: u16,
        id_card: String,
        last_changed_on: NaiveDate,
    }

    // 条件查询，查询单个数据
    let res = conn.query_first("select * from student where name = '张三'")
        .map(
            // Unpack Result
            |row| {
                row.map(|(id, name, age, id_card, update)| Student {
                    id: id,
                    name: name,
                    age: age,
                    id_card: id_card,
                    last_changed_on: update,
                })
            },
        );

    match res.unwrap() {
        Some(student) => println!(
            "{}, {},{},{}, {:?}",
            student.id, student.name, student.age, student.id_card, student.last_changed_on
        ),
        None => println!("Sorry no student found."),
    }
}

命名参数的使用

use chrono::prelude::*;// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接


    struct Student {
        id: u64,
        name: String,
        age: u16,
        id_card: String,
        last_changed_on: NaiveDate,
    }

    let res = conn
        .exec_first(
            "select * from student where name = :name",
            params! {
                "name" => "李四"
            },
        )
        .map(
            // Unpack Result
            |row| {
                row.map(|(id, name, age, id_card, update)| Student {
                    id: id,
                    name: name,
                    age: age,
                    id_card: id_card,
                    last_changed_on: update,
                })
            },
        );

    match res.unwrap() {
        Some(student) => println!(
            "{}, {},{},{}, {:?}",
            student.id, student.name, student.age, student.id_card, student.last_changed_on
        ),
        None => println!("Sorry no student found."),
    }

}

写操作

本部分是对 Rust使用MySQL数据库02^[3]的学习与记录

插入数据使用 conn.exec_drop()
使用预编译语句插入大量数据， conn.prep()
使用 conn.last_insert_id()可以获取主键

更新和删除也使用 conn.prep和 conn.exec_drop

插入新数据

use chrono::prelude::*;
// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接


    conn.exec_drop(
        "INSERT INTO student (name, age, id_card, last_update) VALUES (:name, :age, :id_card, :last_update)",
        params! {
        "name" => "王五",
        "age" => 28,
        "id_card" => "66666688",
        "last_update" => today(),
}).unwrap();
}

fn today() -> NaiveDate {
    let l = Local::today();

    NaiveDate::from_ymd(l.year(), l.month(), l.day())
}

和上面一节一样，命名参数在这里使用了params宏的语法

exec_drop方法中的drop表示没有返回结果

用于执行插入/更新/删除的sql

使用预编译语句

使用conn.prep将sql编译成预编译语句。

use chrono::prelude::*;
// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接


    let stmt = conn.prep("INSERT INTO student (name, age, id_card, last_update) VALUES (:name, :age, :id_card, :last_update)")
        .unwrap();

    for i in 1..10 {
        conn.exec_drop(&stmt, params! {
         "name" => "dashen",
         "age" => 18 + i,
         "id_card" => "1234565X",
         "last_update" => NaiveDate::from_ymd(2017, 05, 04),
     }).unwrap()
    }
}

获取生成的主键id

可以通过conn.last_insert_id()方法获取到新记录的主键id，该方法将返回的一个类型为u64 的值

use chrono::prelude::*;
// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接

    conn.exec_drop("INSERT INTO student (name, age, id_card, last_update) VALUES (:name, :age, :id_card, :last_update)", params! {
    "name" => "fliter",
    "age" => 29,
    "id_card" => "88888888",
    "last_update" => NaiveDate::from_ymd(2022, 05, 04),
}).unwrap();

    println!("新插入的记录的主键为: {}", conn.last_insert_id())
}

新插入的记录的主键为: 13

更新和删除

类似于插入操作

use chrono::prelude::*;
// 用来处理日期
use mysql::*;
use mysql::prelude::*;

fn main() {
    let url = "mysql://root:12345678@localhost:3306/shuang";
    let pool = Pool::new(url).unwrap(); // 获取连接池


    let mut conn = pool.get_conn().unwrap();// 获取链接


    let stmt = conn.prep("update student set name=:name, last_update=:last_update where id=:id")
        .unwrap();

    conn.exec_drop(&stmt, params! {
     "name" => "新名字",
     "last_update" => NaiveDate::from_ymd(2038, 12, 31),
     "id" => 10,
}).unwrap();


    let stmt = conn.prep("delete from student where id=:id").unwrap();

    conn.exec_drop(&stmt, params! {
    "id" => 12,
}).unwrap();
}

参考资料

[1]

「Rust入门系列」Rust 中使用 MySQL: https://rustmagazine.GitHub.io/rust_magazine_2021/chapter_3/rust-mysql.html

[2]

mysql: Https://crates.io/crates/mysql

[3]

Rust使用MySQL数据库02: https://www.modb.pro/db/179746

本文由 mdnice 多平台发布

来源地址：https://blog.csdn.net/techdashen/article/details/131735261

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: Rust操作MySQL

本文链接: https://www.lsjlt.com/news/429291.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

Rust操作MySQL

查询本部分是对「Rust入门系列」Rust 中使用 MySQL[1]的学习与记录经常使用的时间处理库： chrono 流式查询使...

99+

2023-10-12

后端
Rust 中的文件操作示例详解

目录文件路径文件创建和删除目录创建和删除文件创建和删除文件读取和写入文件打开文件读取文件写入相关资料文件路径想要打开或者创建一个文件，首先要指定文件的路径。 Rust 中的路径操作...

99+

2024-04-02
python操作mysql

# rpm -qa |grep MySQL-python 查询是否有mysqldb库MySQL-python-1.2.3-0.3.c1.1.el6.x86_64>>> import MySQLdb #导入mysqldb模块...

99+

2023-01-31

操作 python mysql
shell操作mysql

参考文章：shell脚本操作MYSQL（1） shell操作mysql主要有两种方式：直接链接数据库并且执行sql。不执行sql，而是连接数据库,使用...

99+

2023-09-06

mysql 数据库 sql
PHP操作MySQL

PHP对数据库进行操作前言时间不足，只为二级准备的粗略笔记很多事情没有答案一、使用PHP进行MySQL编程 1、php操作MySQL的介绍：可以使用拍php内置的mys...

99+

2023-10-03

数据库服务器 mysql
Rust应用调用C语言动态库的操作方法

目录外部功能接口FFIUDP套接字的读超时Rust调用C语言动态库中的函数避免重复造轮子，使用Rust官方C语言库外部功能接口FFI 虽然高级（脚本）编程语言的功能丰富，表达能力强，...

99+

2023-01-29

Rust调用C语言动态库 Rust C语言动态库
MySQL 基本操作

目录数据库的列类型数据库基本操作 SQL语言规范 SQL语句分类查看表，使用表管理数据库创建数据库和表删除数据库和表向数据表中添加数据查询数据表中数据修改数据表的数据删除数据表中数据修改表明和表结构扩展表结构（增加...

99+

2023-09-03

mysql 数据库
MySQL怎么操作

小编给大家分享一下MySQL怎么操作，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！创建数据库luowei mysql>...

99+

2024-04-02
Python操作MySQL(2)

查询数据使用execute()函数执行查询sql语句后，得到的只是受影响的行数，并不能真正拿到我们查询的内容。没关系，这里游标cursor中还提供了三种提取数据的方法：fetchone、fetchmany、fetchall，每个方法都会...

99+

2023-01-31

操作 Python MySQL
Mysql多表操作

文章目录 1. 概述2. 内连接3. 外连接4. 自连接5. 联合查询-union,union all6. 子查询 1. 概述在项目开发中，在进行数据库表结构设计是，...

99+

2023-09-05

mysql
mysql如何操作

这篇文章将为大家详细讲解有关mysql如何操作，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。管理创建表create &nb...

99+

2024-04-02
Python 操作Mysql(PyMysql)

Python 操作 Mysql 常用方式： PyMysql：纯 Python 语言编写的 Mysql 操作客户端，安装方便，支持 Python3。SQLAlchemy：是一个非常强大的 ORM 框架，...

99+

2023-09-09

Python 操作Mysql Python使用PyMysql
MySQL表的操作

MySQL表的操作创建表查看表结构的详细信息修改表结构增加表结构属性删除表结构表结构的修改删除表结构创建表语法: create table table_name( fiel...

99+

2023-09-01

mysql android 数据库
mysql-表的操作

mysql支持的存储引擎数据库中的表也应该有不同的类型，表的类型不同，会对应mysql不同的存取机制，表类型又称为存储引擎1、InnoDB 存储引擎支持事务,其设计目标主要面向联机事务处理(OLTP)的应用。其特点是行锁设计、支持外键,并支...

99+

2023-01-30

操作 mysql
mysql分页操作

在MySQL中，可以使用LIMIT子句来实现分页操作，LIMIT子句接受两个参数，第一个参数是偏移量，即要跳过的记录数，第二个参数是要返回的记录数量，基本语法为“SELECT * FROM 表名 LIMIT 偏移量, 记录...

99+

2024-01-17

mysql分页 mysql
MySQL的JSON操作

官网地址 1. MySQL json介绍 As of MySQL 5.7.8, MySQL supports a native JSON data type defined by RFC 7159 ...

99+

2023-09-04

mysql json
[MySQL] MySQL基础操作汇总

文章目录前言1.数据库概述1.1 数据库相关概念1.2登录MySQL：1.3 MySQL常用命令1.4表：1.5SQL语句分类： 2.CRUD操作2.1 DQL1.基础查询基础查询（简单...

99+

2023-09-23

mysql 数据库
【MySQL】MySQL审计操作记录

server_audit是一款内嵌在mariadb的审计插件，在mysql中同样适用，主要用于记录用户操作 1.安装：通过show variables like 'plugin_dir';查看你的插件目录...

99+

2024-04-02
『 MySQL篇』：MySQL表的CURD操作

📢 MySQL 系列专栏持续更新中 … MySQL专栏目录目录一、SQL语句- SQL通用语法- 注释- SQL语句分类二、基础表操作- 创建表- 查看库中的表- 查看表结构- 删除表- 重...

99+

2023-08-17

mysql 数据库 sql
mysql加快alter操作

场景: mysql的alter table 操作的性能对大表来说是个大问题.mysql执行大部分修改表结构的操作方法是用新的结构创建一个空表,从旧表中查出所...

99+

2024-04-02