Linux下MySQL的简单使用

导语
MySQL安装与配置
- MySQL安装
- 密码设置
MySQL管理
- 命令
- - myisamchk
  - mysql
  - 其他
- 常见操作
C语言访问MYSQL
- 连接例程
- 错误处理
- 使用SQL
总结
参考文献

导语

这一章是MySQL的使用，一些常用的MySQL语句属于本科阶段内容，然后是C语言和MySQl之间的交互，可以看到C语言已经有成熟的和MySQL的接口

MySQL安装与配置

MySQL安装

MySQL的安装很简单，只需要执行几个shell命令就行，需要注意的是，对于Ubuntu新机器来说最好不要一开始就执行sudo apt update，因为很多包之间的依赖是复杂且未知的，如果直接全部更新可能会导致在跟书上同步实验时出问题（命令参考了ubuntu 23.10.1 mysql 安装）

sudo apt install mysql-server -y#这里就安装好了服务器
systemctl start mysql#开启mysql服务
systemctl status mysql#检查状态，如果出现mysql>就没问题sudo mysul -u root mysql#进入mysql
ps -el | grep mysqld#可以看mysql是否启动

下面这个是备选方案，是在新机器上装的

sudo apt-get update
sudo apt-get install libmysqlclient-dev
mysql_config --cflags
mysql_config --libs

后两条命令是检测MySQL Connector/C是否安装完成，由于新版本的MySQL已经不支持书上的写法，所以需要安装这个包，正常应该显示如下图

在这里插入图片描述

之后直接安装服务器即可

sudo apt-get update
sudo apt-get install mysql-server

通过下面的程序验证安装是否成功

#include <stdio.h>
#include <mysql/mysql.h>int main() {MYSQL *conn;conn = mysql_init(NULL);if (conn == NULL) {fprintf(stderr, "mysql_init() failed\n");return EXIT_FAILURE;}if (mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0) == NULL) {fprintf(stderr, "mysql_real_connect() failed: %s\n", mysql_error(conn));mysql_close(conn);return EXIT_FAILURE;}printf("Connected to the database successfully!\n");mysql_close(conn);return EXIT_SUCCESS;
}

执行的命令和结果如下

gcc -o test_program test_program.c $(mysql_config --cflags) $(mysql_config --libs)

在这里插入图片描述

密码设置

一开始的root是没有密码的，可以通过命令查看各用户的密码如下，可以看到root密码为空

在这里插入图片描述

这里需要注意的是新版的MySQL和老版的不一样，新版本的password列改成了authentication_string

可以执行命令来设置密码，修改后查看，可以看到root有密码，但是被MySQL加密过了，再次登录时直接回车发现无法识别，只有输入密码才能识别用户

在这里插入图片描述

这里我们删除除去root之外的默认用户，并且删除从localhost以外任何主机的登录

在这里插入图片描述

到此为止，我们有了一个运行的MySQL，该MySQL只有设定密码的root通过本地才能连接，为了方便后续的操作，这里创建一个普通用户rick，它将能用三种方法来连接MySQL（本地连接，从IP连接，从wiley.com域中任何机器连接）

首先为rick创建一个本地登录，这里书上给的代码太老了，已经不适配现在的MySQL，更改成了现在版本的，最新的 MySQL 版本中，GRANT 语句不再用于设置用户密码。密码应该通过单独的 CREATE USER 或 SET PASSWORD 语句来设置。

在这里插入图片描述

通过三种不同的方式设置了三个用户，可以通过select命令展示，可以看到三种方式都成功了，并且rick的权利很大

在这里插入图片描述

MySQL管理

命令

所有命令都接受三个标准参数

-u 用于指定用户（用户名）
-p 用于提示密码（如果在命令行中未直接提供）
-h 用于指定主机（MySQL 服务器地址）

除了标准参数之外，每个命令还有自己的命令选项

myisamchk

通常情况下，myisamchk以创建的mysql用户运行并且工作目录为数据表在的目录中，常见的命令选项有

-c 检查表以发现错误
-e 执行扩展检查
-r 修复发现的错误

mysql

使用mysql可以不经过MySQL的控制台完成很多功能，通过在命令行最后添加数据库名称作为参数即可，可以通过 mysql --help | less来查看所有的命令行选项列表

其他

