bitscn.com
#include
#include cmysql.h
#include stdio.h
#define mysql_port 3306
void process_result_set(mysql mysql, mysql_res *result);
void exit(mysql mydata,char *ep);
int main(int argc, char * argv[]) {
 mysql mydata;
 database_param p;
 char queryname[600];
 mysql_res *result=null;
 int status =0;
 //初始化
 strcpy(p.host,127.0.0.1);
 strcpy(p.user,root);
 strcpy(p.password,root);
 strcpy(p.db,im);
 p.port = mysql_port;
 //初始化数据结构
 if(mysql_init(&mydata) == null)
 {
  printf(init mysql data stauct fail/n);
  system(pause);
  return -1;
 }
 //连接数据库
 if(argc == 1)
 {
  if(null == mysql_real_connect(&mydata,p.host,p.user,p.password,
   p.db,p.port,null,client_multi_statements))
  {
   printf(connect database fail,%s/n,mysql_error(&mydata));
   system(pause);
   return -1;
  }
 }
 else
 {
  printf(run parameter error/n);
  system(pause);
  return -1;
 }
 //首先设置字符集
 strcpy(queryname,set names gbkd);
 if(mysql_query(&mydata,set names gbk)!=0)
 {
  exit(mydata,set names fail);
  return -1;
 }
 //查询数据(支持单个字段和多个字段，输出排版)
 strcpy(queryname,show databases);
 if(mysql_query(&mydata,queryname) != 0)
 {
  exit(mydata,execute sql syntax fail);
  return -1;
 }
 //取得查询结果
 result= mysql_store_result(&mydata);
 process_result_set(mydata,result);
 //处理多条插入语句，在mysql_real_connect(......)函数里的最后一个参数更改为：client_multi_statements
 strcpy(queryname,insert into fangl.admin(username,password) values('fangl1','fangl1'),('fangl2','fangl2'),('fangl3','fangl3');/
 insert into fangl.admin(username,password) values('fl1','fl1'),('fl2','fl2'),('fl3','fl3');/
 insert into fangl.admin(username,password) values('fal1','fal1'),('fal2','fal2'),('fal3','fal3');/
 select * from fangl.admin);
 if(mysql_query(&mydata,queryname)!=0)
 {
  exit(mydata,insert values fail);
  return -1;
 }
 do {
  /* did current statement return data? */
  result = mysql_store_result(&mydata);
  if (result)
  {
   /* yes; process rows and free the result set */
   process_result_set(mydata, result);
   mysql_free_result(result);
  }
  else          /* no result set or error */
  {
   if (mysql_field_count(&mydata) == 0)
   {
    printf(%lld rows affected/n,
     mysql_affected_rows(&mydata));
   }
   else  /* some error occurred */
   {
    printf(could not retrieve result set/n);
    break;
   }
  }
  /* more results? -1 = no, >0 = error, 0 = yes (keep looping) */
  if ((status = mysql_next_result(&mydata)) > 0)
   printf(could not execute statement/n);
 } while (status == 0);
 //删除表中的数据
 strcpy(queryname,delete from fangl.admin where username='fl1');
 if(mysql_query(&mydata,queryname) != 0)
 {
  exit(mydata,execute sql syntax fail);
  return -1;
 }
 //查询数据(支持单个字段和多个字段，输出排版)
 strcpy(queryname,select * from fangl.admin);
 if(mysql_query(&mydata,queryname) != 0)
 {
  return -1;
 }
 //取得查询结果
 result= mysql_store_result(&mydata);
 process_result_set(mydata,result);
//释放结果
 if(result != null)
 {
  mysql_free_result(result);
 }
 mysql_close(&mydata);
 system(pause);
 return 1;
}
void process_result_set(mysql mydata, mysql_res *result)
{
 int rowcount = mysql_num_rows(result);       //查询结果有多少行
 //取得各字段名
 mysql_field *fields = null;
 for(int i=0;fields=mysql_fetch_field(result);i++)
 {
  printf(%s ,fields->name);
 }
 printf(/n);
 //依次读取各条记录
 mysql_row currow = null;
 while((currow = mysql_fetch_row(result)) != null)
 {
  for(int i = 0; i
  {
   printf(%s ,currow[i]?currow[i]:null);
  }
  printf(/n);
 }
}
void exit(mysql mydata,char *ep)
{
 mysql_close(&mydata);
 printf(%s,%s/n,ep,mysql_error(&mydata));
 system(pause);
}
以上是在vs 2008下编译并验证无误的，若有问题大家一起讨论，哈
本文出自 “lynn” 博客
bitscn.com