C语言连接数据库

接下来我简单的介绍一下怎么用C语言连接数据库。

1. 初始化数据库
2. 创建数据库连接
3. 执行增删改查语句
4. 关闭数据库连接

一、初始化数据库

1. // 数据库初始化
2. MYSQL mysql;
3. MYSQL* ret1 = mysql_init(&mysql);
4. if (ret1 == nullptr)
5. {
6. std::cerr << "init_error" << std::endl;
7. exit(-1);
8. }
10. /*****************
11. 返回值：
12. 如果没有足够的内存来分配新对象，则为空。
13. *****************/

复制代码

二、创建数据库连接

1. // 数据库连接
2. MYSQL* ret2 = mysql_real_connect(&mysql, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0);
3. if (ret2 == nullptr)
4. {
5. std::cerr << "connect_error" << std::endl;
6. exit(-1);
7. }
9. /*****************
10. 参数：
11. 1、MYSQL *mysql ===> 创建的数据库变量
12. 2、const char *host ===> 主机号, 如果是本地可以用"127.0.0.1"
13. 3、const char *user ===> 用户名
14. 4、const char *passwd ===> 密码
15. 5、const char *db ===> 数据库名
16. 6、unsigned int port ===> 端口号
17. 7、剩下的两个参数一个置空，一个置0就行
18. 返回值：
19. 如果没有足够的内存来分配新对象，则为空。
20. *****************/

复制代码

三、执行增删改查语句

这个部分需要分成两类：增删改、查。增删改只需要考虑这个语句执行的是否是正常的，但是查询这个操作还需要通过返回值得到查询的结果。

1、增删改

1. // 执行增删改
2. std::string sql = "insert into user (name, age) values ('wangwu', 19);";
3. int ret3 = mysql_query(&mysql, sql.c_str());
4. if (ret3)
5. {
6. std::cerr << "query_error" << std::endl;
7. exit(-1);
8. }

复制代码

2、查

1. 执行查询语句
2. 得到结果集
3. 得到结果集的行数和列数
4. 遍历即可

1. // 执行查找语句
2. std::string sql = "select * from user;";
3. int ret4 = mysql_query(&mysql, sql.c_str());
4. if (ret4)
5. {
6. std::cerr << "query_error" << std::endl;
7. exit(-1);
8. }
9. // 得到结果集
10. MYSQL_RES* res = mysql_store_result(&mysql);
12. // 得到行数和列数
13. int row = mysql_num_rows(res);
14. int field = mysql_num_fields(res);
16. // 得到列名
17. MYSQL_FIELD* fields = mysql_fetch_fields(res);
18. for (int i = 0; i < row; i++)
19. {
20. // 注意，不能直接打印，需要指定里面的name属性
21. std::cout << fields[i].name << " ";
22. }
23. std::cout << "\n";
25. // 遍历得到结果集
26. MYSQL_ROW line;
27. for (int i = 0; i < row; i++)
28. {
29. line = mysql_fetch_row(res);
30. for (int j = 0; j < field; j++)
31. {
32. std::cout << line[j] << " ";
33. }
34. std::cout << "\n";
35. }

复制代码

四、执行增删改查语句

1. // 关闭数据库
2. mysql_close(&mysql);

复制代码

cout << “\n”;
}

2. # 四、执行增删改查语句
4. [外链图片转存中...(img-9HkkinoN-1733452583128)]
6. ```cpp
7. // 关闭数据库
8. mysql_close(&mysql);

复制代码