在实际应用中,我们不可能在命令行登录进数据库进行数据的查询、插入等操作,用户一般是使用一个界面良好的应用程序软件来对数据进行管理。为了方便应用程序的开发,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

技术
今日推荐
阅读数 6783
阅读数 1922
阅读数 1504
阅读数 1291
阅读数 1254
阅读数 1134
下载桌面版
GitHub
百度网盘(提取码:draw)
Gitee
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:ixiaoyang8@qq.com
QQ群:766591547
关注微信