用C语言如何对MySQL数据库进行操作

Posted 2023-05-16

有时为了性能，我们会直接用C语言来开发相关的模块，尤其在我们的web应用中，虽然php、JSP等脚本均提供了mysql的接口，但是显然直接使用C语言具有更好的安全性和性能，Michael以前用PHP开发的多个项目中就使用了C语言编写的这类接口，然后再编译到php里面，供php脚本直接使用,这方面的话题就不多说了，下面主要说一下在Linux下如何用C语言连接MySQL数据库，并且读取里面的数据返回，同时如何进行编译。if defined(_WIN32) || defined(_WIN64)为了支持windows平台上的编译#include<windows.h#endif#include<stdio.h#include<stdlib.h#includemysql.h我的机器上该文件在/usr/local/include/mysql下定义MySQL数据库操作的宏，也可以不定义留着后面直接写进代码defineSELECT_QUERYselectusernamefromtbb_userwhereuserid=%dintmain(intargc,char**argv)char**argv相当于char*argv[]MYSQL mysql,*sock;定义数据库连接的句柄，它被用于几乎所有的MySQL函数MYSQL_RES *res;查询结果集，结构类型MYSQL_FIELD *fd ;包含字段信息的结构MYSQL_ROW row ;存放一行查询结果的字符串数组char qbuf[160];存放查询sql语句字符串if(argc!=2)//检查输入参数fprintf(stderr,usage:mysql_select<userid\n\n);exit(1);mysql_init(&mysql);if(!(sock=mysql_real_connect(&mysql,localhost,dbuser,dbpwd,9tmd_bbs_utf8,0,NULL,0)))fprintf(stderr,Couldn'tconnecttoengine!\n%s\n\n,mysql_error(&mysql));perror();exit(1);sprintf(qbuf,SELECT_QUERY,atoi(argv[1]));if(mysql_query(sock,qbuf))fprintf(stderr,Queryfailed(%s)\n,mysql_error(sock));exit(1);if(!(res=mysql_store_result(sock)))fprintf(stderr,Couldn'tgetresultfrom%s\n,mysql_error(sock));exit(1);printf(numberoffieldsreturned:%d\n,mysql_num_fields(res));while(row=mysql_fetch_row(res))printf(Theruserid#%d'susernameis:%s\n,atoi(argv[1]),(((row[0]==NULL)&&(!strlen(row[0])))?NULL:row[0]));puts(queryok!\n);mysql_free_result(res);mysql_close(sock);exit(0);return0;为了兼容大部分的编译器加入此行编译的时候，使用下面的命令gcc -o mysql_select ./mysql_select.c -I/usr/local/include/mysql -L/usr/local/lib/mysql -lmysqlclient (-lz) (-lm) 后面两个选项可选，根据您的环境情况运行的时候，执行下面的命令./mysql_select 1将返回如下结果：numberoffieldsreturned:1Theruserid#1'susernameis:Michaelqueryok!上面的代码我想大部分都能看明白，不明白的可以参考一下MySQL提供的有关C语言API部分文档源码天空，各个函数都有详细说明，有时间我整理一份常用的API说明出来。 参考技术A 里的大部分代码参考了MySQL发行包里面的.c源文件，大家也可以去里面找找相关的代码，下面这段代码实现了连接到本地MySQL服务器上9tmd_bbs_utf8数据库，从数据表tbb_user中根据输入的userid取得该用户的用户名并打印输出到终端。
if defined(_WIN32) || defined(_WIN64)为了支持windows平台上的编译
#include <windows.h> #endif #include <stdio.h> #include <stdlib.h> #include "mysql.h"

我的机器上该文件在/usr/local/include/mysql下
定义MySQL数据库操作的宏，也可以不定义留着后面直接写进代码
define SELECT_QUERY "select username from tbb_user where userid = %d" int main(int argc, char **argv)char **argv 相当于 char *argv[]

MYSQL mysql,*sock;定义数据库连接的句柄，它被用于几乎所有的MySQL函数
MYSQL_RES *res;查询结果集，结构类型
MYSQL_FIELD *fd ;包含字段信息的结构
MYSQL_ROW row ;存放一行查询结果的字符串数组
char qbuf[160];存放查询sql语句字符串
if (argc != 2) //检查输入参数 fprintf(stderr,"usage : mysql_select <userid>\n\n"); 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%s\n\n",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 %s\n", mysql_error(sock)); exit(1); printf("number of fields returned: %d\n",mysql_num_fields(res)); while (row = mysql_fetch_row(res)) printf("Ther userid #%d 's username is: %s\n", 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); return 0;

