c语言连接mysql数据库的实现方法

以你之姓@ 2022-03-16 07:44 241阅读 0赞

# c语言连接mysql数据库的实现方法 #

发布：mdxy-dxy 字体：\[ 增加 减小\] 类型：转载

C语言连接mysql数据库，需要相应的头文件和lib文件，如果你安装Mysql数据库，会在安装目录下找到这些库文件，如果没有安装，也可以在网上找到

我这里也有一份网上找到的： [/201205/other/C\_link\_mySql51.rar][201205_other_C_link_mySql51.rar]  
C连接MySql5.1所需文件.rar  
附带一个不错的例子：

复制代码 代码如下:

\#include <string.h>  
\#include <stdlib.h>  
\#include <stdio.h>  
\#include <winsock2.h>  
\#include <mysql/mysql.h>/\*注意要包含这个头文件\*/  
\#pragma comment(lib,"libmysql")  
/\*定义了一些数据库连接需要的宏\*/  
\#define HOST "localhost"  
\#define USERNAME "root"  
\#define PASSWORD "123456"  
\#define DATABASE "test"  
/\*这个函数用来执行传入的sql語句\*/  
void exe\_sql(char\* sql) \{  
MYSQL my\_connection; /\*这是一个数据库连接\*/  
int res; /\*执行sql語句后的返回标志\*/  
/\*初始化mysql连接my\_connection\*/  
mysql\_init(&my\_connection);  
/\*这里就是用了mysql.h里的一个函数，用我们之前定义的那些宏建立mysql连接，并  
返回一个值，返回不为空证明连接是成功的\*/  
if (mysql\_real\_connect(&my\_connection, HOST, USERNAME, PASSWORD,  
DATABASE, 0, NULL, CLIENT\_FOUND\_ROWS)) \{/\*连接成功\*/  
printf("数据库执行exe\_sql连接成功！n");  
/\*这句话是设置查询编码为utf8，这样支持中文\*/  
mysql\_query(&my\_connection, "set names utf8");  
/\*下面这句话就是用mysql\_query函数来执行我们刚刚传入的sql語句，  
这会返回一个int值，如果为0，证明語句执行成功\*/  
res = mysql\_query(&my\_connection, sql);  
if (res) \{/\*现在就代表执行失败了\*/  
printf("Error： mysql\_query !\\n");  
/\*不要忘了关闭连接\*/  
mysql\_close(&my\_connection);  
\} else \{/\*现在就代表执行成功了\*/  
/\*mysql\_affected\_rows会返回执行sql后影响的行数\*/  
printf("%d 行受到影响！\\n",  
mysql\_affected\_rows(&my\_connection));  
/\*不要忘了关闭连接\*/  
mysql\_close(&my\_connection);  
\}  
\} else \{  
/\*数据库连接失败\*/  
printf("数据库执行exe\_sql连接失败！\\n");  
\}  
\}  
/\*这个函数用来执行传入的sql語句，并打印出查询結果\*/  
void query\_sql(char\* sql) \{  
MYSQL my\_connection; /\*这是一个数据库连接\*/  
int res; /\*执行sql語句后的返回标志\*/  
MYSQL\_RES \*res\_ptr; /\*指向查询结果的指针\*/  
MYSQL\_FIELD \*field; /\*字段结构指针\*/  
MYSQL\_ROW result\_row; /\*按行返回的查询信息\*/  
int row, column; /\*查询返回的行数和列数\*/  
int i, j; /\*只是控制循环的两个变量\*/  
/\*初始化mysql连接my\_connection\*/  
mysql\_init(&my\_connection);  
/\*这里就是用了mysql.h里的一个函数，用我们之前定义的那些宏建立mysql连接，并  
返回一个值，返回不为空证明连接是成功的\*/  
if (mysql\_real\_connect(&my\_connection, HOST, USERNAME, PASSWORD,  
DATABASE, 0, NULL, CLIENT\_FOUND\_ROWS)) \{/\*连接成功\*/  
printf("数据库查询query\_sql连接成功！\\n");  
/\*这句话是设置查询编码为utf8，这样支持中文\*/  
mysql\_query(&my\_connection, "set names utf8");  
\*下面这句话就是用mysql\_query函数来执行我们刚刚传入的sql語句，  
这会返回一个int值，如果为0，证明語句执行成功\*/  
res = mysql\_query(&my\_connection, sql);  
if (res) \{ /\*现在就代表执行失败了\*/  
printf("Error： mysql\_query !\\n");  
/\*不要忘了关闭连接\*/  
mysql\_close(&my\_connection);  
\} else \{ /\*现在就代表执行成功了\*/  
/\*将查询的結果给res\_ptr\*/  
res\_ptr = mysql\_store\_result(&my\_connection);  
/\*如果结果不为空，就把结果print\*/  
if (res\_ptr) \{  
/\*取得結果的行数和\*/  
column = mysql\_num\_fields(res\_ptr);  
row = mysql\_num\_rows(res\_ptr) + 1;  
printf("查询到 %lu 行 \\n", row);  
/\*输出結果的字段名\*/  
for (i = 0; field = mysql\_fetch\_field(res\_ptr); i++)  
printf("%st", field->name);  
printf("\\n");  
/\*按行输出結果\*/  
for (i = 1; i < row; i++) \{  
result\_row = mysql\_fetch\_row(res\_ptr);  
for (j = 0; j < column; j++)  
printf("%st", result\_row\[j\]);  
printf("\\n");  
\}  
\}  
/\*不要忘了关闭连接\*/  
mysql\_close(&my\_connection);  
\}  
\}  
\}  
int main(int argc, char \*argv\[\]) \{  
/\*测试下向里面插入数据\*/  
char \*query;  
char \*exe = "insert into student values('lala','hahhahah!');";  
exe\_sql(exe);  
\*测试下查询\*/  
query="select \* from student;";  
query\_sql(query);  
return 0;  
\}

[201205_other_C_link_mySql51.rar]: http://xiazai.jb51.net/201205/other/C_link_mySql51.rar