VS2013通过MySQL方式连接到MySQL

MySQL官网上C++的API有两个。一个是很成熟的mysql++,另一个是MySQL Connector/C++,近两年才出的,模仿JDBC做的,封装得很方便使用。这里使用的是mysql方式。

1.新建bookAdminSys工程

2.将文件夹MySQL目录下的include添加到VC++目录中的包含目录中,另外将文件夹MySQL目录下的lib添加到VC++目录中的库目录中

3.添加附加依赖项,将MySQL目录下的libmysql.lib添加到Linker(链接器)——Input(输入)——Additional Dependencies(附加依赖项)中

4.修改工程运行平台 ,由于windows系统是64位的,故mysql也是64位的,而我们创建的工程是win32控制台程序,无法直接使用64位的libmysql.lib,所以要修改为x64

5.将MySQL目录中的libmysql.dll,libmysql.lib拷到所建工程的根目录下,并将libmysql.dll拷到system32和syswow64这两个系统文件夹下

6.从官方网站http://dev.mysql.com下载到mysql安装包并安装,安装完成后打开MySQL 5.6 Command Client窗口,如下图所示:

第1步:创建一个名为db_books的数据库;

第2步:创建完成数据库之后,使用use语句来改变当前的数据库;

第3步:使用create table语句来创建数据表。

使用mysql的图书管理系统源代码(在VS2013上已测试通过):

