基于Win32工程C++连接MySQL数据库

1、MySQL简要介绍

MySQL是一个小型关系型数据库管理系统,它由 MySQL AB开发、发布和支持。MySQL是一个快速的、多线程、多用户和健壮的SQL数据库服务器。MySQL服务器支持关键任务、重负载生产系统的使用，也可以将它嵌入到一个大配置(mass- deployed)的软件中去。MySQL的特点是：

• 面向集合的操作方式
• 开源代码
• 高度非过程化
• 以一种语法结构提供多种使用方式
• 语言简洁，易用易学。

2、MySQL下载

• 官网下载： https://dev.mysql.com/downloads/mysql/

本文示例源码工程中已集成mysql.h、libmysql.lib、libmysql.dll，有需要的可在文末下载。

3、C++连接MySQL

首先将本文示例中用到的数据库文件world.sql导入到数据库中，文件在可执行目录下：

C++连接MySQL:

#include "stdafx.h"
#include <iostream>
#include <Windows.h>
#include "include\mysql\mysql.h"
#include <string>
using namespace std;

int _tmain(int argc, _TCHAR* argv[])
{
	// 定义基本信息
	MYSQL mydata;
	char server[] = "localhost";
	char user[] = "root";
	char password[] = "123456";
	char database[] = "world";
	int port = 3306;

	// 初始化数据库
	if (0 != mysql_library_init(0, NULL, NULL))
	{
		cout << "mysql_library_init() failed" << endl;
		return  -1;
	}

	// 初始化数据结构
	if (NULL == mysql_init(&mydata))
	{
		cout << "mysql_init() failed" << endl;
		return -1;
	}

	// 在连接数据库之前，设置额外的连接选项
	// 可以设置的选项很多，这里设置字符集，否则无法处理中文
	if (0 != mysql_options(&mydata, MYSQL_SET_CHARSET_NAME, "gbk"))
	{
		cout << "mysql_options() failed" << endl;
		return -1;
	}

	// 连接数据库
	if (NULL == mysql_real_connect(&mydata, server, user, password, database, port, NULL, 0))
	{
		cout << "mysql_real_connect() failed" << endl;
		return -1;
	}

	// sql字符串
	string sqlstr;
	// 创建一个表
	sqlstr = "CREATE TABLE IF NOT EXISTS `new_paper` (";
	sqlstr += " `NewID` int(11) NOT NULL AUTO_INCREMENT,";
	sqlstr += " `NewCaption` varchar(40) NOT NULL,";
	sqlstr += " `NewContent` text,";
	sqlstr += " `NewTime` datetime DEFAULT NULL,";
	sqlstr += " PRIMARY KEY(`NewID`)";
	sqlstr += " ) ENGINE = InnoDB DEFAULT CHARSET = utf8";

	if (0 != mysql_query(&mydata, sqlstr.c_str())) {
		cout << "mysql_query() create table failed" << endl;
		mysql_close(&mydata);
		return -1;
	}

	// 向表中插入数据
	for (int i = 0; i < 10; i++)
	{
		sqlstr = "INSERT INTO `world`.`new_paper` (`NewID`, `NewCaption`, `NewContent`, `NewTime`) ";
		sqlstr += "VALUES (default, '组织者', '组织方提出更换骨灰存放', '2015-09-01 14:29:51');";
		if (0 != mysql_query(&mydata, sqlstr.c_str())) {
			cout << "mysql_query() insert data failed" << endl;
			mysql_close(&mydata);
			return -1;
		}
	}

	// 显示刚才插入的数据
	sqlstr = "SELECT `NewID`,`NewCaption`,`NewContent`,`NewTime` FROM `world`.`new_paper`";
	MYSQL_RES *result = NULL;
	if (0 == mysql_query(&mydata, sqlstr.c_str())) {
		// 一次性取得数据集
		result = mysql_store_result(&mydata);
		// 取得并打印行数
		int rowcount = mysql_num_rows(result);
		cout << "row count: " << rowcount << endl;

		// 取得并打印各字段的名称
		unsigned int fieldcount = mysql_num_fields(result); MYSQL_FIELD *field = NULL;
		for (unsigned int i = 0; i < fieldcount; i++)
		{
			field = mysql_fetch_field_direct(result, i);
			cout << field->name << "\t\t";
		}
		cout << endl;

		// 打印各行
		MYSQL_ROW row = NULL;
		row = mysql_fetch_row(result);
		while (NULL != row)
		{
			for (int i = 0; i < fieldcount; i++)
			{
				cout << row[i] << "\t\t";
			}
			cout << endl;
			row = mysql_fetch_row(result);
		}
	}
	else {
		cout << "mysql_query() select data failed" << endl;
		mysql_close(&mydata);
		return -1;
	}

	// 删除刚才建的表
	sqlstr = "DROP TABLE `world`.`new_paper`";
	if (0 != mysql_query(&mydata, sqlstr.c_str())) {
		cout << "mysql_query() drop table failed" << endl;
		mysql_close(&mydata);
		return -1;
	}

	// 断开连接
	mysql_free_result(result);
	mysql_close(&mydata);
	mysql_server_end();

	system("pause");
	return 0;
}

运行结果：