C连接MySQL数据库开发之Linux环境完整示例演示（增、删、改、查_MySQL

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));
}}</mysql.h></string.h></stdlib.h></stdio.h>