VC连接MySql
VC连接MySql
一丶MySql 需要了解的知识
VC连接MySql 需要了解几个关键的API:
MYSQL * stdcall mysql init (MYSQL *mysql): 初始化一个数据库.如果传NULL.则返回一个数据库对象
mysql_real connect(); 与MySql 数据库创建连接
mySql_close() 关闭连接释放对象.如果自动分配的.也就是init传的NULL. 则自动释放.
mysql_select_db 选择一个数据库. 相当于sql语句 use database 数据库名
mysql_ query sql查询.
mysql_store_resul 如果调用来的sql查询.那么必须调用它.保存查询结果.并且返回这个数据库的结果集.
mysql_set_ character 等价于 set names 设置编码格式.
mysql _freeresult 释放结果集使用的内存.
二丶VS2015 配置库目录以及包含目录.使用MySql
1.要包含mysql的include目录.以及lib下的opt目录.
2.包含头文件 mysql.h 以及使用库 #pragma comment(lib,"libmysql.lib")
首先我们VS2015 打开项目属性.点击我们的VC++目录设置我们的包含目录以及库目录.
mysql是你安装的目录.include以及lib都在他的目录下. 你可以使用Everything 搜索一下Mysql 看看你的mysql放哪里了.
例如:
C:\Program Files (x86)\MySQL\MySQL Server 5.0\include\ 我的是在C盘.
c:xxxx\MySQL\mySql Server 5.0\lib\opt; 库目录
下图为设置.
包含我们的头文件
#include "mysql.h" #pragma comment(lib,"libmysql.lib")
如果编译出错.可能会显示socket的字样.那是因为mysql用了socket
我们还需要加载一个头文件.
#include <winsock2.h>
三丶数据库连接代码示例
我们可以下载一个MySql 手册. 可以查看 API 跟库.
我们常见的属性也列举出来了.
1.初始化跟连接数据库的代码
// 1.初始化MySql
MYSQL *pMySql;
pMySql = mysql_init(NULL); //因为我们不是new的自动创创建
if (NULL == pMySql)
{
AfxMessageBox(TEXT("数据库连接失败"));
return;
}
//2.与我们的数据库创建连接
/*
1.我们的MySql指针
2.我们数据库的IP地址
3.数据库用户名
4.数据库的用户密码.
5.db 为数据库名称
6.端口
7.linux下的.给NULL
8.协议
使用Show processlist; 可以查看数据库当前连接
*/
if (!mysql_real_connect(pMySql, LOCAL_HOST, "root", "123456", NULL, 3306, NULL, NULL))
{
AfxMessageBox(TEXT("数据库连接失败"));
return;
}调用mysql_real_connect 的时候.给定属性即可.
我们可以看下我们当前的连接 使用 show processlist;
可以看到.ID 为6的使我们的连接. 只不过数据库名字我们没有选中.我们可以设置选中
2.设置我们的数据库.
//3.设置我们的数据库
/*
1.我们的sql句柄
2.我们要选择的数据库的名称 use daatabse 数据库名
*/
mysql_select_db(pMySql, "newtest");
这样我们就会使用newtest这个数据库了.
三丶数据库的查询.获取结果集.提取结果集
这里总共分三步.
1.我们使用sql 语句查询结果.
2.查询完毕之后.我们还需要使用api.来接受这个结果.
3.结果里面很多东西.所以我们还要使用API 进行进一步的提取.
//4.查询.返回结果集. 提取结果集
/*
1.sql 句柄
2.查询语句
*/
if (!mysql_query(pMySql, "select *from stu"))
{
AfxMessageBox(TEXT("数据库查询失败"));
return;
}
//获取结果集
MYSQL_RES pres; //结果集结构体
pres = mysql_store_result(pMySql);
if (NULL ==pres)
{
AfxMessageBox(TEXT("获取结果集失败"));
return;
}
//提取结构
MYSQL_FIELD *fd;
//使用API获取,循环获取.不断获取.直到为0 遍历字段名
for (size_t i = 0; fd = mysql_fetch_field(pres); i++)
{
printf("%s", fd->name);//打印出字段名
}
//遍历字段中的数据.
// 结果集中有一个 rowcount 表示多少行数据.所以遍历
MYSQL_ROW row;
CString str;
while (row = mysql_fetch_row(pres));
{
//输出我们的字段
str = "";
str.Format(TEXT("字段1 %s 字段2 %s 字段3 %s"), row[0], row[1], row[2]);
AfxMessageBox(str);
}最后我们要关闭结果集.以及数据库连接
mysql_close();
mysql_free_result();
如果我们查询乱码.那么还需要设置我们的结果集.
mysql_set_character_set(数据库句柄,"gbk");
4.创建数据库
mysql_create_db():
具体函数可以查询参考手册