引言

MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，目前属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一，在 WEB 应用方面，MySQL是最好的 RDBMS (Relational Database Management System，关系数据库管理系统) 应用软件。

MySQL是一种关系数据库管理系统，关系数据库将数据保存在不同的表中，而不是将所有数据放在一个大仓库内，这样就增加了速度并提高了灵活性。

MySQL所使用的 SQL 语言是用于访问数据库的最常用标准化语言。MySQL 软件采用了双授权政策，分为社区版和商业版，由于其体积小、速度快、总体拥有成本低，尤其是开放源码这一特点，一般中小型网站的开发都选择 MySQL 作为网站数据库。

API是其它的应用程序为程序员提供的编程接口，可以通过这些接口修改原应用程序的一些行为（可以通过API为原应用程序编写插件），前面的C表示这些接口可以用C语言编写的程序调用。

MySQL C API编程

MYSQL结构体：

这个结构主要用于连接，保存一些连接的信息。

typedefstructst_mysql { NET net;/* Communication parameters */gptr connector_fd;/* ConnectorFd for SSL */char*host,*user,*passwd,*unix_socket, *server_version,*host_info,*info,*db;unsignedintport,client_flag,server_capabilities;unsignedintprotocol_version;unsignedintfield_count;unsignedintserver_status;unsignedlongthread_id;/* Id for connection in server */my_ulonglong affected_rows; my_ulonglong insert_id;/* id if insert on table with NEXTNR */my_ulonglong extra_info;/* Used by mysqlshow */unsignedlongpacket_length;enummysql_status status; MYSQL_FIELD *fields; MEM_ROOT field_alloc; my_bool free_me;/* If free in mysql_close */my_bool reconnect;/* set to 1 if automatic reconnect */structst_mysql_options options;charscramble_buff[9];structcharset_info_st *charset;unsignedintserver_language;} MYSQL;

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

2. MYSQL_RES结构体：

这个结构主要是返回一些操作数据库（SELECT, SHOW, DESCRIBE, EXPLAIN等）的结果，即“数据集”。

typedefstructst_mysql_res { my_ulonglong row_count;unsignedintfield_count, current_field; MYSQL_FIELD *fields; MYSQL_DATA *data; MYSQL_ROWS *data_cursor; MEM_ROOT field_alloc; MYSQL_ROW row;/* If unbuffered read */MYSQL_ROW current_row;/* buffer to current row */unsignedlong*lengths;/* column lengths of current row */MYSQL *handle;/* for unbuffered reads */my_bool eof;/* Used my mysql_fetch_row */} MYSQL_RES;

1

2

3

4

5

6

7

8

9

10

11

12

13

1

2

3

4

5

6

7

8

9

10

11

12

13

3. MySQL C API编程步骤：

具体有哪些函数，可以到网上搜索一下相关介绍，这里讲一下编程步骤：

(1)、首先我们要包含mysql的头文件，并链接mysql动态库。即添加以下语句：

#include // 进行网络编程需要winsock2.h

#include

#pragma comment(lib, "libmysql.lib")

(2)、创建MYSQL变量。如：

MYSQL mysql;

(3）、初始化MYSQL变量。

mysql_init(&mysql);

（4）、调用mysql_real_connect函数连接Mysql数据库。mysql_real_connect函数的原型如下：

MYSQL * STDCALL 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 clientflag);

参数说明：mysql--前面定义的MYSQL变量；host--MYSQL服务器的地址；user--登录用户名；passwd--登录密码；db--要连接的数据库；port--MYSQL服务器的TCP服务端口；unix_socket--unix连接方式，为NULL时表示不使用socket或管道机制；clientflag--Mysql运行为ODBC数据库的标记，一般取0。

连接失败时该函数返回0。

（5）、调用mysql_real_query函数进行数据库查询。mysql_real_query函数的原型如下：

int STDCALL mysql_real_query(MYSQL *mysql, const char *q, unsigned long length);

参数说明：mysql--前面定义的MYSQL变量；q--SQL查询语句；length--查询语句的长度。

查询成功则该函数返回0。

（6）、通过调用mysql_store_result或mysql_use_result函数返回的MYSQL_RES变量获取查询结果数据。

