-
#include <stdio.h>
-
#include <mysql/mysql.h>
-
-
#define HOST "192.168.56.2"
-
#define DB "webdevtest"
-
#define USER "webdev"
-
#define PWD "webdev"
-
#define PORT 3306
-
-
int main(){
-
MYSQL mysql;
-
-
//连接之前得先初始化
-
mysql_init(&mysql);
-
//连接mysql数据库
-
if(!mysql_real_connect(&mysql,HOST,USER,PWD,DB,PORT,NULL,0)){
-
printf("连接数据库发生错误!\n");
-
return -1;
-
}
-
printf("连接数据库成功!\n");
-
-
//设置查询时的编码
-
mysql_query(&mysql,"set names utf8");
-
//执行查询语句
char *sql="select * from test_sell_records limit 20";
-
if(mysql_query(&mysql,sql)!=0){
-
printf("执行mysql语句发生错误!\n");
-
mysql_close(&mysql);
-
return -1;
-
}
-
//获取结果集
-
MYSQL_RES *result=mysql_store_result(&mysql);
-
unsigned int i,num_fields;
-
//获取字段数
-
num_fields=mysql_num_fields(result);
-
//循环打印出各行
-
MYSQL_ROW row;
-
while((row=mysql_fetch_row(result))!=NULL){
-
for(i=0;i<num_fields;i++){
-
printf("%s\t",row[i]);
-
}
-
printf("\n");
-
}
-
-
//释放结果集
-
mysql_free_result(result);
-
//关闭连接
-
mysql_close(&mysql);
-
return 0;
-
}