#include "stdafx.h"
#include <stdio.h>
#include <stdlib.h>
#include <conio.h>
#include <windows.h> //包含了其它window头文件,为mmysql.h服务,且必须声明在mysql.h前面
#include <mysql.h> //mysql数据库头文件 #pragma warning( disable : 4996) /*定义数据库相关操作变量*/
MYSQL mysql; //定义mysql对象
MYSQL_RES *result; //定义结果集变量
MYSQL_ROW row; //定义行变量
char ch[]; void ShowAll(); //显示所有的图书信息
void AddBook(); //添加图书信息
void ModifyBook(); //修改图书信息
void DeleteBook(); //删除图书信息
void QueryBook(); //查询图书信息 //显示菜单
void showmenu()
{
printf("\n\n\n\n\n");
printf("\t╔═══════════════════════════╗\n");
printf("\t║ Welcome To Lemon Books System ║\n");
printf("\t╠═══════════════════════════╣\n");
printf("\t║\t\t 1 - 显示所有图书信息 ║\n");
printf("\t║\t\t 2 - 添加图书信息 ║\n");
printf("\t║\t\t 3 - 修改图书信息 ║\n");
printf("\t║\t\t 4 - 删除图书信息 ║\n");
printf("\t║\t\t 5 - 查询图书信息 ║\n");
printf("\t║\t\t 6 - 退出 ║\n");
printf("\t╚═══════════════════════════╝\n");
printf("\n ENTER YOUR CHOICE(1-6):"); } void inquire() /*询问用户是否显示主菜单*/
{
printf("\t 显示主菜单?(y/n):");
scanf("%s", ch);
if (strcmp(ch, "Y") == || strcmp(ch, "y") == )/*判断是否要显示查找到的信息*/
{
showmenu(); /*显示菜单*/
}
else
{
exit();
}
} /*显示主菜单,连接数据库*/
int main()
{
int n; //定义变量 存储用户输入的编号 showmenu(); /*显示菜单*/ scanf("%d", &n);/*输入选择功能的编号*/ while (n)
{
mysql_init(&mysql); //初始化mysql结构 switch (n)
{
case :
ShowAll(); /*调用显示所有图书数据的过程*/
break;
case :
AddBook(); /*添加图书信息*/
break;
case :
ModifyBook(); /*修改图书信息*/
break;
case :
DeleteBook(); /*删除图书信息*/
break;
case :
QueryBook(); /*查询图书信息*/
break;
case :
exit(); /*退出*/
default:break;
}
system("PAUSE");
system("CLS");
inquire(); scanf("%d", &n);
}
} //显示所有的图书信息
void ShowAll()
{
//连接数据库
if (!mysql_real_connect(&mysql,"localhost","root","root","db_books",,NULL,)) //连接数据库成功,返回true
{
printf("连接数据库失败!\n");
}
else
{
//连接数据库成功
if (mysql_query(&mysql, "select * from db_books")) //查询数据表tb_books中的所有字段 查询成功,返回false
{
printf("\n 查询 tb_books 失败!\n"); //连接数据库失败
}
else
{
result = mysql_store_result(&mysql); //获得结果集
if (mysql_num_rows(result) != NULL) //获得结果集的行数,若行数不为0,则进入if
{
//有记录数据时,才显示记录数据
printf("\t ════════════════════════════ \n");
printf("\t 显 示 所 有 图 书 信 息 \n");
printf("\t ════════════════════════════ \n");
printf("\t 图书编号 图书名 作者 出版社 \n");
printf("\t -------------------------------------------------------- \n"); while (row = mysql_fetch_row(result)) //取出结果集中的下一行数据
{
//取出结果集中记录
fprintf(stdout, "\t %s %s %s %s \n", \
row[], row[], row[], row[]); //输出这行记录 [相当于从文件中取出数据,所以使用了fprintf]
}
printf("\t ════════════════════════════ \n");
}
else
{
printf("\n 没有记录数据! \n");
} mysql_free_result(result); //释放结果集
} mysql_close(&mysql); //释放连接
}
} void AddBook() /*添加图书信息*/
{
int rowcount; /*结果集中的行数*/ char id[]; /*编号*/
char *bookname; //图书名称
char *author; //图书作者
char *bookconcern; char *sql; //数据库字符串
char dest[] = { " " }; /*连接数据库*/
if (!mysql_real_connect(&mysql, "localhost", "root", "root", "db_books", , NULL, ))
{
printf("\n\t 不能连接数据库!\n");
}
else
{
/*数据库连接成功,插入数据*/
printf("\t ════════════════════════════ \n");
printf("\t 添 加 图 书 信 息 \n");
printf("\t ════════════════════════════ \n");
if (mysql_query(&mysql, "select * from db_books"))
{ //如果查询失败
printf("\n\t 查询 db_books 数据表失败!\n");
}
else
{
result = mysql_store_result(&mysql); //获得结果集
rowcount = (int)mysql_num_rows(result); //获得行数
row = mysql_fetch_row(result); //获取结果集的行 printf("\t 图书编号:");
scanf("%s", id); /*输入图书编号*/ if (mysql_num_rows(result) != NULL)
{
/*判断输入的编号是否存在*/
do
{ //存在相同编号
if (!strcmp(id, row[])) //row[0]为每行的第一个元素,即ID,则row[1]则为bookname
{
// printf("%s",row[0]);
printf("\n\t 记录存在,按任意键继续!\n");
getch();
mysql_free_result(result); /*释放结果集*/
mysql_close(&mysql); /*释放连接*/
return;
}
} while (row = mysql_fetch_row(result));
} //给字符指针分配内存
bookname = (char*)malloc();
author = (char*)malloc();
bookconcern = (char*)malloc(); //不存在相同的编号
printf("\t 请输入图书名:");
scanf("%s", bookname); /*输入图书名*/ //将要写入数据库的字符串添加到dest后
sql = "insert into db_books (ID,bookname,author,bookconcern) values (";
strcat(dest, sql);
strcat(dest, "'");
strcat(dest, id);
strcat(dest, "', '");
strcat(dest, bookname); /*将图书编号追加到sql语句后面*/ printf("\t 请输入作者:");
scanf("%s", author); /*输入作者*/
strcat(dest, "', '");
strcat(dest, author); printf("\t 请输入出版社:");
scanf("%s", bookconcern); /*输入出版社*/
strcat(dest, "', '");
strcat(dest, bookconcern);
strcat(dest, "')");
printf("%s",dest); if (mysql_query(&mysql, dest) != ) //将dest插入到数据库中(db_books)
{
fprintf(stderr, "\t 不能插入记录!", mysql_error(&mysql));
}
else
{
printf("\t 插入成功!\n");
}
mysql_free_result(result); //释放结果集
}
mysql_close(&mysql); //释放连接
}
} void QueryBook() /*查询图书信息*/
{
char id[]; /*结果集中的行数*/
char *sql;
char dest[] = { " " }; if (!mysql_real_connect(&mysql, "127.0.0.1", "root", "root", "db_books", , NULL, ))
{
printf("\t 不能连接数据库!\n");
}
else
{
printf("\t 请输入您想要查询的图书编号:");
scanf("%s", id); /*输入图书编号*/
sql = "select * from db_books where id="; //查询条件
strcat(dest, sql);
strcat(dest, id); /*将图书编号追加到sql语句后面*/ if (mysql_query(&mysql, dest))
{ //如果查询失败
printf("\n 查询 tb_book 数据表失败!\n");
}
else
{
result = mysql_store_result(&mysql); //获得结果集
if (mysql_num_rows(result) != NULL)
{ //有记录的情况,只有有记录取数据才有意义
printf("\t ════════════════════════════ \n");
printf("\t 显示图书信息 \n");
printf("\t ════════════════════════════ \n");
printf("\t图书编号 图书名 作者 出版社 \n");
printf("\t -------------------------------------------------------- \n");
while ((row = mysql_fetch_row(result)))
{ //取出结果集中记录
fprintf(stdout, "\t %s %s %s %s \n", row[], row[], row[], row[]); //输出这行记录
}
printf("\t ════════════════════════════ \n");
}
else
{
printf("\t 没有发现要查询的信息!\n");
}
mysql_free_result(result); //释放结果集
}
mysql_close(&mysql); //释放连接
}
} //修改图书信息
void ModifyBook()
{
char id[]; /*结果集中的行数*/
char *sql;
char dest[] = { " " };
char dest1[] = { " " }; char *bookname;
char *author;
char *bookconcern; if (!mysql_real_connect(&mysql, "127.0.0.1", "root", "root", "db_books", , NULL, ))
{
printf("\t 不能连接数据库!\n");
}
else
{
/*数据库连接成功*/
// printf("连接成功");
printf("\t 请输入您想要修改的图书编号."); scanf("%s", id); /*输入图书编号*/
sql = "select * from db_books where id=";
strcat(dest, sql);
strcat(dest, id); /*将图书编号追加到sql语句后面*/ //printf("%s\n",dest); /*查询该图书信息是否存在*/
if (mysql_query(&mysql, dest))
{ //如果查询失败
printf("\n 查询 db_books 数据表失败! \n");
}
else
{
result = mysql_store_result(&mysql); //获得结果集
if (mysql_num_rows(result) != NULL)
{
//有记录的情况,只有有记录取数据才有意义
printf("\t 发现记录信息,是否显示?(y/n) ");
scanf("%s", ch);
if (strcmp(ch, "Y") == || strcmp(ch, "y") == )/*判断是否要显示查找到的信息*/
{
printf("\t ════════════════════════════ \n");
printf("\t ***** 显示图书信息 ***** \n");
printf("\t ════════════════════════════ \n");
printf("\t图书编号 图书名 作者 出版社 \n");
printf("\t -------------------------------------------------------- \n");
while ((row = mysql_fetch_row(result)))
{ //取出结果集中记录
fprintf(stdout, "\t %s %s %s %s \n", row[], row[], row[], row[]); //输出这行记录
}
printf("\t ════════════════════════════ \n");
} printf("\t Modify?(y/n)");
scanf("%s", ch);
if (strcmp(ch, "Y") == || strcmp(ch, "y") == ) /*判断是否需要录入*/
{ sql = "update db_books set bookname= '";
strcat(dest1, sql);
// printf("%s",sql);
bookname = (char*)malloc();
author = (char*)malloc();
bookconcern = (char*)malloc(); printf("\t 图书名:");
scanf("%s", bookname); /*输入图书名*/ strcat(dest1, bookname);
// printf("%s",&bookname); printf("\t 作者:");
scanf("%s", author); /*输入作者*/
strcat(dest1, "', author= '");
strcat(dest1, author); /*追加sql语句*/ printf("\t 出版社:");
scanf("%s", bookconcern); /*输入出版社*/
strcat(dest1, "', bookconcern = '");
strcat(dest1, bookconcern); /*追加sql语句*/ strcat(dest1, "' where id= ");
strcat(dest1, id); //printf("%s",dest1); if (mysql_query(&mysql, dest1) != )
{
fprintf(stderr, "\t 不能修改记录!\n", mysql_error(&mysql));
}
else
{
printf("\t 修改成功!\n");
}
} }
else
{
printf("\t 没有发现要修改的信息!\n");
}
}
mysql_free_result(result); //释放结果集
}
mysql_close(&mysql); //释放连接
} void DeleteBook() /*删除图书信息*/
{
char id[]; /*结果集中的行数*/
char *sql;
char dest[] = { " " };
char dest1[] = { " " };
if (!mysql_real_connect(&mysql, "127.0.0.1", "root", "root", "db_books", , NULL, ))
{
printf("\t 不能连接数据库!\n");
}
else
{
printf("\t 请输入您想要删除的图书编号. ");
scanf("%s", id); /*输入图书编号*/
sql = "select * from tb_book where id=";
strcat(dest, sql);
strcat(dest, id); /*将图书编号追加到sql语句后面*/
//printf("%s\n",dest); /*查询该图书信息是否存在*/
if (mysql_query(&mysql, dest))
{ //如果查询失败
printf("\n 查询 tb_book 数据表失败! \n");
}
else
{
result = mysql_store_result(&mysql); //获得结果集
if (mysql_num_rows(result) != NULL)
{ //有记录的情况,只有有记录取数据才有意义
printf("\t 发现记录信息,是否显示?(y/n) ");
scanf("%s", ch);
if (strcmp(ch, "Y") == || strcmp(ch, "y") == )/*判断是否要显示查找到的信息*/
{
printf("\t ════════════════════════════ \n");
printf("\t ***** 显示图书信息 ***** \n");
printf("\t ════════════════════════════ \n");
printf("\t图书编号 图书名 作者 出版社 \n");
printf("\t -------------------------------------------------------- \n");
while ((row = mysql_fetch_row(result)))
{ //取出结果集中记录
fprintf(stdout, "\t %s %s %s %s \n", row[], row[], row[], row[]); //输出这行记录
}
printf("\t ════════════════════════════ \n");
} printf("\t 是否删除?(y/n) ");
scanf("%s", ch);
if (strcmp(ch, "Y") == || strcmp(ch, "y") == ) /*判断是否需要录入*/
{
sql = "delete from tb_book where ID= ";
printf("%s", dest1);
strcat(dest1, sql);
strcat(dest1, id);
// printf("%s",dest1); if (mysql_query(&mysql, dest1) != )
{
fprintf(stderr, "\t 不能删除记录! \n", mysql_error(&mysql));
}
else
{
printf("\t 删除成功!\n");
}
}
}
else
{
printf("\t 没有发现要删除的信息!\n");
}
}
mysql_free_result(result); //释放结果集
}
mysql_close(&mysql);
}

