mysql中新建的數據庫為hyx,hyx中的表為my_schema,表中的數據為下圖:
編寫代碼,訪問表中的數據,測試代碼如下:
#include "stdafx.h" #include <WinSock2.h> /*socket通信,系統頭文件*/ #include <windows.h> #include <stdio.h> #include <stdlib.h> #include <time.h> #include "mysql.h" #pragma comment(lib, "libmysql.lib") /*數據庫連接用宏*/ #define HOST "localhost" #define USERNAME "root" #define PASSWORD "root" #define DATABASE "hyx" void query_sql(char* sql); int main() { char *query; query="select * from my_schema"; query_sql(query); return 0; } void query_sql(char* sql) { MYSQL *conn; /*這是一個數據庫連接*/ int res; /*執行sql語句后的返回標志*/ MYSQL_RES *res_ptr; /*指向查詢結果的指針*/ MYSQL_FIELD *field; /*字段結構指針*/ MYSQL_ROW result_row; /*按行返回的查詢信息*/ int row, column; /*查詢返回的行數和列數*/ int i, j; /*初始化mysql連接my_connection*/ conn=mysql_init(NULL); /*建立mysql連接*/ if (NULL != mysql_real_connect(conn, HOST, USERNAME, PASSWORD, DATABASE, 0, NULL, CLIENT_FOUND_ROWS)) /*連接成功*/ { printf("數據庫查詢query_sql連接成功!\n"); /*設置查詢編碼為gbk,以支持中文*/ mysql_query(conn, "set names gbk"); res = mysql_query(conn, sql); if (res) /*執行失敗*/ { printf("Error: mysql_query !\n"); /*關閉連接*/ mysql_close(conn); } else /*現在就代表執行成功了*/ { /*將查詢的結果給res_ptr*/ res_ptr = mysql_store_result(conn); /*如果結果不為空,就把結果print*/ if (res_ptr) { /*取得結果的行數和*/ column = mysql_num_fields(res_ptr); row = mysql_num_rows(res_ptr); printf("查詢到 %d 行 \n", row); /*輸出結果的字段名*/ for (i = 0; field = mysql_fetch_field(res_ptr); i++) printf("%10s ", field->name); printf("\n"); /*按行輸出結果*/ for (i = 1; i < row+1; i++) { result_row = mysql_fetch_row(res_ptr); for (j = 0; j < column; j++) printf("%10s ", result_row[j]); printf("\n"); } } /*不要忘了關閉連接*/ mysql_close(conn); } } else { printf("數據庫連接失敗"); } }
運行結果: