一、在你的程序中使用数据库是不错的注意。如果已经有可用的MySQL服务器,在VC中可以按照如下方法实现与数据库的连接。

1、找来MySQL(Win32)安装目录下的include文件夹,将其添加到VC头文件目录列表中;

(VC6 -> Options -> Directories -> 加入此目录)

(VC2005

-> 工具 -> 选择 ->项目和解决方案 -> VC++目录 -> 显示以下內容的目录 -> 包含文件

-> 加入此目录)2、找来MySQL(Win32)安装目录下的lib文件夹,将 其添加到VC库文件目录列表中;

(VC6 -> Options -> Directories -> 加入此目录)

(VC2005 -> 工具 ->选择 -> 项目和解決方案 -> VC++目录 -> 显示以下內容的目录 -> 库文件 -> 加入此目录,注意是lib\debug或lib\opt)

3、新建一个工程,参考如下代码:

// mysql.cpp : Defines the entry point for the console application.

#include "stdafx.h"

#include

#include

#include

#include

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

int main(int argc, char* argv[])

{

unsigned short Port = 3306;

char *IPAddress = "192.168.31.56";

char *UserName = "root";

char *Password = "";

char *DBName = "SAS_1_2_0";

printf("Start… ");

MYSQL *ssock;

//char execsql[500];

ssock = (MYSQL *)malloc(sizeof(MYSQL));

//在某些版本中,不需要该初始化工作,可观看mysql.H以及readme

mysql_init(ssock);

if(ssock == NULL)

{

printf("EROR: MySQL ssock init error. ");

return FALSE;

}

//连接到指定的数据库

ssock = mysql_real_connect(ssock, IPAddress, UserName, Password, NULL, Port, NULL, 0);

if(!ssock)

{

printf("conn fail… ");

//memcpy(eee, mysql_error(ssock), 20);

//fprintf(stderr, "Failed to connect to database: Error: %s ", mysql_error(ssock));

//printf("%c ", eee);

unsigned int mtint = mysql_errno(ssock);

//printf("%d ");

return FALSE;

}

if(mysql_select_db(ssock, DBName) != 0)

{

printf("select db error. ");

return FALSE;

}

printf("version=%d ", mysql_get_server_version(ssock));

//exec my execsql string

//sprintf(execsql,"create table girls (name char(10),age int)");

//mysql_real_query(ssock,execsql,strlen(execsql));

mysql_close(ssock);

printf("End… ");

return TRUE;

}

二、怎样用c/c++编程连接mysql数据库

执行一个查询有以下几个步骤要做。首先执行一个查询,然后保存结果,

得到的是一个子集。这里是一个小例子:

#include   

#include

#include  

MYSQL   mysql;

MYSQL_RES   *res;

MYSQL_ROW   row;

void   exiterr(int   exitcode)

{

fprintf(   stderr,   "%s\n",   mysql_error(&mysql)   );

exit(   exitcode   );

}

int   main()

{

uint   i   =   0;

if   (!(mysql_connect(&mysql,"host","username","password")))

exiterr(1);

if   (mysql_select_db(&mysql,"payroll"))

exiterr(2);

if   (mysql_query(&mysql,"SELECT   name,rate   FROM   emp_master"))

exiterr(3);

if   (!(res   =   mysql_store_result(&mysql)))

exiterr(4);

while((row   =   mysql_fetch_row(res)))   {

for   (i=0   ;   i  

printf("%s\n",row[i]);

}

mysql_free_result(res);

mysql_close(&mysql);

}

mysql_query   函数将把查询送给服务器,如果查询成功,调用mysql_store_result 函数将分配一个MYSQL_RES   结构并且重新从服务器获得一个结果集。

你可以用mysql_fetch_row   函数来查看数据。这样做你将获得一个   MYSQL_ROW   指针指向数据中的一行。   MYSQL_ROW   指针是一简单的字符串数组。所有的数据类型被转换成字符串送到客户端。

mysql_num_fields函数将告诉你返回的列数。你可以继续调用mysql_fetch_row直到它返回一个空指针以得到查询中的每一行。

注意在这个例子里,我们没有检查有空指针的列。如果你不使用非空列的表,那么你必须检查一个特殊行的列是否为空。一旦你使用完毕一个结果集,你必须释放它。这通过   mysql_free_result   来完成。

最后调用mysql_close来关闭你和数据库之间的连接。

查看结果集你可以不用调用mysql_fetch_row就查出返回的结果集共有多少行。这由

int   mysql_num_rows(MYSQL_RES   *result)来完成。

改变到被下一个   mysql_fetch_row   调用返回的行,你可以用void

mysql_data_seek(MYSQL_RES   *res,   uint   offset)   改变到任意一行。  获得更多的信息

你可以使用这几个额外的函数来找出关于一个查询的更多的信息,并从服务器获得这些信息。

如果你执行一个UPDATE,   INSERT   或者   DELETE   查询,你可以用int   mysql_affected_rows   来查出共有多少行数据被你影响到。

如果在你的数据库里有二进制数据,那么得知数据的长度将是有用的。unsigned  int   *mysql_fetch_lengths(MYSQL_RES   *mysql)   将返回一指出了结果集中每一列 的长度的整型数组。

当你插入一个带有   AUTO_INCREMENT   列的表的时候,你可以用int   mysql_insert_id(MYSQL   *mysql)   来查出生成的那一行的ID。

======================

int main()

{

MYSQL mysql;

MYSQL_RES * res ;

MYSQL_FIELD * fd ;

MYSQL_ROW row ;

int id[10000];

double result[10000][8];

vector v;

if(mysql_init(&mysql) == NULL)

{

std::cout<

return false;

}

else

{

std::cout<

}

if(NULL == mysql_real_connect(&mysql,"localhost","root","","wsnss",MYSQL_PORT,NULL,0))

{

std::cout<

return false;

}

else{

std::cout<

}

char   szSqlText[500]="";

int j = 0;

sprintf(szSqlText,"%s","select * from data_receive ");

if (mysql_query( &mysql, szSqlText))

//进行数据检索

{

//执行SQL语句出错

cout<

mysql_close( &mysql ) ;

return FALSE ;

}

else

{

res = mysql_store_result( &mysql ) ;

int i;

while((row   =   mysql_fetch_row(res)))   {

id[j] = atoi(row[0]);

for   (i = 1; i < mysql_num_fields(res); i++)

{

result[j][i-1] =  atof(row[i]);

}

j++;

}

}

for(int i = 0 ; i < 10000; i++)

{

if(i>=j)

break;

char str[10000];

stringstream ss;

ss<

data_receive(ID,data1,data2,data3, data4,data5,data6,data7,data8)values('"<

result[i][0]<

result[i][3]<

result[i][6]<

string s = ss.str();

v.push_back(s);

}

for(vector::iterator iter = v.begin();  iter != v.end(); ++iter)

{

if(mysql_query(&mysql,(*iter).c_str())!=0)

{

std::cout<

std::endl<

mysql_close(&mysql);

return 1;

}

}

mysql_free_result(res);

mysql_close(&mysql);

return 0;

}