为了兼容大部分的编译器加入此行

编译的时候，使用下面的命令
gcc -o mysql_select ./mysql_select.c -I/usr/local/include/mysql -L/usr/local/lib/mysql -lmysqlclient (-lz) (-lm) 后面两个选项可选，根据您的环境情况运行的时候，执行下面的命令
./mysql_select 1
将返回如下结果：
number of fields returned: 1 Ther userid #1 's username is: Michael query ok !

上面的代码我想大部分都能看明白，不明白的可以参考一下MySQL提供的有关C语言API部分文档，各个函数都有详细说明，有时间我整理一份常用的API说明出来。 参考技术B 调用mysql数据库API。
去官网下载mysql c API库文件，然后安装一下，每个调用数据库的函数都有相关解释，直接参照函数解释进行编程就行了。
注意编写makefile的时候把相关依赖库加入

用c语言怎么连接数据库呢？

用c语言怎么连接数据库呢？我问了好多人都说不知道，也有很多人说面向过程的语言是不能连接数据库的！

1、配置ODBC数据源。
2、使用SQL函数进行连接。
对于1、配置数据源，配置完以后就可以编程操作数据库了。
对于2、使用SQL函数进行连接，参考代码如下：

#include<windows.h>
#include<sql.h>
#include<sqlext.h>
void main()

HENV henv; //环境句柄
HDBC hdbc; //数据源句柄
HSTMT hstmt; //执行语句句柄
unsigned char datasource[]="数据源名称"; //即源中设置的源名称
unsigned char user[]= "用户名"; //数据库的帐户名
unsigned char pwd[]= "密码"; //数据库的密码
unsigned char search[]="select xm from stu where xh=0";
SQLRETURN retcode; //记录各SQL函数的返回情况
// 分配环境句柄
retcode= SQLAllocEnv(&henv); // 等介于 SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL
, &henv);
// 设置ODBC环境版本号为3.0
retcode= SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
// 分配连接句柄
retcode= SQLAllocConnect(henv,&hdbc); // 等介于 SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
//设置连接属性,登录超时为*rgbValue秒（可以没有）
// SQLSetConnectAttr(hdbc, SQL_LOGIN_TIMEOUT, (SQLPOINTER)(rgbValue), 0);
//直接连接数据源
// 如果是windows身份验证，第二、三参数可以是
，也可以是任何字串
//SQL_NTS 即 "
retcode= SQLConnect(hdbc,datasource, SQL_NTS, user, SQL_NTS , pwd, SQL_NTS );
//分配语句句柄
retcode= SQLAllocStmt(hdbc,&hstmt); // 等介于 SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
//直接执行查询语句
retcode=SQLExecDirect(hstmt,search,SQL_NTS);
//将数据缓冲区绑定数据库中的相应字段（i是查询结果集列号，queryData是绑定缓冲区，BUFF_LENGTH是缓冲区长度）
SQLBindCol(hstmt, i, SQL_C_CHAR, queryData[i-1], BUFF_LENGTH, 0);
//遍历结果集到相应缓冲区 queryData
SQLFetch(hstmt);
/*
*对遍历结果的相关操作，如显示等
*/
//注意释放顺序，否则会造成未知错误！
SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
SQLDisconnect(hdbc);
SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
SQLFreeHandle(SQL_HANDLE_ENV, henv);

参考技术A 25.2.2. C API函数概述
这里归纳了C API可使用的函数，并在下一节详细介绍了它们。请参见25.2.3节，“C API函数描述”。

函数
描述

mysql_affected_rows()
返回上次UPDATE、DELETE或INSERT查询更改／删除／插入的行数。

mysql_autocommit()
切换 autocommit模式，ON/OFF

mysql_change_user()
更改打开连接上的用户和数据库。

mysql_charset_name()
返回用于连接的默认字符集的名称。

mysql_close()
关闭服务器连接。

mysql_commit()
提交事务。

mysql_connect()
连接到MySQL服务器。该函数已不再被重视，使用mysql_real_connect()取代。

mysql_create_db()
创建数据库。该函数已不再被重视，使用SQL语句CREATE DATABASE取而代之。

mysql_data_seek()
在查询结果集中查找属性行编号。

mysql_debug()
用给定的字符串执行DBUG_PUSH。