还有一些其他的命令，如mysqladmin、mysqlbug等，由于MySQL已经相对于书上更新很多了，所以很多命令已经过时，在此不多赘述

常见操作

书上提供的常见操作包括grant、revoke以及数据类型等，这些属于本科阶段SQL的基本内容，在此不再赘述，跳过

C语言访问MYSQL

连接例程

C语言连接MySQL需要先初始化一个连接句柄结构，然后再进行实际的连接，句柄通过mysql_init函数初始化，函数原型具体如下，mysql_init() 函数通常是在使用 MySQL 客户端 API 进行数据库编程时的第一个步骤。它为连接操作做了准备，确保在进行连接操作之前，连接对象处于一个已初始化的状态

MYSQL *mysql_init(MYSQL *);
//mysql：一个指向 MYSQL 结构体的指针。如果该指针为空，
//mysql_init() 将分配一个新的 MYSQL 结构体并返回它。如果提供了一个非空指针，它会用新的数据初始化该对象

真正与数据库进行连接的是mysql_real_connect函数，函数原型如下

MYSQL *mysql_real_connect(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *dbname, unsigned int port, const char *unix_socket, unsigned long client_flag);
//mysql是初始化之后的句柄

还有例程函数和关闭函数，在此不赘述

现在尝试创立一个数据库，向其中填入数据并通过C语言访问它

在这里插入图片描述

逐行输入对数据库的操作比较麻烦，并且容易出错，可以把要执行的命令单独做成文件，然后直接导入执行

-- Create the table childrenCREATE TABLE children (childno int(11) NOT NULL auto_increment,fname varchar(30),age int(11),PRIMARY KEY (childno)
);-- Populate the table 'children'INSERT INTO children (childno, fname, age) VALUES (1, 'Jenny', 21);
INSERT INTO children (childno, fname, age) VALUES (2, 'Andrew', 17);
INSERT INTO children (childno, fname, age) VALUES (3, 'Gavin', 8);
INSERT INTO children (childno, fname, age) VALUES (4, 'Duncan', 6);
INSERT INTO children (childno, fname, age) VALUES (5, 'Emma', 4);
INSERT INTO children (childno, fname, age) VALUES (6, 'Alex', 15);
INSERT INTO children (childno, fname, age) VALUES (7, 'Adrian', 9);

在这里插入图片描述

可以看到数据都被成功插入了

之后可以通过上述函数来连接数据库，由于系统和包之间的依赖问题以及mysql的版本问题，导致这个程序无法在旧机上运行，暂时没有找到解决方案，在新机上可以运行，运行结果和程序如下

#include <stdlib.h>
#include <stdio.h>
#include <mysql/mysql.h>  // 包含新版 MySQL Connector/C 的头文件int main(int argc, char *argv[])
{MYSQL *con;// 初始化 MySQL 连接句柄con = mysql_init(NULL);if (con == NULL) {fprintf(stderr, "mysql_init() failed\n");return EXIT_FAILURE;}// 连接数据库if (mysql_real_connect(con, "localhost", "rick", "111111", "foo", 0, NULL, 0) == NULL) {fprintf(stderr, "mysql_real_connect() failed\n");fprintf(stderr, "Error: %s\n", mysql_error(con));mysql_close(con);return EXIT_FAILURE;}// 输出连接成功状态printf("Connected successfully!\n");// 关闭连接mysql_close(con);return EXIT_SUCCESS;
}

在这里插入图片描述

执行的时候需要添加对应的inlcude路径和库文件路径

错误处理

MySQL使用一系列由连接句柄结构报告的返回码来获取错误信息，具体的函数原型如下

unsigned int mysql_errno(MYSQL *connection);
//返回错误码
char *mysql_error(MYSQL *connection);
//返回有意义的文本信息

这里是书上给出的一个例子以及运行结果，可以看到屏幕上输出了错误信息

#include <stdio.h>
#include <stdlib.h>
#include <mysql.h>int main(int argc, char *argv[]) {MYSQL my_connection;mysql_init(&my_connection);if (mysql_real_connect(&my_connection, "localhost", "rick", "I do not know", "foo", 0, NULL, 0)) {printf("Connection success\n");mysql_close(&my_connection);} else {fprintf(stderr, "Connection failed\n");if (mysql_errno(&my_connection)) {fprintf(stderr, "Connection error %d: %s\n",mysql_errno(&my_connection), mysql_error(&my_connection));}}return EXIT_SUCCESS;
}

