VC用MYSQL提供的LIB查询数据库

#include "winsock.h"
#include "mysql.h"

void query_example(void)
{
MYSQL *pDbCon = NULL;
char *pszHost = "localhost";
char *pszUser = "guest";
char *pszPsw = "";
char *pszDbName = "mysql_db_name";
int iPort = 3306;

pDbCon = mysql_init((MYSQL*) 0);
if (NULL != pDbCon)
{
if (mysql_real_connect(pDbCon, pszHost, pszUser, pszPsw, pszDbName, iPort, NULL, 0))
{
if (!mysql_select_db(pDbCon, pszDbName))
{
pDbCon->reconnect = 1;
char *pszSql = "select * from tb_name";
if (!mysql_query(pDbCon, pszSql))
{
long i = 0;
MYSQL_RES *pReSet = mysql_store_result(pDbCon);
long iFieldNum = mysql_num_fields(pReSet);
long iRecordNum = (long)mysql_num_rows(pReSet);
//printf name of fields
MYSQL_FIELD *pField = mysql_fetch_fields(pReSet);
for (i = 0; i < iFieldNum; i++)
{
//printf("%s, ", pField[i].name);
}
//printf all data
MYSQL_ROW stRow;
while (stRow = mysql_fetch_row(pReSet))
{
//printf row's data
for (i = 0; i < iFieldNum; i++)
{
if (stRow[i] != NULL)
{
//printf("%s  ", stRow[i]);
}
}
}
}
}
else
{
//printf("unable to select the database!/n");
}
}
else
{
//printf("can't connect to the mysql server!/n");
}
mysql_close(pDbCon);
}
}