mysql_drop_db()
撤销数据库。该函数已不再被重视，使用SQL语句DROP DATABASE取而代之。

mysql_dump_debug_info()
让服务器将调试信息写入日志。

mysql_eof()
确定是否读取了结果集的最后一行。该函数已不再被重视，可以使用mysql_errno()或mysql_error()取而代之。

mysql_errno()
返回上次调用的MySQL函数的错误编号。

mysql_error()
返回上次调用的MySQL函数的错误消息。

mysql_escape_string()
为了用在SQL语句中，对特殊字符进行转义处理。

mysql_fetch_field()
返回下一个表字段的类型。

mysql_fetch_field_direct()
给定字段编号，返回表字段的类型。

mysql_fetch_fields()
返回所有字段结构的数组。

mysql_fetch_lengths()
返回当前行中所有列的长度。

mysql_fetch_row()
从结果集中获取下一行

mysql_field_seek()
将列光标置于指定的列。

mysql_field_count()
返回上次执行语句的结果列的数目。

mysql_field_tell()
返回上次mysql_fetch_field()所使用字段光标的位置。

mysql_free_result()
释放结果集使用的内存。

mysql_get_client_info()
以字符串形式返回客户端版本信息。

mysql_get_client_version()
以整数形式返回客户端版本信息。

mysql_get_host_info()
返回描述连接的字符串。

mysql_get_server_version()
以整数形式返回服务器的版本号。

mysql_get_proto_info()
返回连接所使用的协议版本。

mysql_get_server_info()
返回服务器的版本号。

mysql_info()
返回关于最近所执行查询的信息。

mysql_init()
获取或初始化MYSQL结构。

mysql_insert_id()
返回上一个查询为AUTO_INCREMENT列生成的ID。

mysql_kill()
杀死给定的线程。

mysql_library_end()
最终确定MySQL C API库。

mysql_library_init()
初始化MySQL C API库。

mysql_list_dbs()
返回与简单正则表达式匹配的数据库名称。

mysql_list_fields()
返回与简单正则表达式匹配的字段名称。

mysql_list_processes()
返回当前服务器线程的列表。

mysql_list_tables()
返回与简单正则表达式匹配的表名。

mysql_more_results()
检查是否还存在其他结果。

mysql_next_result()
在多语句执行过程中返回/初始化下一个结果。

mysql_num_fields()
返回结果集中的列数。

mysql_num_rows()
返回结果集中的行数。

mysql_options()
为mysql_connect()设置连接选项。

mysql_ping()
检查与服务器的连接是否工作，如有必要重新连接。

mysql_query()
执行指定为“以Null终结的字符串”的SQL查询。

mysql_real_connect()
连接到MySQL服务器。

mysql_real_escape_string()
考虑到连接的当前字符集，为了在SQL语句中使用，对字符串中的特殊字符进行转义处理。

mysql_real_query()
执行指定为计数字符串的SQL查询。

mysql_refresh()
刷新或复位表和高速缓冲。

mysql_reload()
通知服务器再次加载授权表。

mysql_rollback()
回滚事务。

mysql_row_seek()
使用从mysql_row_tell()返回的值，查找结果集中的行偏移。

mysql_row_tell()
返回行光标位置。

mysql_select_db()
选择数据库。

mysql_server_end()
最终确定嵌入式服务器库。

mysql_server_init()
初始化嵌入式服务器库。

mysql_set_server_option()
为连接设置选项（如多语句）。

mysql_sqlstate()
返回关于上一个错误的SQLSTATE错误代码。

mysql_shutdown()
关闭数据库服务器。

mysql_stat()
以字符串形式返回服务器状态。

mysql_store_result()
检索完整的结果集至客户端。

mysql_thread_id()
返回当前线程ID。

mysql_thread_safe()
如果客户端已编译为线程安全的，返回1。

mysql_use_result()
初始化逐行的结果集检索。

mysql_warning_count()
返回上一个SQL语句的告警数。 详见：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#c-api-function-overview
http://dev.mysql.com/doc/refman/5.0/en/c.html 参考技术B C语言连接mysql数据库，需要相应的头文件和lib文件，如果你安装Mysql数据库，会在安装目录下找到这些库文件，如果没有安装，也可以在网上找到
我这里也有一份网上找到的：/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连接，并
返回一个值，返回不为空证明连接是成功的*/ 参考技术C 你可以去查一下odbc接口用这个比较方便