在这里插入图片描述

使用SQL

这里直接给出一些C语言执行SQL语句的函数原型和简单解释

int mysql_query(MYSQL *connection, const char *query);
//第一个是初始化后的句柄，第二个是sql语句，返回错误码
my_ulonglong mysql_affected_rows(MYSQL *connection);
//查询上一条指令运行后影响了多少行

书上给出了一个使用AUTO_INCREMENT的代码实例，下面是修改后的程序和运行结果，AUTO_INCREMENT对每次插入的数据分配一个新的id值并进行追踪

#include <stdio.h>
#include <stdlib.h>
#include <mysql.h>#define DB_HOST "localhost"
#define DB_USER "rick"  // 用户名 'rick'
#define DB_PASS "111111" // 数据库密码
#define DB_NAME "foo" // 数据库名称 'foo'// 错误处理函数，减少冗余代码
void handle_error(MYSQL *connection, const char *message) {fprintf(stderr, "%s\nError %d: %s\n", message, mysql_errno(connection), mysql_error(connection));mysql_close(connection);exit(EXIT_FAILURE);
}int main(int argc, char *argv[]) {MYSQL my_connection;MYSQL_RES *res_ptr;MYSQL_ROW sqlrow;int res;// 初始化 MySQL 连接对象mysql_init(&my_connection);// 连接数据库if (!mysql_real_connect(&my_connection, DB_HOST, DB_USER, DB_PASS, DB_NAME, 0, NULL, 0)) {handle_error(&my_connection, "Connection failed");}printf("Connection success\n");// 插入数据到表中res = mysql_query(&my_connection, "INSERT INTO children(fname, age) VALUES('Robert', 7)");if (res) {handle_error(&my_connection, "Insert error");} else {printf("Inserted %lu rows\n", (unsigned long)mysql_affected_rows(&my_connection));}// 查询最后插入的数据res = mysql_query(&my_connection, "SELECT LAST_INSERT_ID()");if (res) {handle_error(&my_connection, "SELECT error");}// 获取查询结果res_ptr = mysql_use_result(&my_connection);if (res_ptr) {// 迭代结果集并输出while ((sqlrow = mysql_fetch_row(res_ptr))) {printf("We inserted childno %s\n", sqlrow[0]);}// 释放结果集mysql_free_result(res_ptr);} else {fprintf(stderr, "Failed to retrieve result set.\n");}// 关闭连接mysql_close(&my_connection);return EXIT_SUCCESS;
}

可以看到成功插入了一行，并且通过LAST_INSERT_ID拿到了ID

在这里插入图片描述

这里附上书上数据对应的插入代码

-- Create the table childrenCREATE TABLE children (childno INT(11) AUTO_INCREMENT NOT NULL PRIMARY KEY,fname VARCHAR(30),age INT
);-- Populate the table 'children'INSERT INTO children (fname, age) VALUES ('Jenny', 21);
INSERT INTO children (fname, age) VALUES ('Andrew', 17);
INSERT INTO children (fname, age) VALUES ('Gavin', 8);
INSERT INTO children (fname, age) VALUES ('Duncan', 6);
INSERT INTO children (fname, age) VALUES ('Emma', 4);
INSERT INTO children (fname, age) VALUES ('Alex', 15);
INSERT INTO children (fname, age) VALUES ('Adrian', 9);
INSERT INTO children (fname, age) VALUES ('Ann', 3);
INSERT INTO children (fname, age) VALUES ('Ann', 4);
INSERT INTO children (fname, age) VALUES ('Ann', 3);
INSERT INTO children (fname, age) VALUES ('Ann', 4);

除了上述两个基本的函数之外还有一些其他的函数，函数原型如下

