天天看點

用C語言操縱Mysql

以下代碼塊是用來連接配接資料庫的通訊過程,要連接配接MYSQL,必須建立MYSQL執行個體,通過mysql_init初始化方能開始進行連接配接.

這個結構代表傳回行的一個查詢的(<code>SELECT</code>, <code>SHOW</code>, <code>DESCRIBE</code>, <code>EXPLAIN</code>)的結果。傳回的資料稱為“資料集”,用過資料庫的朋友應該對資料庫中查詢後得到的結果集不會陌生,在C的API裡對應的就是MYSQL_RES了,從資料庫讀取資料,最後就是從MYSQL_RES中讀取資料。

----------------------------------------------

再看函數:

C語言操作mysql資料 常用函數

所需頭檔案: #include &lt;mysql/mysql.h&gt; 功能:  獲得或初始化一個MYSQL結構 函數原型: MYSQL *mysql_init(MYSQL *mysql) 函數傳回值: 一個被始化的MYSQL*句柄 備注:  在記憶體不足的情況下,傳回NULL

所需頭檔案: #include &lt;mysql/mysql.h&gt; 函數功能: 關閉一個伺服器連接配接,并釋放與連接配接相關的記憶體 函數原型: void mysql_close(MYSQL *mysql); 函數傳入值: MYSQL:類型的指針 函數傳回值: 無

所需頭檔案: #include &lt;mysql/mysql.h&gt; 函數功能: 連接配接一個MySQL伺服器 函數原型: MYSQL * mysql_connect(MYSQL *mysql,const char *host,const char *user,const char *passwd); 函數傳入值: mysql表示一個現存mysql結構的位址   host表示MYSQL伺服器的主機名或IP   user表示登入的使用者名   passwd表示登入的密碼 函數傳回值: 如果連接配接成功,一個MYSQL *連接配接句柄:如果連接配接失敗,NULL 備注:  該函數不推薦,使用mysql_real_connect()代替

所需檔案: #include &lt;mysql/mysql.h&gt; 函數功能: MYSQL  *mysql_real_connect(MYSQL *mysql,const char *host,const char *user,const  char *passwd,const char *db,unsigned int port,const char  *unix_socket,unsigned int client_flag); 函數傳入值: mysql表示一個現存mysql結構的位址   host表示MYSQL伺服器的主機名或IP   user表示登入的使用者名   passwd表示登入的密碼   db表示要連接配接的資料庫   port表示MySQL伺服器的TCP/IP端口   unix_socket表示連接配接類型   client_flag表示MySQL運作ODBC資料庫的标記 函數傳回值: 如果連接配接成功,一個MYSQL*連接配接句柄:如果連接配接失敗,NULL

所需頭檔案: #include &lt;mysql/mysql.h&gt; 函數功能: 傳回最新的UPDATE,DELETE或INSERT查詢影響的行數 函數傳入值: MYSQL:類型指針 函數傳回值: 大于零的一個整數表示受到影響或檢索出來的行數。零表示沒有區配查序中WHERE子句的記錄或目前還沒有查詢被執行;-1表示查詢傳回一個錯誤,或對于一個SELECT查詢

所需頭檔案: #include &lt;mysql/mysql.h&gt; 函數功能: 對指定的連接配接執行查詢 函數原型: int mysql_query(MYSQL *mysql,const char *query); 函數傳入值: query表示執行的SQL語句 函數傳回值: 如果查詢成功,為零,出錯為非零。 相關函數: mysql_real_query

所需頭檔案: #include &lt;mysql/mysql.h&gt; 函數功能: 為無緩沖的結果集獲得結果辨別符 函數原形: MYSQL_RES *mysql_use_result(MYSQL *mysql); 函數傳入值: MYSQL:類型的指針 函數傳回值: 一個MYSQL_RES結果結構,如果發生一個錯誤發NULL

#incluee &lt;mysql/mysql.h&gt; 檢索一個結果集合的下一行 MYSQL_ROW mysql_fetch_row(MYSQL_RES *result); MYSQL_RES:結構的指針 下一行的一個MYSQL_ROW結構。如果沒有更多的行可檢索或如果出現一個錯誤,NULL

#include &lt;mysql/mysql.h&gt; 傳回指定結果集中列的數量 unsigned int mysql_num_fields(MYSQL_RES *res); MYSQL_RES 結構的指針 結果集合中字段數量的一個無符号整數