两个函数的原型分别为：

MYSQL_RES * STDCALL mysql_store_result(MYSQL *mysql);

MYSQL_RES * STDCALL mysql_use_result(MYSQL *mysql);

这两个函数分别代表了获取查询结果的两种方式。第一种，调用端，然后读取；第二种，调用mysql_use_result初始化检索，以便于后面一行一行的读取结果集，而它本身并没有从服务器读取任何数据，这种方式较之第一种速度更快且所需内存更少，但它会绑定服务器，阻止其他线程更新任何表，而且必须重复执行mysql_fetch_row读取数据，直至返回NULL，否则未读取的行会在下一次查询时作为结果的一部分返回，故经常我们使用mysql_store_result。

（7）、调用mysql_fetch_row函数读取结果集数据。

上述两种方式最后都是重复调用mysql_fetch_row函数读取数据。mysql_fetch_row函数的原型如下：

MYSQL_ROW STDCALL mysql_fetch_row(MYSQL_RES *result);

参数result就是mysql_store_result或mysql_use_result的返回值。

该函数返回MYSQL_ROW型的变量，即字符串数组，假设为row，则row[i]为第i个字段的值。当到结果集尾部时，此函数返回NULL。

（8）、结果集用完后，调用mysql_free_result函数释放结果集，以防内存泄露。mysql_free_result函数的原型如下：

void STDCALL mysql_free_result(MYSQL_RES *result);

（9）、不再查询Mysql数据库时，调用mysql_close函数关闭数据库连接。mysql_close函数的原型为：

void STDCALL mysql_close(MYSQL *sock);

4. MySQL C API编程例子：

#if defined(_WIN32) || defined(_WIN64)//为了支持windows平台上的编译#include #endif#include #include #include "mysql.h"//我的机器上该文件在/usr/local/include/mysql下//定义数据库操作的宏，也可以不定义留着后面直接写进代码#define SELECT_QUERY "select username from tbb_user where userid = %d"intmain(intargc,char**argv)//char **argv 相当于 char *argv[]{ MYSQL mysql,*sock;//定义数据库连接的句柄，它被用于几乎所有的MySQL函数MYSQL_RES *res;//查询结果集，结构类型MYSQL_FIELD *fd ;//包含字段信息的结构MYSQL_ROW row ;//存放一行查询结果的字符串数组charqbuf[160];//存放查询sql语句字符串if(argc !=2) {//检查输入参数fprintf(stderr,"usage : mysql_select nn");exit(1); } mysql_init(&mysql);if(!(sock = mysql_real_connect(&mysql,"localhost","dbuser","dbpwd","9tmd_bbs_utf8",0,NULL,0))) {fprintf(stderr,"Couldn't connect to engine!n%snn",mysql_error(&mysql)); perror("");exit(1); }sprintf(qbuf,SELECT_QUERY,atoi(argv[1]));if(mysql_query(sock,qbuf)) {fprintf(stderr,"Query failed (%s)n",mysql_error(sock));exit(1); }if(!(res=mysql_store_result(sock))) {fprintf(stderr,"Couldn't get result from %sn", mysql_error(sock));exit(1); }printf("number of fields returned: %dn",mysql_num_fields(res));while(row = mysql_fetch_row(res)) {printf("Ther userid #%d 's username is: %sn", atoi(argv[1]),(((row[0]==NULL)&&(!strlen(row[0]))) ?"NULL": row[0])) ;puts("query ok !n") ; } mysql_free_result(res); mysql_close(sock);exit(0);return0;//. 为了兼容大部分的编译器加入此行}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

总结

以 上就是我对Java开发大型互联网-如何构建一个MySQL数据库 C API编程系统   问题及其优化总结，分享给大家，觉得收获的话可以点个关注收藏转发一波喔，谢谢大佬们支持！

最后，每一位读到这里的网友，感谢你们能耐心地看完。希望在成为一名更优秀的Java程序员的道路上，我们可以一起学习、一起进步！都能赢取白富美，走向架构师的人生巅峰!

想了解学习Java方面的技术内容以及Java技术视频的内容可加群：722040762 验证码：简书（666 必过）欢迎大家的加入哟！