【MySQL】11.使用 C 语言访问 MySQL
一.检查第三方库是否配置成功
想要使用代码连接数据库，必须使用 MySQL 官方提供的第三方库。早在我们第一节使用 yum 安装 MySQL 的时候，
就安装了三个东西：MySQL 客户端，MySQL 服务端，MySQL 开发包(库)。所以我们只需检查一下环境是否就绪。
//1.检查是否有MySQL库
[liuyi@centos-7 usr]$ ls /usr/lib64/mysql/
libmysqlclient.a libmysqlclient_r.so.18.1.0 libmysqlclient.so.18 libmysqlclient.so.20 libmysqlservices.a plugin
libmysqlclient_r.so.18 libmysqlclient.so libmysqlclient.so.18.1.0 libmysqlclient.so.20.3.31 mecab
//2.检查是否有MySQL头文件
[liuyi@centos-7 usr]$ ls /usr/include/mysql/
big_endian.h keycache.h my_command.h my_getopt.h mysqld_ername.h mysqlx_ername.h my_xml.h plugin_validate_password.h thr_cond.h
binary_log_types.h little_endian.h my_compiler.h my_global.h mysqld_error.h mysqlx_error.h plugin_audit.h sql_common.h thr_mutex.h
byte_order_generic.h m_ctype.h my_config.h my_list.h mysql_embed.h mysqlx_version.h plugin_ftparser.h sql_state.h thr_rwlock.h
byte_order_generic_x86.h m_string.h my_config_x86_64.h mysql mysql.h my_sys.h plugin_group_replication.h sslopt-case.h typelib.h
decimal.h my_alloc.h my_dbug.h mysql_com.h mysql_time.h my_thread.h plugin.h sslopt-longopts.h
errmsg.h my_byteorder.h my_dir.h mysql_com_server.h mysql_version.h my_thread_local.h plugin_keyring.h sslopt-vars.h
如果以上东西没有，则执行以下命令安装开发包：
sudo yum install -y mysql-devel
#include <mysql/mysql.h>
#include <iostream>
using namespace std;
int main()
{
cout << "mysql client version: " << mysql_get_client_info() << endl;
return 0;
}
//编译命令如下：
//g++ -o test test.cc -std=c++11 -L /usr/lib64/mysql -l mysqlclient
//如果编译成功，则说明环境没有问题
[liuyi@centos-7 test_db]$ ./test
mysql client version: 5.7.44
二.MySQL 常用接口
1.创建，销毁操作句柄
MYSQL* mysql_init(MYSQL* mysql);
功能：创建一个mysql对象，这就是我们操作的句柄
返回值：如果返回NULL则创建失败，否则返回一个创建出的对象
void mysql_close(MYSQL* mysql);
功能：销毁mysql对象
2.使用句柄连接数据库
MYSQL* mysql_real_connect(MYSQL *mysql, //句柄
const char *host, //mysqld所在主机
const char *user, //mysql用户名
const char *passwd, //登录密码
const char *db, //数据库名
unsigned int port, //mysqld所在端口
const char *unix_socket, //一般设为nullptr
unsigned long client_flag) //一般设为0
功能：连接数据库
返回值：连接失败返回nullptr,连接成功返回句柄本身
3.向 mysqld 发送指令
int mysql_query(MYSQL *mysql,
const char *stmt_str)
功能：向mysqld发送指令执行
返回值：0表示语句执行成功，非0表示执行失败
int mysql_set_character_set(MYSQL *mysql,
const char *csname)
功能：设置当前连接的字符串编码格式，必须让它和mysqld的编码格式保持一致，否则中文会乱码
返回值：为0则设置成功
4.查询相关函数
select查询到的数据会保存在MYSQL对象中
MYSQL_RES* mysql_store_result(MYSQL *mysql);
功能：将保存在MySQL对象中的数据进行整合，把查询结果保存到MYSQL_RES对象中
返回值：为nullptr表示失败
说明：
MYSQL_RES也是第三方库定义的一个结构体类型，其内部维护了一个char**的数组，
以后处理select结果会频繁用到该对象；
mysql_store_result内部肯定会malloc一段空间用于保存结果，最后一定要调用相应函数释放以免内存泄露
unsigned int mysql_num_rows(MYSQL_RES *res);
功能：返回表的行数(不包含字段行)
unsigned int mysql_num_fields(MYSQL_RES *res);
功能：返回表的列数(不包含字段行)
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
功能：获取一行的结果，每次调用后会自动迭代
返回值：为nullptr表示获取失败
说明：MYSQL_ROW是对char**的typedef
MYSQL_FIELD *mysql_fetch_fields(MYSQL_RES *res);
功能：返回该表的所有字段的详细信息
返回值：为nullptr表示获取失败
说明：MYSQL_FIELD是一个结构体类型，包含一个字段的详细信息，如字段名，属性，所属表的名称等
void mysql_free_result(MYSQL_RES* res)
功能：释放mysql_store_result中申请的空间，释放后就不要试图访问res了
三.使用示例
#include <mysql/mysql.h>
#include <iostream>
#include <cassert>
const char *host = "127.0.0.1"; //写localhost也行
const char *user = "ly";
const char *password = "**********"; //密码不方便透露
const char *db = "test_db";
unsigned int port = 3306;
using namespace std;
int main()
{
//1.创建句柄
MYSQL *mysql = mysql_init(nullptr);
if (mysql == nullptr)
{
cout << "创建MySQL对象失败" << endl;
return 1;
}
//2.连接数据库并修改本次连接中客户端的编码方式
assert(mysql_real_connect(mysql, host, user, password, db, port, nullptr, 0) != nullptr);
mysql_set_character_set(mysql, "utf8");
//3.执行建表，插入，查询语句
assert(mysql_query(mysql, "create table test_tb(id int, name varchar(20))") == 0);
assert(mysql_query(mysql, "insert into test_tb values(1, '张三')") == 0);
assert(mysql_query(mysql, "insert into test_tb values(2, '李四')") == 0);
assert(mysql_query(mysql, "select * from test_tb") == 0);
//4.将查询结果保存到res中
MYSQL_RES *res = mysql_store_result(mysql);
//5.处理查询结果
int rows = mysql_num_rows(res);
int cols = mysql_num_fields(res);
MYSQL_FIELD *fields_array = mysql_fetch_fields(res);
for (int i = 0; i < cols; i++)
{
cout << fields_array[i].name << "\t";
}
cout << endl;
for (int i = 0; i < rows; i++)
{
char **line = mysql_fetch_row(res);
for (int j = 0; j < cols; j++)
{
cout << line[j] << "\t";
}
cout << endl;
}
//6.释放查询结果
mysql_free_result(res);
//7.销毁句柄
mysql_close(mysql);
return 0;
}
//编译运行结果：
[liuyi@centos-7 test_db]$ ./test
id name
1 张三
2 李四
原文地址：https://blog.csdn.net/weixin_74113106/article/details/140493541
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！