1、首先當(dāng)然是連接數(shù)據(jù)庫(kù)，函數(shù)原型如下：

MYSQL * STDCALL 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 long clientflag);

第一個(gè)參數(shù) MYSQL是 C api中一個(gè)非常重要的變量，里面內(nèi)存非常豐富，有port,dbname,charset等連接基本參數(shù)。它也包含了一個(gè)叫 st_mysql_methods的結(jié)構(gòu)體變量，該變量里面保存著很多函數(shù)指針，這些函數(shù)指針將會(huì)在數(shù)據(jù)庫(kù)連接成功以后的各種數(shù)據(jù)操作中被調(diào)用。mysql_real_connect函數(shù)中各參數(shù)，基本都是顧名思意。

2、連接數(shù)據(jù)庫(kù)成功之后就可以執(zhí)行sql語(yǔ)句了使用mysql_query
int STDCALL mysql_query(MYSQL *mysql, const char *q);

第一個(gè)參數(shù)上面已經(jīng)介紹過(guò)，第二個(gè)參數(shù)為要執(zhí)行的sql語(yǔ)句。

這個(gè)函數(shù)總體就兩步：

（1）發(fā)送sql語(yǔ)句，其實(shí)就一個(gè)socket發(fā)送sql 語(yǔ)句，加上mysql固定的協(xié)議頭。懶的去看源碼了，抓了下包，如下：
0000 19 00 00 00 0373 65 6c 65 63 74 20 61 70 70 5f .....select app_
0010 6e 61 6d 65 20 66 72 6f 6d 20 61 70 70 name from app
紅色部分是協(xié)議，前面兩位其實(shí)就是包的長(zhǎng)度。具體協(xié)議沒(méi)研究過(guò)。

（2）然后就是接受結(jié)果，這里將會(huì)調(diào)用MYSQL變量中的st_mysql_methods中的read_query_result函數(shù)指針

3、獲取結(jié)果

sql執(zhí)行完以后，如果是查詢語(yǔ)句，我們當(dāng)然還要讀取數(shù)據(jù)，如果update，insert等語(yǔ)句，那么就看下操作成功與否即可。我們來(lái)看看如何獲取查詢結(jié)果： 如果mysql_query返回成功，那么我們就通過(guò)mysql_store_result這個(gè)函數(shù)來(lái)讀取結(jié)果。原型如下：

MYSQL_RES * STDCALL mysql_store_result(MYSQL *mysql);

該函數(shù)會(huì)調(diào)用MYSQL變量中的st_mysql_methods中的 read_rows函數(shù)指針來(lái)獲取查詢的結(jié)果。同時(shí)該函數(shù)會(huì)返回MYSQL_RES 這樣一個(gè)變量，該變量主要用于保存查詢的結(jié)果。同時(shí)該函數(shù)malloc了一片內(nèi)存空間來(lái)存儲(chǔ)查詢過(guò)來(lái)的數(shù)據(jù)，所以我們一定要記的 free(result),不然是肯定會(huì)造成內(nèi)存泄漏的。 執(zhí)行完mysql_store_result以后，其實(shí)數(shù)據(jù)都已經(jīng)在MYSQL_RES 變量中了，下面的api基本就是讀取MYSQL_RES 中的數(shù)據(jù)。例如mysql_fetch_row這個(gè)函數(shù)，就是讀去查詢結(jié)果的一行。函數(shù)原型如下

MYSQL_ROW STDCALL mysql_fetch_row(MYSQL_RES *result);

它會(huì)返回一個(gè)MYSQL_ROW變量，MYSQL_ROW其實(shí)就是char **.就當(dāng)成一個(gè)二維數(shù)組來(lái)用吧。還有很多api，不再一一介紹，大部分信息都在MYSQL_RES MYSQL這兩個(gè)結(jié)構(gòu)體中。具體可以參考mysql官方網(wǎng)站： http://dev.mysql.com/doc/refman/5.1/en/c.html 突然發(fā)現(xiàn)官方網(wǎng)站資料好全面，貌似比任何書都要好。

下面來(lái)個(gè)例子：

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<mysql/mysql.h>
#define MAX_COLUMN_LEN  32
int main(int argc , char *argv[])
{
  MYSQL my_connection;
  MYSQL_RES *result;
  MYSQL_ROW sql_row;
  MYSQL_FIELD *fd;
  char column[MAX_COLUMN_LEN][MAX_COLUMN_LEN];
  int res;
  mysql_init(&my_connection);
  if(mysql_real_connect(&my_connection,"127.0.0.1","用戶","密碼","數(shù)據(jù)名稱",3306,NULL,0))
  {
    perror("connect");
    res=mysql_query(&my_connection,"select * from app");//查詢
    if(!res)
    {
      result=mysql_store_result(&my_connection);//保存查詢到的數(shù)據(jù)到result
      if(result)
      {
        int i,j;
        printf("the result number is %lu\n ",(unsigned long)mysql_num_rows(result));
        for(i=0;fd=mysql_fetch_field(result);i++)//獲取列名
        {
          bzero(column[i],sizeof(column[i]));
          strcpy(column[i],fd->name);
        }
        j=mysql_num_fields(result);
        for(i=0;i<j;i++)
        {
          printf("%s\t",column[i]);
        }
        printf("\n");
        while(sql_row=mysql_fetch_row(result))//獲取具體的數(shù)據(jù)
        {
          for(i=0;i<j;i++)
          {
            printf("%s\t",sql_row[i]);
          }
          printf("\n");
        }
        
      }
    }
    else
    {
      perror("select");
    }
  }
  else
  {
    perror("connect:error");
  }
  mysql_free_result(MYSQL_RES *result);//釋放結(jié)果資源
  mysql_close(&my_connection);//斷開連接

}

上面這個(gè)例子就是從一個(gè)表中查數(shù)據(jù)，然后輸出。 如果要insert或者update，只需要修改具體的sql既可。具體的操作都是通過(guò)mysql_query這個(gè)函數(shù)來(lái)搞定。 現(xiàn)在來(lái)講編譯的方法吧，這里我們需要.h以及.so庫(kù)。我們可以在 http://dev.mysql.com/downloads/connector/c/6.0.html 下載Connector/C。簡(jiǎn)單的方法就是： 把里面include的東西拷貝到/usr/include/mysql/下面去，這樣編譯的時(shí)候就不需要加-I了，然后把lib下面的東西拷貝的/usr/lib/下去。

gcc具體的編譯方法：gcc ***.c -o *** -lmysqlclient

最新評(píng)論