MySQL MYSQL_ROW http://www.cnblogs.com/cy163/archive/2009/04/24/1442859.html

MySQL MYSQL_ROW 返回的字段若是 float 如何在 C++程序中 把 字段值赋给 一个 float变量

cy163注： 文中此句“MYSQL_ROW 指针是一简单的字符串数组。所有的数据类型被转换成字符串送到客户端。”很有意义。 另外，从文章了解到需要使用 atoi() 和atof()将
MYSQL_ROW 字符串中对应int 和 float的值转变为 整型值 和 浮点值。

一、在你的程序中使用数据库是不错的注意。如果已经有可用的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 <stdio.h>

#include <winsock.h>

#include <mysql.h>

#include <windows.h>

#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 <stdio.h>

#include

#include <mysql.h>

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 < mysql_num_fields(res); 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<string> v;
if(mysql_init(&mysql) == NULL)

{

std::cout<<"init mysql data status fail"<<std::endl;

return false;

}

else

{

std::cout<<"init mysql data status success"<<std::endl;

}

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

{

std::cout<<"connect database fail"<<std::endl<<mysql_error(&mysql)<<std::endl;;

return false;

}

else{

std::cout<<"connect database success"<<std::endl;

}
char szSqlText[500]="";

int j = 0;
sprintf(szSqlText,"%s","select * from data_receive ");

if (mysql_query( &mysql, szSqlText))

//进行数据检索

{

//执行SQL语句出错

cout<<"query error"<<endl;

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<<"insert into data_receive(ID,data1,data2,data3, data4,data5,data6,data7,data8)values('"<<id[i]<<"','"<<

result[i][0]<<"','"<<result[i][1]<<"','"<<result[i][2]<<"','"<<

result[i][3]<<"','"<<result[i][4]<<"','"<<result[i][5]<<"','"<<

result[i][6]<<"','"<<result[i][7]<<"');";

string s = ss.str();

v.push_back(s);

}

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

{

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

{

std::cout<<"execute insert syntax fail"<<

std::endl<<mysql_error(&mysql)<<endl;

mysql_close(&mysql);

return 1;

}

}

mysql_free_result(res);

mysql_close(&mysql);

return 0;

}