#include <windows.h>
#include <iostream>
#include <mysql.h>
#include <stdio.h>
#include <string.h>
using namespace std;

int connDB();
int create_table();
int insert_table();
int select_table();
int disconnDB();

MYSQL *mysql;
MYSQL_RES *res;
MYSQL_FIELD * fd;
MYSQL_ROW row;
char buf[500]="";

int i;

int main()
{

	connDB();
	create_table();
	insert_table();
	select_table();
	disconnDB();
return 0;
}


///////////////子函數
int connDB()//連接數據庫
{
	char *host = "localhost";
	char *user = "root";
	char *pass = "123";
	char *db = "jj";
	mysql = mysql_init((MYSQL*) 0);
	mysql_real_connect( mysql, host, user, pass, db, 0, NULL, 0 ) ;	
	mysql_set_character_set(mysql,"gb2312");
	cout<<"conn OK!"<<endl;
	return 0;
}

int disconnDB()//關閉數據庫
{
	mysql_close( mysql ) ;
	cout<<"disconn OK!"<<endl;
	   return 0 ;
}	

int create_table()	
{
	mysql_set_character_set(mysql,"gb2312");
	sprintf(buf, //構造SQL語句
		"create table mytable"
		//新建一張表
		"(s0 varchar(100), s1 char(6), "
		"s2 varchar(4), s3 varchar(6), s4 int)");
	if( mysql_query( mysql, szSqlText) )
	cout<<"create OK!"<<endl;
	return 0;
}

int insert_table()
{
	mysql_set_character_set(mysql,"gb2312");
	sprintf(buf,
"insert into mytable "
     //向表中插入數據
"values('2000-3-10 21:01:30',"
  //注意時間的格式
"'Test','清風寒劍','歲月情',2500)");
	if( mysql_query( mysql, szSqlText) )
	cout<<"insert OK!"<<endl;
	return 0;
	
}

int select_table()
{

	mysql_set_character_set(mysql,"gb2312");
	sprintf(buf, "select * from mytable ");
		if (mysql_query( mysql, szSqlText))
			//進行數據檢索
		{
			//執行SQL語句出錯
			mysql_close( mysql ) ;
			return FALSE ;
		}

	res = mysql_store_result( mysql) ;
	//取得查詢結果
	i = (int) mysql_num_rows( res ) ;
	//取得有效記錄數
	cout<<"Query: "<<szSqlText<<"\n"<<i<<" records found:"<<endl;
	for ( i = 0 ; fd = mysql_fetch_field( res ) ; i++ )
		cout<<fd->name<<"\t";
	cout<<endl;
	//輸出各字段名
	while(row = mysql_fetch_row( res ))
		//依次讀取各條記錄
		cout<<row[0]<<"\t"<<row[1]<<"\t"<<row[2]<<"\t"<<row[3]<<"\t"<<row[4]<<endl;
	
	mysql_free_result( res ) ;
	cout<<"select OK!"<<endl;
	return 0;
}