mysql c API访问数据库_MySQL

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