MYSQL_RES *mysql_store_result(MYSQL *connection);
//从返回数据的语句中提取所有的数据，返回一个指向结果集的指针
my_ulonglong mysql_num_rows(MYSQL_RES *result);
//统计返回结果中的行数
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
//从结果集中提取一行，把这一行放在行机构里，每次使用一个
void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);
//在结果集中跳转，第二个参数是行号，设置下一个被fetch操作返回的行
MYSQL_ROW_OFFSET mysql_row_tell(MYSQL_RES *result);
//返回一个偏移值，表示结果集中的当前位置（不是行号）
void mysql_free_result(MYSQL_RES *result);
//对结果集的操作完成后，需要调用这个函数清理已经分配的对象
MYSQL_RES *mysql_use_result(MYSQL *connection);
//提取一行数据，返回指向对象的指针，不会缓存
//适合处理大数据量的查询结果，因为它允许逐行读取而不会将所有行一次性加载到内存中，这样可以有效减少内存的使用
unsigned int mysql_field_count(MYSQL *connection);
//获取最近一次查询的结果集中字段（列）的数量
MYSQL_FIELD *mysql_fetch_field(MYSQL_RES *result);
//用于从查询结果的字段列表中获取每个字段的描述信息，类似于字段的元数据。
//返回一个指向 MYSQL_FIELD 结构体的指针，这个结构体包含了字段的详细信息（例如字段名、类型等）。

下面是书上给出的一个综合程序（用chatgpt优化了），基本上用到了上面的所有函数，还有运行结果和具体的程序解释

#include <stdlib.h>
#include <stdio.h>
#include <mysql.h>// MySQL 连接对象和结果集
MYSQL my_connection;
MYSQL_RES *res_ptr;
MYSQL_ROW sqlrow;// 函数声明
void display_header();
void display_row();int main(int argc, char *argv[]) {int res;int first_row = 1;  // 用于确保我们只显示一次表头// 初始化 MySQL 连接对象mysql_init(&my_connection);// 尝试连接到数据库if (mysql_real_connect(&my_connection, "localhost", "rick", "111111", "foo", 0, NULL, 0)) {printf("Connection success\n");// 执行 SQL 查询，选择年龄大于 5 的记录res = mysql_query(&my_connection, "SELECT childno, fname, age FROM children WHERE age > 5");if (res) {// 查询执行失败，打印错误信息fprintf(stderr, "SELECT error: %s\n", mysql_error(&my_connection));} else {// 使用 mysql_store_result() 获取结果集到内存res_ptr = mysql_store_result(&my_connection);if (res_ptr) {// 获取每行的数据并显示while ((sqlrow = mysql_fetch_row(res_ptr))) {if (first_row) {// 首次显示表头display_header();first_row = 0;}// 显示每行数据display_row();}// 释放结果集资源mysql_free_result(res_ptr);} else {// 获取结果集失败，打印错误信息fprintf(stderr, "Failed to retrieve result set: %s\n", mysql_error(&my_connection));}}// 关闭数据库连接mysql_close(&my_connection);} else {// 连接失败，打印错误信息fprintf(stderr, "Connection failed\n");if (mysql_errno(&my_connection)) {fprintf(stderr, "Connection error %d: %s\n",mysql_errno(&my_connection), mysql_error(&my_connection));}}return EXIT_SUCCESS;
}// 显示表头，列出字段名称及其相关属性
void display_header() {MYSQL_FIELD *field_ptr;//获得列名printf("Column details:\n");while ((field_ptr = mysql_fetch_field(res_ptr)) != NULL) {// 显示字段的名称printf("\t Name: %s\n", field_ptr->name);printf("\t Type: ");// 判断字段类型并显示if (IS_NUM(field_ptr->type)) {//数字printf("Numeric field\n");} else {switch (field_ptr->type) {//字符串case FIELD_TYPE_VAR_STRING:printf("VARCHAR\n");break;case FIELD_TYPE_LONG:printf("LONG\n");break;default:printf("Type is %d, check in mysql_com.h\n", field_ptr->type);}}// 显示字段的最大长度printf("\t Max width %ld\n", field_ptr->length);// 检查字段是否具有 AUTO_INCREMENT 属性if (field_ptr->flags & AUTO_INCREMENT_FLAG) {printf("\t Auto increments\n");}printf("\n");}
}// 显示查询结果的每一行
void display_row() {unsigned int field_count;// 遍历每一列，打印其值field_count = 0;while (field_count < mysql_num_fields(res_ptr)) {//如果域名数量比当前索引大if (sqlrow[field_count]) {//sqlrow存了这一行的数据printf("%s ", sqlrow[field_count]);} else {printf("NULL ");}field_count++;}printf("\n");
}