MYSQL * con = mysql_init((MYSQL*) 0); LPSTR host = "***"; LPSTR user,psw,dbname,; if ( con !=NULL && mysql_real_connect(con,host,user,psw,dbname,3306,NULL,0) ) { if (!mysql_select_db(con,dbname)) { printf("Select successfully the database!\n"); con ->reconnect = 1; if (!mysql_query(con,"select * from table_name")) { printf("Show table---orders:\n"); MYSQL_RES * recordSet = mysql_store_result(con); long j = mysql_num_fields(recordSet); long i = (long)mysql_num_rows(recordSet); //get RecordSet of fields MYSQL_FIELD * field = mysql_fetch_fields(recordSet); for(int l=0;l<j;l++) { printf("%s ",field[l].name); } printf("\n");
// get all the row of table---boothinfo MYSQL_ROW row; while( row = mysql_fetch_row(recordSet)) { //get the number of fields
for(int l=0 ; l< j;l++) { if(row[l]==NULL || !strlen(row[l])) printf("NULL "); else printf("%s ",row[l]); } printf("\n"); } } } else { printf("Unable to select the databas!\n"); return 0; } return 1; } else { printf("can't connect to the mysql server!\n"); printf("Errors: %s",mysql_error(con)); return -1; } mysql_close(con); }
安装mysql时记得装 类库,里面有 mysql提供的函数借口,用它来连mysql很方便
MYSQL mysql; MYSQL_RES *result; MYSQL_ROW row; CString strsql="select * from mytab"; mysql_init(&mysql);
#include "winsock.h"
#include "mysql.h"
int main(int argc, char* argv[])
{
MYSQL * con = mysql_init((MYSQL*) 0);
LPSTR host = "***";
LPSTR user,psw,dbname,;
if ( con !=NULL
&& mysql_real_connect(con,host,user,psw,dbname,3306,NULL,0) )
{
if (!mysql_select_db(con,dbname))
{
printf("Select successfully the database!\n");
con ->reconnect = 1;
if (!mysql_query(con,"select * from table_name"))
{
printf("Show table---orders:\n");
MYSQL_RES * recordSet = mysql_store_result(con);
long j = mysql_num_fields(recordSet);
long i = (long)mysql_num_rows(recordSet);
//get RecordSet of fields
MYSQL_FIELD * field = mysql_fetch_fields(recordSet);
for(int l=0;l<j;l++)
{
printf("%s ",field[l].name);
}
printf("\n");
// get all the row of table---boothinfo
MYSQL_ROW row;
while( row = mysql_fetch_row(recordSet))
{
//get the number of fields
for(int l=0 ; l< j;l++)
{
if(row[l]==NULL || !strlen(row[l]))
printf("NULL ");
else
printf("%s ",row[l]);
}
printf("\n");
}
}
}
else
{
printf("Unable to select the databas!\n");
return 0;
}
return 1;
}
else
{
printf("can't connect to the mysql server!\n");
printf("Errors: %s",mysql_error(con));
return -1;
}
mysql_close(con);
}
MYSQL_RES *result;
MYSQL_ROW row;
CString strsql="select * from mytab";
mysql_init(&mysql);
if( !mysql_real_connect(&mysql,"localhost","root","123456","mydb",3306,NULL,0))
{
AfxMessageBox("连接数据库失败!");
return FALSE;
}
mysql_set_character_set(&mysql, "gbk");
if( mysql_real_query(&mysql,strsql,strsql.GetLength())!=0 )
{
AfxMessageBox("err query!");
return FALSE;
}
if(!(result=mysql_use_result(&mysql)))
AfxMessageBox("读取数据集失败");
int i=0;
while(row=mysql_fetch_row(result))
{
m_teamlist.InsertItem(i,(char*)row[0]);
m_teamlist.SetItemText(i,1,(char*)row[1]);
i++;
}
mysql_free_result(result);
mysql_close(&mysql);