一、开发环境
ReadHat6.332位、mysql5.6.15、gcc4.4.6
二、编译
gcc-I/usr/include/mysql-L/usr/lib-lmysqlclient main.c -o main.out
-I：指定mysql头文件所在目录（默认去/usr/include目录下寻找所用到的头文件）
-L：指定mysql动态库文件所在目录（默认从/usr/lib目录查找）
-l：链接libmysqlclient.so动态库
-o：生成的可执行文件名
三、完整示例
////main.c//mysql数据库编程////Created by YangXin on 14-5-22.//Copyright (c) 2014年 yangxin. All rights reserved.//#include <stdio.h>#include <stdlib.h>#include <string.h>#include <mysql.h>MYSQL mysql;// 查询int query();// 修改int update();// 添加数据my_ulonglong add();// 参数化添加数据my_ulonglong addByParams();// 删除数据my_ulonglong delete();// 打印数据库服务器信息void printMySqlInfo();int main(int argc, const char * argv[]){ /*连接之前，先用mysql_init初始化MYSQL连接句柄*/ mysql_init(&mysql); /*使用mysql_real_connect连接服务器,其参数依次为MYSQL句柄，服务器IP地址， 登录mysql的用户名，密码，要连接的数据库等*/ if(!mysql_real_connect(&mysql, "localhost", "root", "yangxin", "test", 0, NULL, 0)) { printf("connecting to Mysql error:%d from %s/n",mysql_errno(&mysql), mysql_error(&mysql)); return -1; }else { printf("Connected Mysql successful!/n"); } printMySqlInfo(); // 设置编码 mysql_query(&mysql, "set names utf8"); // 参数化添加数据 addByParams(); // 查询 query(); // 修改 update(); // 添加 add(); // 删除 delete(); /*关闭连接*/ mysql_close(&mysql); return 0;}// 查询int query(){ int flag, i; const char *sql = NULL; MYSQL_RES *res = NULL; MYSQL_ROW row = NULL; MYSQL_FIELD *fields = NULL; sql = "select * from t_user" ; flag = mysql_real_query(&mysql, sql, (unsigned int)strlen(sql)); if (flag) { printf("query error:%d from %s/n",mysql_errno(&mysql),mysql_error(&mysql)); return -1; } // 将查询结果读取到内存当中，如果数据很多的情况会比较耗内存 res = mysql_store_result(&mysql); // res = mysql_use_result(&mysql); // 需要用到的时候，每次从服务器中读取一行 // 字段数量 unsigned int field_count = mysql_field_count(&mysql); printf("field_cout:%d/n",field_count); // 查询总数 my_ulonglong rows = mysql_num_rows(res); printf("%lld/n",rows); // 获取所有字段 fields = mysql_fetch_fields(res); for (int i = 0; i < mysql_num_fields(res); i++) { printf("%s/t", fields[i].name); } printf("/n"); // 遍历结果集 while((row = mysql_fetch_row(res))) { for (i = 0; i < mysql_num_fields(res); i++) { printf("%s/t",row[i]); } printf("/n"); } // 释放结果集 mysql_free_result(res); return 0;}// 修改int update(){ const char *sql = NULL; int flag = -1; sql = "update t_user set name='lisi',age=20 where id=1"; // 执行SQL指令 flag = mysql_real_query(&mysql, sql, (unsigned int)strlen(sql)); if (flag) { printf("update data error:%d from %s/n",mysql_errno(&mysql),mysql_error(&mysql)); return-1; } printf("update success./n"); return 0;}// 添加my_ulonglong add(){ const char *sql = NULL; int flag = -1; sql = "insert into t_user(name,age,address) values ('zhangsan',40,'beijing')"; // 执行 flag = mysql_real_query(&mysql, sql, strlen(sql)); if (flag) { printf("add data error:%d from %s/n",mysql_errno(&mysql),mysql_error(&mysql)); return -1; } // 删除的行数 my_ulonglong affected_rows = mysql_affected_rows(&mysql); // 新添加记录的ID my_ulonglong newid = mysql_insert_id(&mysql); printf("success add %lld record data, newid:%lld!/n",affected_rows,newid); return newid;}// 参数化添加my_ulonglong addByParams(){ const char *sql = NULL; MYSQL_STMT *stmt = NULL; MYSQL_BIND bnd[3];// 占位符参数数量 memset(&bnd, 0, sizeof(bnd)); // 设置手动提交事务 //mysql_autocommit(&mysql, 0); // 通过参数占位符的方式执行SQL sql = "insert into t_user(name,age,address) values (?,?,?)"; stmt = mysql_stmt_init(&mysql); // 预处理SQL if(mysql_stmt_prepare(stmt, sql, (unsigned int)strlen(sql))) { fprintf(stderr, "mysql_stmt_prepare faild:%d from %s/n", mysql_stmt_errno(stmt),mysql_stmt_error(stmt)); return -1; } // 封装占位符数据 const char *name = "hanzhiqiang"; bnd[0].buffer = (void *)name; bnd[0].buffer_type = MYSQL_TYPE_STRING; bnd[0].buffer_length = strlen(name); int age = 30; bnd[1].buffer = (void *)&age; bnd[1].buffer_length = sizeof(int); bnd[1].buffer_type = MYSQL_TYPE_LONG; const char *addres = "heimuer"; bnd[2].buffer = (void *)addres; bnd[2].buffer_length = strlen(addres); bnd[2].buffer_type = MYSQL_TYPE_STRING; // 绑定占位符参数值 if(mysql_stmt_bind_param(stmt, bnd)) { fprintf(stderr, "mysql_stmt_bind_param faild:%d from %s/n",mysql_errno(&mysql), mysql_error(&mysql)); return -2; } // 执行SQL if (mysql_stmt_execute(stmt)) { fprintf(stderr, "mysql_stmt_execute faild:%d from %s/n", mysql_errno(&mysql), mysql_error(&mysql)); return -3; } // 关闭statement mysql_stmt_close(stmt); // 提交事务 //mysql_commit(&mysql); // 事务回滚（在提交事务前）执行 // mysql_rollback(&mysql); // 获取插入数据后，数据库受影响的记录数 my_ulonglong newid = mysql_stmt_insert_id(stmt); printf("参数化语句插入新记录的id: %lld/n",newid); // 受影响的行数 my_ulonglong affectedrows = mysql_stmt_affected_rows(stmt); printf("参数化语句插入受影响的行数：%lld/n",affectedrows); return newid;}my_ulonglong delete(){ const char *sql = NULL; int flag = -1; sql = "delete from t_user where id > 10"; flag = mysql_real_query(&mysql, sql, strlen(sql)); if (flag) { printf("delete data error:%d from %s/n",mysql_errno(&mysql), mysql_error(&mysql)); return -1; } my_ulonglong affected_rows = mysql_affected_rows(&mysql); printf("删除的行数：%lld/n",affected_rows); printf("success delete %lld record data !/n",affected_rows); return affected_rows;}void printMySqlInfo(){ const char *stat = mysql_stat(&mysql); const char *server_info = mysql_get_server_info(&mysql); const char *clientInfo = mysql_get_client_info(); unsigned long version = mysql_get_client_version(); const char *hostinfo = mysql_get_host_info(&mysql); unsigned long serverversion = mysql_get_server_version(&mysql); unsigned int protoinfo = mysql_get_proto_info(&mysql); printf("stat：%s/n",stat); printf("server_info：%s/n",server_info); printf("clientInfo：%s/n",clientInfo); printf("version：%ld/n",version); printf("hostinfo：%s/n",hostinfo); printf("serverversion：%ld/n",serverversion); printf("protoinfo：%d/n",protoinfo); const char *charactername = mysql_character_set_name(&mysql); printf("client character set：%s/n",charactername); if (!mysql_set_character_set(&mysql, "utf8")) { printf("New client character set: %s/n", mysql_character_set_name(&mysql)); }}
