一、开发环境
ReadHat6.3 32位、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)); } }