Demonstrates ? how ? to ? use ? plain ? C ? to ? create ? a ? MySQL ? database, ? connect ? to ? it, ? create ? a ? table ? with ? fields, ? populate ? the ? table, ? execute ? an ? SQL ? query, ? and ? print ? the ? results. ? No ? MFC ? required ? - ? uses ? only ? plain ? C. ?
? ?
? #include ? <conio.h> ?
? #include ? <stdarg.h> ?
? #include ? <stdio.h> ?
? #include ? <stdlib.h> ?
? #include ? "winsock.h" ?
? #include ? "mysql.h" ?
? ?
? MYSQL ? ? ? ? ? *mysql ? = ? NULL; ?
? ?
? void ? MySQLError(void) ?
? { ?
? fprintf(stderr, ? "%s\n", ? mysql_error(mysql)); ?
? exit(1); ?
? } ?
? ?
? void ? ExecuteSQL(char ? *fmt, ? ...) ?
? { ?
? char ? SQL[1000] ? = ? {0}; ?
? int ? ? retval; ?
? va_list ? args; ?
? va_start(args, ? fmt); ?
? if ? (_vsnprintf(SQL, ? sizeof(SQL)-1, ? fmt, ? args) ? < ? 0) ?
? { ?
? fprintf(stderr, ? "SQL ? query ? truncated! ? Increase ? SQL ? buffer ? size ? in ? ExecuteSQL\n"); ?
? exit(1); ?
? } ?
? va_end(args); ?
? retval ? = ? mysql_query(mysql, ? SQL); ?
? if ? (retval) ?
? { ?
? fprintf(stderr, ? "Original ? SQL ? Statement: ? %s\n", ? SQL); ?
? fprintf(stderr, ? "%s\n", ? mysql_error(mysql)); ?
? exit(2); ?
? } ?
? } ?
? ?
? int ? main() ?
? { ?
? UINT ? ? ? ? ? ? ? ? ? i; ?
? UINT ? ? ? ? ? ? ? ? ? FieldCount; ?
? MYSQL_RES ? ? ? *res ? ? ? ? ? ? ? ? ? = ? NULL; ?
? MYSQL_ROW ? ? ? ? row ? ? ? ? ? ? ? ? ? = ? NULL; ?
? MYSQL_FIELD ? *field; ?
? ?
? char ? ? ? ? ? ? *DBName ? ? ? ? ? ? = ? "Test"; ?
? char ? ? ? ? ? ? *TableName ? ? ? = ? "People"; ?
? char ? ? ? ? ? ? *CreateDB ? ? ? ? = ? "CREATE ? DATABASE ? IF ? NOT ? EXISTS ? %s"; ?
? char ? ? ? ? ? ? *DropTable ? ? ? = ? "DROP ? TABLE ? IF ? EXISTS ? %s"; ?
? char ? ? ? ? ? ? *CreateTable ? = ? "CREATE ? TABLE ? IF ? NOT ? EXISTS ? %s ? (\n" ?
? ? "ID ? ? ? ? ? ? ? ? ? INT ? UNSIGNED ? AUTO_INCREMENT, ? \n" ?
? ? "FirstName ? ? VARCHAR(32), ? \n" ?
? ? "MiddleName ? VARCHAR(32), ? \n" ?
? ? "LastName ? ? ? VARCHAR(32), ? \n" ?
? ? "Address1 ? ? ? VARCHAR(50), ? \n" ?
? ? "Address2 ? ? ? VARCHAR(50), ? \n" ?
? ? "City ? ? ? ? ? ? ? VARCHAR(50), ? \n" ?
? ? "State ? ? ? ? ? ? VARCHAR(2), ? \n" ?
? ? "Zip ? ? ? ? ? ? ? ? VARCHAR(5), ? \n" ?
? ? "Email ? ? ? ? ? ? VARCHAR(50), ? \n" ?
? ? "Gender ? ? ? ? ? VARCHAR(1), ? \n" ?
? ? "WorkPhone ? ? VARCHAR(50), ? \n" ?
? ? "HomePhone ? ? VARCHAR(50), ? \n" ?
? ? "CellPhone ? ? VARCHAR(50), ? \n" ?
? ? "BirthDate ? ? DATE ? NULL, ? \n" ?
? ? "Primary ? Key ? (ID) ? \n" ?
? ? ")\n"; ?
? char ? ? ? ? ? ? *AddRecord ? ? ? = ? "INSERT ? INTO ? %s ? (FirstName, ? LastName) ? VALUES ? ('FirstName ? %03d', ? 'LastName ? %03d')"; ?
? char ? ? ? ? ? ? *GetRecords ? ? = ? "SELECT ? ID, ? FirstName, ? LastName ? FROM ? %s"; ?
? ?
? ?
? ?
? // ? Initialize ? MySQL ?
? mysql ? = ? mysql_init(NULL); ?
? ?
? // ? Connect ? to ? MySQL ?
? if ? (!(mysql_real_connect(mysql, ? "localhost", ? "admin", ? "", ? NULL, ? mysql->port, ? 0, ? 0))) ? ?
? MySQLError(); ?
? ?
? // ? Create ? database ?
? ExecuteSQL(CreateDB, ? DBName); ?
? ?
? // ? Connect ? to ? temporary ? database ?
? if ? (mysql_select_db(mysql, ? DBName)) ?
? MySQLError(); ?
? ?
? // ? Delete ? table ? if ? it ? already ? exists. ?
? ExecuteSQL(DropTable, ? TableName); ?
? ?
? // ? Create ? table ?
? ExecuteSQL(CreateTable, ? TableName); ?
? ?
? // ? Insert ? some ? data ? into ? the ? table. ?
? for ? (i ? = ? 0; ? i ? < ? 200; ? i++) ?
? ExecuteSQL(AddRecord, ? TableName, ? i, ? i); ?
? ?
? // ? Execute ? query ?
? ExecuteSQL(GetRecords, ? TableName); ?
? ?
? // ? Store ? the ? recordset ?
? if ? ((res ? = ? mysql_store_result(mysql)) ? == ? NULL) ?
? MySQLError(); ?
? ?
? // ? Print ? the ? recordset ?
? printf("Table ? %s\n", ? TableName); ?
? while((field ? = ? mysql_fetch_field(res)) ? != ? NULL) ?
? printf("%s\t", ? field->name); ?
? printf("\n"); ?
? FieldCount ? = ? mysql_num_fields(res); ?
? while((row ? = ? mysql_fetch_row(res)) ? != ? NULL) ? ?
? { ?
? for ? (i ? = ? 0; ? i ? < ? FieldCount; ? i++) ? ?
? printf("%s\t", ? row[i]); ?
? printf("\n"); ?
? } ?
? printf("\nTotal ? rows: ? %d\n", ? mysql_num_rows(res)); ?
? ?
? // ? Free ? the ? recordset ?
? mysql_free_result(res); ?
? ?
? // ? Close ? the ? connection ?
? mysql_close(mysql); ?
? ?
? printf("\nPrint ? any ? key ? to ? continue...\n"); ?
? getche(); ?
? } ?
? ?
? 如果有問題,請加入mysql++.lib????
在VC里的toos->option->directories中將include增加一個c:\mysql\include,將lib增加一個c:\mysql\lib,將libmysql.dll和libmysql.lib拷到當前目錄下,并且把libmysql.lib增加到工程中。
2,????? 建立與服務器的連接。
Include <mysql.h> //包含頭文件
MYSQL *conn;//定義一個MYSQL類型結構,這個幾乎在所有的后面的編程中都需要
MYSQL *mysql_init(MYSQL *conn);//如果conn=NULL,返回一個新分配的句柄結構返回,反之則重新初始化該結構,出現錯誤則返回NULL;
MYSQL *mysql_real_connect(MYSQL * connection,const char *server_host,const char *sql_urs_name,const char *sql_password,const char *db_name,unsigned int port_number,const char *unix_socket_name,unsigned int flags);//連接MYSQL服務器,里面的參數應該很清楚了,一般port_number和unix_socket_name的值為0和NULL。例如:
mysql_real_connect(conn_ptr,"localhost","sagely","secret","ra",0,NULL,0);
???? void mysql_close(MYSQL *connection);關閉一個連接。
3,????? 執行SQL語句
mysql_select_db(MYSQL *connection,const char *db_name);選定某個數據庫。
???? int mysql_query(MYSQL *connection,const char *query)//他將執行query語句,運行成功將返回0,例如mysql_query(conn_ptr, Create table cert_info(...),將創建一個名為cert_info的表,幾乎所有的SQL語句都能這么執行。呵呵,是不是顯得很簡單,他就和命令行中輸入的SQL語句差不多。在使用上面函數的時候一般會使用
???? my_ulonglong mysql_affected_rows(MYSQL *connection),這個函數返回的是mysql_query對進行改動的行的數量。
4,????? 處理檢索到的數據
當我們可以執行SQL語句以后,那么就很容易執行增加刪除修改等操作,但是假若檢索出來的數據存儲在哪里呢?
???? MYSQL_RES *mysql_use_result(MYSQL *connection)這個函數得到一個連接對象返回一個結果集合指針,出錯時返回NULL。不過他只是返回一個集合對象初始化來接收數據,并沒有將任何檢索到的數據返回到結果集合中。
???? MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)這個函數獲得mysql_use_resul得到的結果結構體,并從中檢索單個行,并返回分配給行結構體的數據,沒有更多數據或出錯時,返回NULL。
???? Unsigned int mysql_field_count(MYSQL *connection)它得到一個連接對象并返回在集合中字段的數目。
于是有上面的基礎我們就可以理解下面這段了:(沒有錯誤處理)
mysql_init(&conn_ptr);
mysql_real_connect(conn_ptr,"localhost","sagely","secret","ra",0,NULL,0);
mysql_query(conn_ptr,"SELECT * form usr_info);
res_ptr=mysql_use_result(&conn_ptr);
sqlrow=mysql_fetch_row(res_ptr);
for(int i=0;i<mysql_field_count(&conn_ptr);i++){printf("%s ",sqlrow);}
???? MYSQL_FIELD *mysql_fetch_field(MYSQL_RES *result)它返回的是列的信息,比如列的名稱,列所在表名稱等等,有了這個就可以將列標題與數據想對應起來了。
posted on 2007-03-07 11:32
喬棟 閱讀(317)
評論(0) 編輯 收藏 引用 所屬分類:
C的游樂園