MySQL学习（二）—— 常用API

创始人

2025-05-28 17:41:08

一、错误信息

（1）mysql_errno

（2）mysql_error

二、数据库的初始化

（3）mysql_init( )

函数原型：MYSQL *mysql_init(MYSQL *mysql)
描述：分配或初始化与mysql_real_connect()相适应的MYSQL对象。如果mysql是NULL指针，该函数将分配、初始化、并返回新对象。否则，将初始化对象，并返回对象的地址。如果mysql_init()分配了新的对象，当调用mysql_close()来关闭连接时。将释放该对象。
返回值：初始化的MYSQL*句柄。如果无足够内存以分配新的对象，返回NULL。
错误：在内存不足的情况下，返回NULL。

三、连接数据库

（4）mysql_real_connect( )

函数原型：MYSQL *mysql_real_connect(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned long client_flag)
描述：mysql_real_connect( )尝试与运行在主机上的MySQL数据库引擎建立连接。在你能够执行需要有效MySQL连接句柄结构的任何其他API函数之前mysql_real_connect()必须成功完成。
参数说明：
（1）第1个参数应是已有MYSQL结构的地址。

（2）“host”的值必须是主机名或IP地址。如果“host”是NULL或字符串"localhost"，连接将被视为与本地主机的连接。

（3）“user”参数包含用户的MySQL登录ID。如果“user”是NULL或空字符串""，用户将被视为当前用户。在UNIX环境下，它是当前的登录名。在Windows ODBC下，必须明确指定当前用户名。

（4）“passwd”参数包含用户的密码。

（5）“db”是数据库名称。

（6）如果“port”不是0，其值将用作TCP/IP连接的端口号。

（7）如果unix_socket不是NULL，该字符串描述了应使用的套接字或命名管道。

（8）client_flag的值通常为0。
返回值：如果连接成功，返回MYSQL*连接句柄。如果连接失败，返回NULL。对于成功的连接，返回值与第1个参数的值相同

示例代码：

#include 
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象，并且初始化，返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;}   m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;}   }int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}return 0;
}

在编译的时候出现了下面这种问题：
在这里插入图片描述
编译的时候要加上库的名字

现在编译通过了：

运行结果：

四、向数据库添加信息

（5）mysql_query( )

函数原型：int mysql_query(MYSQL *mysql, const char *query)
描述：用于向 MySQL 发送并执行 SQL 语句（这里我用来向数据库添加信息）
返回值：成功返回0，失败返回非零值

示例代码：

#include 
#include 
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象，并且初始化，返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;}   m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;}   }void InsertDatabase(MYSQL *m) {if (NULL == m) {return;}char sql[128] = {0};int id, age;char name[32] = {0}, birth[32] = {0}, sex[32] = {0}, tel[32] = {0};cout << "请输入编号、姓名、出生日期、年龄、性别、电话" << endl;cin >> id >> name >> birth >> age >> sex >> tel;sprintf(sql, "insert into student (id, name, birth, age, sex, tel) values (%d, '%s', '%s', %d, '%s', '%s');",id, name, birth, age, sex, tel);int ret = mysql_query(m, sql);if (ret != 0) {cout << mysql_error(m) << endl;return;}cout << "插入成功" << endl;
}int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}// 插入数据InsertDatabase(mysql);return 0;
}

运行结果：
在这里插入图片描述
可以看到student这数据库有添加上东西了

但是插入带有中文的数据时，出现了下面的问题：

在这里插入图片描述

因此要修改字符集：

现在可以了

五、查询数据库里面的数据

（6）mysql_store_result( )

函数原型：MYSQL_RES *mysql_store_result(MYSQL *mysql)
描述：存放查询到的结果
返回：出错返回 NULL

在这里插入图片描述

（7）mysql_num_fields( )

函数原型：unsigned int mysql_num_fields(MYSQL_RES *result)
描述：返回结果中的行数（我认为就是数据类别）

这里运行的结果为：

（8）mysql_fetch_fields( )

函数原型：`MYSQL_FIELD *mysql_fetch_fields(MYSQL_RES *result)
描述：对于结果集，返回所有MYSQL_FIELD结构的数组。每个结构提供了结果集中1列的字段定义`

在这里插入图片描述
运行结果：

（9）mysql_fetch_row( )

函数原型：MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)
描述：获取每一行的信息

运行结果：

完整示例代码：

#include 
#include 
#include 
#include using namespace std;MYSQL *Init() {MYSQL *m; m = mysql_init(NULL); // 创建mysql对象，并且初始化，返回对象的地址if (NULL == m) {cout << mysql_error(m) << endl; // 打印错误信息return NULL;}   m = mysql_real_connect(m, "localhost", "root", "root", "mydatabase", 0, NULL, 0); if (NULL == m) {cout << mysql_error(m) << endl;return NULL;}   }void InsertDatabase(MYSQL *m) {if (NULL == m) {return;}   int ret = mysql_query(m, "set names utf8;");if (ret != 0) {cout << mysql_error(m) << endl;return;}char sql[128] = {0};int id, age;char name[32] = {0}, birth[32] = {0}, sex[32] = {0}, tel[32] = {0};cout << "请输入编号、姓名、出生日期、年龄、性别、电话" << endl;cin >> id >> name >> birth >> age >> sex >> tel;sprintf(sql, "insert into student (id, name, birth, age, sex, tel) values (%d, '%s', '%s', %d, '%s', '%s');",id, name, birth, age, sex, tel);ret = mysql_query(m, sql);if (ret != 0) {cout << mysql_error(m) << endl;return;}cout << "插入成功" << endl;
}void FindDataBase(MYSQL *m) {if (NULL == m) {return;}// 因为后面会输出中文信息mysql_query(m, "set names utf8;");int ret = mysql_query(m, "select * from student;");if (ret != 0) {cout << mysql_error(m) << endl;return;}// 获取查询到的结果MYSQL_RES *res = mysql_store_result(m);if (NULL == res) {cout << mysql_error(m) << endl;return;}// 获取字段数int field = mysql_num_fields(res);//cout << field << endl;MYSQL_FIELD *f; // 结构体，保存每一列的数据while (f = mysql_fetch_field(res)) {// 打印字段名// 宽度为20， 左对齐cout << setw(20) << setiosflags(ios::left) << f->name;}cout << endl;// 获取每一条记录MYSQL_ROW r; // 数组while (r = mysql_fetch_row(res)) {for (int i = 0; i < field; i++) {cout << setw(20) << setiosflags(ios::left) << r[i];}cout << endl;}}int main() {MYSQL *mysql; // 创建mysql对象mysql = Init();if (NULL == mysql) {cout << "初始化mysql失败" << endl;}else {cout << "连接成功" << endl;}// 插入数据//InsertDatabase(mysql);// 查询数据FindDataBase(mysql);return 0;
}