#include &lt;mysql/mysql.h&gt; 建立一個資料庫 int mysql_create_db(MYSQL *mysql,const char *db); MYSQL:類型的指針 db:要建立的資料庫名 如果資料庫成功地被建立,傳回零,如果發生錯誤,為非零。

#include &lt;mysql/mysql.h&gt; 選擇一個資料庫 int mysql_select_db(MYSQL *mysql,const char *db); MYSQL:類型的指針 db:要建立的資料庫名 如果資料庫成功地被建立,傳回零,如果發生錯誤,為非零。

再看例子:

      很多人用到MySQL來開發一些項目,有時為了性能,我們會直接用C語言來開發相關的子產品,尤其在我們的web應用中,雖然PHP、JSP等腳本均 提供了MySQL的接口,但是顯然直接使用C語言具有更好的安全性和性能,Michael以前用PHP開發的多個項目中就使用了C語言編寫的這類接口,然 後再編譯到php裡面,供php腳本直接使用,這方面的話題就不多說了,下面主要說一下在Linux下如何用C語言連接配接MySQL資料庫,并且讀取裡面的 資料傳回,同時如何進行編譯。

  這裡的大部分代碼參考了MySQL發行包裡面的.c源檔案,大家也可以去裡面找找相關的代碼,下面這段代碼實作了連接配接到本地MySQL伺服器上9tmd_bbs_utf8資料庫,從資料表tbb_user中根據輸入的userid取得該使用者的使用者名并列印輸出到終端。

#if defined(_WIN32) || defined(_WIN64) //為了支援windows平台上的編譯#include &lt;windows.h&gt;#endif#include &lt;stdio.h&gt;#include &lt;stdlib.h&gt;#include "mysql.h"  //我的機器上該檔案在/usr/local/include/mysql下//定義資料庫操作的宏,也可以不定義留着後面直接寫進代碼#define SELECT_QUERY "select username from tbb_user where userid = %d"int main(int argc, char **argv) //char **argv 相當于 char *argv[]{     MYSQL mysql,*sock;    //定義資料庫連接配接的句柄,它被用于幾乎所有的MySQL函數     MYSQL_RES *res;       //查詢結果集,結構類型     MYSQL_FIELD *fd ;     //包含字段資訊的結構     MYSQL_ROW row ;       //存放一行查詢結果的字元串數組     char qbuf[160];      //存放查詢sql語句字元串         if (argc != 2) { //檢查輸入參數         fprintf(stderr,"usage : mysql_select &lt;userid&gt;\n\n");         exit(1);     }         mysql_init(&amp;mysql);     if (!(sock = mysql_real_connect(&amp;mysql,"localhost","dbuser","dbpwd","9tmd_bbs_utf8",0,NULL,0))) {         fprintf(stderr,"Couldn't connect to engine!\n%s\n\n",mysql_error(&amp;mysql));         perror("");         exit(1);     }         sprintf(qbuf,SELECT_QUERY,atoi(argv[1]));     if(mysql_query(sock,qbuf)) {         fprintf(stderr,"Query failed (%s)\n",mysql_error(sock));         exit(1);     }         if (!(res=mysql_store_result(sock))) {         fprintf(stderr,"Couldn't get result from %s\n", mysql_error(sock));         exit(1);     }         printf("number of fields returned: %d\n",mysql_num_fields(res));             while (row = mysql_fetch_row(res)) {         printf("Ther userid #%d 's username is: %s\n", atoi(argv[1]),(((row[0]==NULL)&amp;&amp;(!strlen(row[0]))) ? "NULL" : row[0])) ;         puts( "query ok !\n" ) ;     }         mysql_free_result(res);     mysql_close(sock);     exit(0);     return 0;   //. 為了相容大部分的編譯器加入此行}

編譯的時候,使用下面的指令

gcc -o mysql_select  ./mysql_select.c -I/usr/local/include/mysql -L/usr/local/lib/mysql  -lmysqlclient (-lz) (-lm) 後面兩個選項可選,根據您的環境情況

運作的時候,執行下面的指令

./mysql_select 1

将傳回如下結果:

number of fields returned: 1 Ther userid #1 's username is: Michael query ok !

上面的代碼我想大部分都能看明白,不明白的可以參考一下MySQL提供的有關C語言API部分文檔,各個函數都有詳細說明,有時間我整理一份常用的API說明出來。