显示效果:

MySQL工具:MySQL Workbench

最新文章

  1. IOS开发遇到(null)与&lt;null&gt;轻松处理
  2. jquery 页面滚动到底部自动加载插件集合
  3. [大数据之Sqoop] —— 什么是Sqoop?
  4. JS闭包导致循环给按钮添加事件时总是执行最后一个
  5. ORA-01017 invalid username/password;logon denied&quot; (密码丢失解决方案)
  6. IIS启用.net2.0
  7. java 获取数组(二维数组)长度实例程序
  8. percona-toolkit工具检查MySQL复制一致性及修复
  9. POST 方式上传图片
  10. poj 2723 二分+2-sat判定
  11. 基于8211lib库对s57电子海图的解析和存储
  12. 浅谈Java线程安全
  13. 利用Team@OSC进行团队协作开发平台
  14. 【Linux基础】history查看历史命令
  15. zabbix系列(四)Zabbix3.0.4添加对Nginx服务的监控
  16. OpenGL中各种坐标系的理解
  17. 部署OpenStack问题汇总(五)--openstack中删除虚拟主机,状态一直未deleting
  18. Currency Exchange 货币兑换 Bellman-Ford SPFA 判正权回路
  19. 安装使用ionic3
  20. notepad++中配置python运行命令

热门文章

  1. [luoguP1015] 回文数(模拟 + 高精度?)
  2. android开发里跳过的坑——“org.apache.http.message.BasicHeaderValueFormatter.INSTANCE”错误
  3. [TJOI2010]中位数
  4. 【NOIP2016】蚯蚓(单调队列)
  5. MVC view页面需要多个model,复杂网页的处理
  6. B - Euler theorem 数学
  7. Apache 使用localhost(127.0.0.1)可以访问,使用本机IP(局域网)不能访问
  8. 2017-10-03-afternoon
  9. Java并发包——线程池
  10. Open Flash Chart IO ERROR Loading test data Error #2032