学步园

在VC6中使用c API方式连接MySQL数据库

一、环境配置
1、在MySql的官方网站下载mysql-connector-c-noinstall，并将解压后的bin和include文件夹拷贝到Mysql的安装目录
2、设置VC6环境，在vc工具-选项-目录，加入刚才的Include文件夹的路径，例如：C:/Program Files/MySQL/MySQL Server 5.1/include

二、工程设置
3、将lib文件夹中的linmysql.lib和libmysql.dll拷贝到工程目录下，工程-设置-连接，在对象/库模块中添加wsock32.lib和libmysql.lib

三、示例
4、先导入测试程序所需的环境，将以下SQL语句保存为sql脚本文件并导入
#VC6通过API连接Mysql测试环境
#创建数据库
drop database if exists `test`;     #如果有这个数据库，则移除它 create database test;               #创建数据库
use test;           #使用数据库
#创建表User，保存会员属性
drop table if exists `User`;
create table User (
    id int(11) not null auto_increment,
    name varchar(20),
    age int(11),
    primary key (id)
);
#插入一些数据
insert into user values (NULL, 'name1', 11);
insert into user values (NULL, 'name2', 22);
insert into user values (NULL, 'name3', 33);

5、测试代码

#include <windows.h><br /> #include <mysql.h><br /> #include "stdio.h"</p> <p>MYSQL mysql, *sock; //mysql连接<br /> MYSQL_RES *res; //这个结构代表返回行的一个查询结果集<br /> MYSQL_ROW row; //一个行数据的类型安全(type-safe)的表示<br /> char query[150]; //查询语句</p> <p>bool ConnectDatabase(); //函数声明<br /> void FreeConnect();<br /> bool QueryDatabase();<br /> bool InsertData();</p> <p>int main()<br /> {<br /> ConnectDatabase();<br /> QueryDatabase();<br /> InsertData();<br /> QueryDatabase();<br /> FreeConnect();</p> <p> return 0;<br /> }</p> <p>//连接数据库<br /> bool ConnectDatabase()<br /> {<br /> //初始化mysql<br /> mysql_init(&mysql); //连接mysql，数据库</p> <p> if (!(sock = mysql_real_connect(&mysql,"localhost", "root", "root", "test",0,NULL,0)))<br /> {<br /> printf( "Error connecting to database:%s/n",mysql_error(&mysql));<br /> return false;<br /> }<br /> else<br /> {<br /> printf("Connected.../n");<br /> return true;<br /> }<br /> }</p> <p>//释放资源<br /> void FreeConnect()<br /> {<br /> //释放资源<br /> mysql_free_result(res);<br /> mysql_close(sock);<br /> }</p> <p>//查询数据<br /> bool QueryDatabase()<br /> {<br /> sprintf(query, "select * from user"); //执行查询语句<br /> if(mysql_query(sock, query)) //执行SQL语句<br /> {<br /> printf("Query failed (%s)/n",mysql_error(sock));<br /> return false;<br /> }<br /> else<br /> {<br /> printf("query success/n");<br /> }</p> <p> //获取结果集<br /> if (!(res=mysql_store_result(sock))) //获得sql语句结束后返回的结果集<br /> {<br /> printf("Couldn't get result from %s/n", mysql_error(sock));<br /> return false;<br /> }</p> <p> //打印结果数<br /> printf("number of fields returned: %d/n",mysql_affected_rows(sock));</p> <p> //获取字段的信息<br /> printf("|/t%s/t|/t%s/t|/t%s/t|/n", mysql_fetch_field(res)->name, //打印各字段名<br /> mysql_fetch_field(res)->name,mysql_fetch_field(res)->name);</p> <p> //打印获取的数据<br /> while (row = mysql_fetch_row(res)) //获取下一行<br /> {<br /> printf("|/t%s/t|/t%s/t|/t%s/t|/n", row[0], row[1], row[2]);<br /> }<br /> return true;<br /> }</p> <p>//插入数据<br /> bool InsertData()<br /> {<br /> sprintf(query, "insert into user values (NULL, 'name4', 44);");<br /> if(mysql_query(sock, query)) //执行SQL语句<br /> {<br /> printf("Query failed (%s)/n",mysql_error(sock));<br /> return false;<br /> }<br /> else<br /> {<br /> printf("Insert success/n");<br /> return true;<br /> }<br /> }<br />