©2020-2024 ioDraw All rights reserved
在实际应用中，我们不可能在命令行登录进数据库进行数据的查询、插入等操作，用户一般是使用一个界面良好的应用程序软件来对数据进行管理。为了方便应用程序的开发，MySQL提供了多种编程语言（C、perl、php等）的编程接口，供开发者使用。
对于C语言来说，MySQL提供了C语言客户机库，它允许从任何C程序的内部访问MySQL数据库，客户机实现API,API定义了客户机如何建立和执行与服务器的通信。使用C语言开发MySQL项目具有更好的安全性和性能，C语言API是与MySQL一起提供的，包含在mysqlclient库文件中，用于连接和执行数据库查询。
在命令行输入以下指令进行MySQL、客户端、客户端接口库的安装。
安装mysql
sudo apt-get install mysql-server
安装mysql客户端
sudo apt install mysql-client
安装mysql客户端接口库
sudo apt-get install libmysqlclient-dev
一、MySQL为C语言操作定义的数据类型
1、MYSQL
MYSQL结构代表一个数据库连接句柄，包含有关服务器的连接状态的信息，几乎所有函数都是用到它。其定义如下：
typedef struct st_mysql { NET net; /* Communication parameters */ unsigned char
*connector_fd; /* ConnectorFd for SSL */ char *host,*user,*passwd,*unix_socket,*
server_version,*host_info; char *info, *db; struct charset_info_st *charset;
MYSQL_FIELD*fields; MEM_ROOT field_alloc; my_ulonglong affected_rows;
my_ulonglong insert_id; /* id if insert on table with NEXTNR */ my_ulonglong
extra_info; /* Not used */ unsigned long thread_id; /* Id for connection in
server */ unsigned long packet_length; unsigned int port; unsigned long
client_flag,server_capabilities; unsigned int protocol_version; unsigned int
field_count; unsigned int server_status; unsigned int server_language; unsigned
int warning_count; struct st_mysql_options options; enum mysql_status status;
my_bool free_me; /* If free in mysql_close */ my_bool reconnect; /* set to 1 if
automatic reconnect */ /* session-wide random string */ char scramble[
SCRAMBLE_LENGTH+1]; /* Set if this is the original connection, not a master or
a slave we have added though mysql_rpl_probe() or mysql_set_master()/
mysql_add_slave() */ my_bool rpl_pivot; /* Pointers to the master, and the next
slave connections, points to itself if lone connection. */ struct st_mysql*
master, *next_slave; struct st_mysql* last_used_slave; /* needed for
round-robin slave pick */ /* needed for send/read/store/use result to work
correctly with replication */ struct st_mysql* last_used_con; LIST *stmts; /*
list of all statements */ const struct st_mysql_methods *methods; void *thd; /*
Points to boolean flag in MYSQL_RES or MYSQL_STMT. We set this flag from
mysql_stmt_close if close had to cancel result set of this object. */ my_bool *
unbuffered_fetch_owner; /* needed for embedded server - no net buffer to store
the 'info' */ char *info_buffer; void *extension; } MYSQL;
2、MYSQL_RES
MYSQL_RES结构代表返回行的查询结果（SELECT、SHOW、DESCRIBE等），从数据库读取数据，最后就是从MYSQL_RES中读取数据。其定义如下：
typedef struct st_mysql_res { my_ulonglong row_count; MYSQL_FIELD *fields;
MYSQL_DATA*data; MYSQL_ROWS *data_cursor; unsigned long *lengths; /* column
lengths of current row */ MYSQL *handle; /* for unbuffered reads */ const struct
st_mysql_methods*methods; MYSQL_ROW row; /* If unbuffered read */ MYSQL_ROW
current_row; /* buffer to current row */ MEM_ROOT field_alloc; unsigned int
field_count, current_field; my_bool eof; /* Used by mysql_fetch_row */ /*
mysql_stmt_close() had to cancel this result */ my_bool
unbuffered_fetch_cancelled; void *extension; } MYSQL_RES;
二、基础函数
1、分配或初始化与mysql_real_connect()相适应的MYSQL对象
MYSQL* mysql_init(MYSQL* mysql)
如果mysql是NULL指针，该函数将分配、初始化、并返回新对象。否则，将初始化对象，并返回对象的地址。如果mysql_init()分配了新的对象，应当在程序中调用mysql_close()
来关闭连接，以释放对象。
2、连接到MySQL server
MYSQL* mysql_real_connect(MYSQL* mysql,const char* host,const charuser,
const char passwd,const char* db,unsigned int port,
const char* unix_socket,unsigned long client_flag)
在能够执行需要有效MySQL连接句柄结构的任何其它API函数之前，mysql_real_connect() 必须成功完成。
参数：
“mysql”——已有MYSQL结构的地址。
“host”——必须是主机名或IP地址。如果host是NULL或字符串“localhost”，连接将被视为与本地主机连接
“user”——用户名
“passwd”——用户的密码
“db”——数据库名称
“port”——如果“port”不是0，其值将用作TCP/IP连接的端口号
“unix_socket”——通常指定为NULL
“client_flag”——通常为0，但是，也能将其设置为具有特定功能的标志组合。
3、执行字符串指定的sql查询语句
int mysql_real_query(MYSQL *mysql, const char *query, unsigned long length)
执行由指针query指向的字符串进行SQL查询，字符串长度应为length。正常情况下，字符串必须包含1条SQL语句，而且不应为语句添加终结分号（‘;’）或“\g”。如果允许多语句执行，字符串可包含由分号隔开的多条语句。
如果查询成功，函数返回0。如果出现错误，函数返回非0值。
4、向客户端检索完整的结果集
MYSQL_RES* mysql_store_result(MYSQL* mysql)
对于成功检索了数据的每个查询（SELECT、SHOW、DESCRIBE、EXPLAIN、CHECK
TABLE等），必须调用mysql_store_result()。
mysql_store_result()将查询的全部结果读取到客户端，分配1个MYSQL_RES结构,并将结果置于该结构中。如果查询未返回结果集，mysql_store_result()将返回Null指针。
5、获取结果集中的行数
my_ulonglong mysql_num_rows(MYSQL_RES *result)
6、获取结果集中的列数
unsigned int mysql_num_fields(MYSQL_RES *result)
7、从结果集中获取下一行
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)
返回值：下一行的MYSQL_ROW结构，如果没有更多的行可检索或者发生错误时，则返回NULL。
8、获取最近查询的列数
unsigned int mysql_field_count(MYSQL* mysql)
返回：最近查询的列数
该函数的正常使用是在 mysql_store_result() 返回 NULL（因而没有结果集指针）时。在这种情况下，可调用
mysql_field_count() 来判定 mysql_store_result()
是否应生成非空结果。这样客户端就能采取恰当的动作，而无需知道查询是否是 SELECT （或类似的SELECT的）语句。
9、返回最近调用MySQL函数发生的错误信息
const char* mysql_error(MYSQL* mysql)
返回值：描述错误信息的以null结尾的字符串，如果未发生错误，则返回空字符串。
10、关闭一个server连接
void mysql_close(MYSQL* mysql)
关闭前面已经打开的连接。如果句柄是由mysql_init() 或mysql_connect() 自定分配的，mysql_close()
还将解除分配由mysql指向的连接句柄。
三、与MySQL交互时，应用程序应使用该一般性原则：
1、 通过调用mysql_init()初始化连接处理程序，并通过调用mysql_real_connect()连接到服务器。
2、 发出SQL语句并处理其结果。
3、 通过调用mysql_close()，关闭与MySQL服务器的连接。
四、实现代码
1、查询数据
#include <stdio.h> #include <mysql/mysql.h> #include <string.h> int main(int
argc, const char *argv[]) { MYSQL mysql; MYSQL_RES *res = NULL; MYSQL_ROW row;
char *query_str = NULL; int rc, i, fields; int rows; if (NULL == mysql_init(&
mysql)) { printf("mysql_init(): %s\n", mysql_error(&mysql)); return -1; } if (
NULL == mysql_real_connect(&mysql, "localhost", "root", "123456", "usrinfo", 0,
NULL, 0)){ printf("mysql_real_connect(): %s\n", mysql_error(&mysql)); return -1;
} printf("Connected MySQL successful! \n"); //然后查询插入删除之后的数据 query_str =
"select * from usr_info"; rc = mysql_real_query(&mysql, query_str, strlen(
query_str)); if (0 != rc) { printf("mysql_real_query(): %s\n", mysql_error(&
mysql)); return -1; } res = mysql_store_result(&mysql); if (NULL == res) {
printf("mysql_restore_result(): %s\n", mysql_error(&mysql)); return -1; } rows =
mysql_num_rows(res); printf("The total rows is: %d\n", rows); fields =
mysql_num_fields(res); printf("The total fields is: %d\n", fields); while ((row
= mysql_fetch_row(res))) { for (i = 0; i < fields; i++) { printf("%s\t", row[i])
; } printf("\n"); } mysql_free_result(res); mysql_close(&mysql); return 0; }
运行
root@instance-3xw0fccv:~/mysqltest# gcc -o Mainpro select.c -L /usr/bin/mysql -
lmysqlclient root@instance-3xw0fccv:~/mysqltest# ./Mainpro Connected MySQL
successful! The total rows is: 3 The total fields is: 3 XiaoMing 22 1999-05-06
XiaoLi23 1998-11-18 XiaoHong 20 2001-06-24
2、插入数据
#include <stdio.h> #include <mysql/mysql.h> #include <string.h> int main(int
argc, const char *argv[]) { MYSQL mysql; MYSQL_RES *res = NULL; MYSQL_ROW row;
char *query_str = NULL; int rc, i, fields; int rows; if (NULL == mysql_init(&
mysql)) { printf("mysql_init(): %s\n", mysql_error(&mysql)); return -1; } if (
NULL == mysql_real_connect(&mysql, "localhost", "root", "123456", "usrinfo", 0,
NULL, 0)){ printf("mysql_real_connect(): %s\n", mysql_error(&mysql)); return -1;
} printf("Connected MySQL successful! \n"); //执行插入请求 query_str = "insert into
usr_info values ('XiaoZhang', '24','1997-02-03')"; rc = mysql_real_query(&mysql,
query_str, strlen(query_str)); if (0 != rc) { printf("mysql_real_query(): %s\n"
, mysql_error(&mysql)); return -1; } //然后查询插入删除之后的数据 query_str = "select *
from usr_info"; rc = mysql_real_query(&mysql, query_str, strlen(query_str)); if
(0 != rc) { printf("mysql_real_query(): %s\n", mysql_error(&mysql)); return -1;
} res = mysql_store_result(&mysql); if (NULL == res) { printf(
"mysql_restore_result(): %s\n", mysql_error(&mysql)); return -1; } rows =
mysql_num_rows(res); printf("The total rows is: %d\n", rows); fields =
mysql_num_fields(res); printf("The total fields is: %d\n", fields); while ((row
= mysql_fetch_row(res))) { for (i = 0; i < fields; i++) { printf("%s\t", row[i])
; } printf("\n"); } mysql_free_result(res); mysql_close(&mysql); return 0; }
运行
root@instance-3xw0fccv:~/mysqltest# gcc -o Mainpro insert.c -L /usr/bin/mysql -
lmysqlclient root@instance-3xw0fccv:~/mysqltest# ./Mainpro Connected MySQL
successful! The total rows is: 4 The total fields is: 3 XiaoMing 22 1999-05-06
XiaoLi23 1998-11-18 XiaoHong 20 2001-06-24 XiaoZhang 24 1997-02-03
3、删除数据
#include <stdio.h> #include <mysql/mysql.h> #include <string.h> int main(int
argc, const char *argv[]) { MYSQL mysql; MYSQL_RES *res = NULL; MYSQL_ROW row;
char *query_str = NULL; int rc, i, fields; int rows; if (NULL == mysql_init(&
mysql)) { printf("mysql_init(): %s\n", mysql_error(&mysql)); return -1; } if (
NULL == mysql_real_connect(&mysql, "localhost", "root", "123456", "usrinfo", 0,
NULL, 0)){ printf("mysql_real_connect(): %s\n", mysql_error(&mysql)); return -1;
} printf("Connected MySQL successful! \n"); //执行删除请求 query_str = "delete from
usr_info where name='XiaoLi'"; rc = mysql_real_query(&mysql, query_str, strlen(
query_str)); if (0 != rc) { printf("mysql_real_query(): %s\n", mysql_error(&
mysql)); return -1; } //然后查询插入删除之后的数据 query_str = "select * from usr_info"; rc
= mysql_real_query(&mysql, query_str, strlen(query_str)); if (0 != rc) { printf(
"mysql_real_query(): %s\n", mysql_error(&mysql)); return -1; } res =
mysql_store_result(&mysql); if (NULL == res) { printf("mysql_restore_result():
%s\n", mysql_error(&mysql)); return -1; } rows = mysql_num_rows(res); printf(
"The total rows is: %d\n", rows); fields = mysql_num_fields(res); printf("The
total fields is: %d\n", fields); while ((row = mysql_fetch_row(res))) { for (i =
0; i < fields; i++) { printf("%s\t", row[i]); } printf("\n"); }
mysql_free_result(res); mysql_close(&mysql); return 0; }
运行
root@instance-3xw0fccv:~/mysqltest# gcc -o Mainpro delete.c -L /usr/bin/mysql -
lmysqlclient root@instance-3xw0fccv:~/mysqltest# ./Mainpro Connected MySQL
successful! The total rows is: 3 The total fields is: 3 XiaoMing 22 1999-05-06
XiaoHong20 2001-06-24 XiaoZhang 24 1997-02-03
4、修改数据
#include <stdio.h> #include <mysql/mysql.h> #include <string.h> int main(int
argc, const char *argv[]) { MYSQL mysql; MYSQL_RES *res = NULL; MYSQL_ROW row;
char *query_str = NULL; int rc, i, fields; int rows; if (NULL == mysql_init(&
mysql)) { printf("mysql_init(): %s\n", mysql_error(&mysql)); return -1; } if (
NULL == mysql_real_connect(&mysql, "localhost", "root", "123456", "usrinfo", 0,
NULL, 0)){ printf("mysql_real_connect(): %s\n", mysql_error(&mysql)); return -1;
} printf("Connected MySQL successful! \n"); //执行修改请求 query_str = "UPDATE
usr_info SET birthday='1999-07-03',age='22' WHERE name ='XiaoHong'"; rc =
mysql_real_query(&mysql, query_str, strlen(query_str)); if (0 != rc) { printf(
"mysql_real_query(): %s\n", mysql_error(&mysql)); return -1; } //然后查询插入删除之后的数据
query_str= "select * from usr_info"; rc = mysql_real_query(&mysql, query_str,
strlen(query_str)); if (0 != rc) { printf("mysql_real_query(): %s\n",
mysql_error(&mysql)); return -1; } res = mysql_store_result(&mysql); if (NULL ==
res) { printf("mysql_restore_result(): %s\n", mysql_error(&mysql)); return -1;
} rows = mysql_num_rows(res); printf("The total rows is: %d\n", rows); fields =
mysql_num_fields(res); printf("The total fields is: %d\n", fields); while ((row
= mysql_fetch_row(res))) { for (i = 0; i < fields; i++) { printf("%s\t", row[i])
; } printf("\n"); } mysql_free_result(res); mysql_close(&mysql); return 0; }
运行
root@instance-3xw0fccv:~/mysqltest# gcc -o Mainpro update.c -L /usr/bin/mysql -
lmysqlclient root@instance-3xw0fccv:~/mysqltest# ./Mainpro Connected MySQL
successful! The total rows is: 3 The total fields is: 3 XiaoMing 22 1999-05-06
XiaoHong22 1999-07-03 XiaoZhang 24 1997-02-03