Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1698316
  • 博文数量: 210
  • 博客积分: 10013
  • 博客等级: 上将
  • 技术积分: 2322
  • 用 户 组: 普通用户
  • 注册时间: 2008-09-25 15:56
文章分类

全部博文(210)

文章存档

2011年(34)

2010年(121)

2009年(37)

2008年(18)

我的朋友

分类: Mysql/postgreSQL

2009-05-16 19:43:13

//下面的代码是一个实现c++连接MYSQL数据库的很好的例子
//
这里用了建表,插入,检索,删表等常用功能
//
我用vs生成,已经成功连接了。
//
Vs中要想把做一下两步准备工作才可以。
//
工具-》选项-》项目解决方案-Vc++目录-》显示以下内容的目录-》包含文件-》下面添加:include文件夹

//工具-》选项-》项目解决方案-Vc++目录-》显示以下内容的目录-》引用文件-》下面添加:lib下面的debug文件夹(或者opt

//工具-》选项-》项目解决方案-Vc++目录-》显示以下内容的目录-》库文件-》下面添加:lib下面的debug文件夹(或者opt
//
其实就是将头文件和库文件包含进来
//
我觉得这个例子写的很好,再结合自己的试验,特地介绍给大家!

#include

#include

#include

#include

using namespace std;

 

#pragma comment(lib, "ws2_32.lib")

#pragma comment(lib, "libmysql.lib")

 

//单步执行,不想单步执行就注释掉

//#define STEPBYSTEP

 

int main()

{

 cout<<"****************************************"<

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //必备的一个数据结构

 MYSQL mydata;

 

 //初始化数据库

 if(0==mysql_library_init(0,NULL,NULL))

 {

  cout<<"mysql_library_init() succeed"<

 }

 else

 {

  cout<<"mysql_library_init() failed"<

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //初始化数据结构

 if(NULL!=mysql_init(&mydata))

 {

  cout<<"mysql_init() succeed"<

 }

 else

 {

  cout<<"mysql_init() failed"<

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //在连接数据库之前,设置额外的连接选项

 //可以设置的选项很多,这里设置字符集,否则无法处理中文

 if(0==mysql_options(&mydata,MYSQL_SET_CHARSET_NAME,"gbk"))

 {

  cout<<"mysql_options() succeed"<

 }

 else

 {

  cout<<"mysql_options() failed"<

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //连接数据库

 if(NULL!=mysql_real_connect(&mydata,"localhost","root","","medicine",3306,NULL,0))

 //这里的地址,用户名,密码,端口可以根据自己本地的情况更改

 {

  cout<<"mysql_real_connect() succeed"<

 }

 else

 {

  cout<<"mysql_real_connect() failed"<

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //sql字符串

 string sqlstr;

 

 //创建一个表

 sqlstr ="CREATE TABLE IF NOT EXISTS user_info";

 sqlstr+="(";

 sqlstr+="user_id INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'Unique User ID',";

 sqlstr+="user_name VARCHAR(100) CHARACTER SET gb2312 COLLATE gb2312_chinese_ci NULL COMMENT 'Name Of User',";

 sqlstr+="user_second_sum INT UNSIGNED NOT NULL DEFAULT 0 COMMENT 'The Summation Of Using Time'";

 sqlstr+=");";

 if(0==mysql_query(&mydata,sqlstr.c_str()))

 {

  cout<<"mysql_query() create table succeed"<

 }

 else

 {

  cout<<"mysql_query() create table failed"<

  mysql_close(&mydata);

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //向表中插入数据

 sqlstr ="INSERT INTO user_info(user_name) VALUES('公司名称'),('一级部门'),('二级部门'),('开发小组'),('姓名');";

 if(0==mysql_query(&mydata,sqlstr.c_str()))

 {

  cout<<"mysql_query() insert data succeed"<

 }

 else

 {

  cout<<"mysql_query() insert data failed"<

  mysql_close(&mydata);

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //显示刚才插入的数据

 sqlstr="SELECT user_id,user_name,user_second_sum FROM user_info";

 MYSQL_RES *result=NULL;

 if(0==mysql_query(&mydata,sqlstr.c_str()))

 {

  cout<<"mysql_query() select data succeed"<

 

  //一次性取得数据集

  result=mysql_store_result(&mydata);

  //取得并打印行数

  int rowcount=mysql_num_rows(result);

  cout<<"row count: "<

 

  //取得并打印各字段的名称

  unsigned int fieldcount=mysql_num_fields(result);

  MYSQL_FIELD *field=NULL;

  for(unsigned int i=0;i

  {

   field=mysql_fetch_field_direct(result,i);

   cout<name<<"\t\t";

  }

  cout<

 

  //打印各行

  MYSQL_ROW row=NULL;

  row=mysql_fetch_row(result);

  while(NULL!=row)

  {

   for(int i=0; i

   {

    cout<

   }

   cout<

   row=mysql_fetch_row(result);

  }

 

 }

 else

 {

  cout<<"mysql_query() select data failed"<

  mysql_close(&mydata);

  return -1;

 }

 

#ifdef STEPBYSTEP

 system("pause");

#endif

 

 //删除刚才建的表

 sqlstr="DROP TABLE user_info";

 if(0==mysql_query(&mydata,sqlstr.c_str()))

 {

  cout<<"mysql_query() drop table succeed"<

 }

 else

 {

  cout<<"mysql_query() drop table failed"<

  mysql_close(&mydata) ;

  return -1;

 }

 mysql_free_result(result);

 mysql_close(&mydata);

 mysql_server_end();

 

 system("pause");

 return 0;

}

 

 

阅读(5171) | 评论(2) | 转发(0) |
给主人留下些什么吧!~~

chinaunix网友2010-07-12 08:43:19

你的前提工作做好了吗?就是 //工具-》选项-》项目解决方案-》Vc++目录-》显示以下内容的目录-》包含文件-》下面添加:include文件夹 //工具-》选项-》项目解决方案-》Vc++目录-》显示以下内容的目录-》引用文件-》下面添加:lib下面的debug文件夹(或者opt) //工具-》选项-》项目解决方案-》Vc++目录-》显示以下内容的目录-》库文件-》下面添加:lib下面的debug文件夹(或者opt)

chinaunix网友2010-07-11 16:32:02

lz你好,看了你教程,实际编译的时候会出现个错误,就是无法发开mysql.h 我分别在两台不同的电脑上实验,都遇到同样的问题,希望lz能够帮助解答一下