什么是FreeTDS
簡單的說FreeTDS是一個程序庫,可以實現在Linux系統下訪問微軟的SQL數據庫! FreeTDS 是一個開源(如果你喜歡可以稱為自由)的程序庫,是TDS(表列數據流 )協議的再次實現。它可以被用在Sybase的db-lib或者ct-lib庫。它也包含一個ODBC的庫。允許許多開源的應用軟件比如Perl和PHP(或者你自己的c或C++程序)去連接到Sybase或 Microsoft SQL服務器。FreeTDS 以源碼的形式被發布,幾乎可以在任何操作系統上編譯。意味着Unix和類Unix系統(包括著名的分支如Interix和QNX),還有Win32,VMS,和OSX。
FreeTDS的安裝
1.下載freetds,點此下載 http://www.jb51.net/database/201983.html
2.將其解壓到任意目錄,進入到解壓后的文件夾里。
3.切換到root,配置: ./configure –prefix=/usr/local –with-tdsver=7.1 –enable-msdblib 解釋:–prefix為設置FreeTDS的安裝目錄,–with-tdsver是設置TDS版本, –enable-msdblib為是否允許Microsoft數據庫函數庫
4.make & make install
FreeTDS測試:
FreeTDS安裝好了,接下來就可以查看下FreeTDS狀態了;
運行./tsql -C ,在安裝目錄的bin目錄下可以找到tsql ,查看終端打印出來信息,這個-with-tdsver=7.1:
關於安裝參考
http://linux.chinaunix.net/techdoc/database/2008/10/31/1042291.shtml 或者:http://www.linuxdiyf.com/viewarticle.php?id=109086
FreeTDS的配置
freeTDS 的配置文件,FreeTDS也支持一個舊的配置文件interfaces,但請使用freetds.conf 除非你的環境必須使用interfaces。FreeTDS首先找freetds.conf文件如果沒有找到才去找 interfaces文件。 freetds.conf文件默認在/usr/local/freetds/etc目錄下,但是可以在configure時配置 sysconfdir選項,這個選項就是freetds.conf文件所存在的目錄。freetds.conf配置文件分為兩部分:一是[global]部分,另外一個是[dataserver]部分,其中 [dataserver]對應一個數據庫。在golbal中的設置是對全部數據庫起作用的,但在dataserver 部分的設置只對自己的數據庫起作用,並且可以覆蓋全局的設置。
例如: freetds.conf文件:
1 [global] 2 tds version = 4.2 3 [myserver] 4 host = ntbox.mydomain.com 5 port = 1433 6 [myserver2] 7 host = unixbox.mydomain.com 8 port = 4000 9 tds version = 5.0
這個文件中global設置所有數據庫使用tds版本為4.2,但在myserver2中使用的版本卻是5.0, 如果myserver2中沒有這一項,那就是用4.2版本的如myserver。
其配置項解釋如下:
ltds version : 指明tds協議的版本,連接數據庫時使用,如果在環境變量中沒有設置 此項,則由此配置決定,協議版本可取4.2,5.0,7.0,8.0。 lhost : 數據庫服務器的主機名或者ip地址。 lport : 數據庫服務器的監聽端口,可以取任何有效的端口值,一般而言Sybase SQL10以前為 1433,10以上用5000,而Sybase SQLAnywhere 7是2638,Microsoft SQL server則用 1433。此配置可以被環境變量中的TDSPORT改寫。 linitial block size : 此值只能取512的倍數,默認為512,指定了協議塊的最大值, 一般不要改變此默認 配置。 ldump file : 任何有效的文件名,指明了轉儲文件的路徑並且會打開日志記錄。 ldump file append: yes或者no,決定是否追加保存到dump file文件中。 ltimeout :設置處理的最大等待時間。 lconnect timeout: 設置連接的最大等待時間。 lemulate little endian: yes或者no,是否強制大端機使用小端方式與MS Server通信。 lclient charset : 任何有效的iconv字符集。默認值為ISO-8859-1,使FreeTDS使用 iconv在數據庫服務器和用戶程序之間轉換。
FreeTDS函數
1. Dbcmd和dbfcmd 函數原形: Dbcmd(DBPROCESS *proc,char * sql); Dbcmd(DBPROCESS *proc, char * format,char *args); 功 能:該函數主要是構造sql語句,一個是帶參數的,一個不帶參數。 2. Dbsqlexec 函數原形:Dbsqlexec(DBPROCESS *proc); 功 能:該函數負責執行你所構造的sql語句。 3. Dbresults 函數原形:Dbrerults(DBPROCESS *proc); 功 能:得到sql語句的執行結果。返回值如果為NO_MORE_RESULTS=0,表明sql查詢為空值(就是沒有一條滿足條件的結果),如果為(FAIL)=-1,表明查詢出錯,如果為(SUCCESS)=1,表明有結果且不為空。 4. DBROWS(全大寫) 函數原形:DBROWS(DBPROCESS *proc); 功 能:取出一行記錄的信息。 5. Dbbind 函數原形:Dbbind(DBPROCESS *proc,int colmn, 功 能:將sql查詢出來的結果綁定到一個變量。第一個參數為從數據庫那里拿的句柄,第二個參數是對應你的select語句中查詢需要的字段(注:必須是按照select順序綁定的,例如select user,password from hist1 ,如果值為1,就是綁定的user),第三個參數是綁定字段的類型,最后一個參數是綁定的變量。 6. Dbnextrow 函數原形:Dbnextrow(DBPROCESS *proc); 功 能:該函數將取出滿足sql語句的每一行,返回值為0,代表處理結束,返回值為-1出錯。 7. Dbcancel 函數原形:Dbcancel(DBPROCESS *proc); 功 能:清空上次查詢得到的數據集,如果是一個句柄的話,每次重新執行select語句之前都要調用它清空結果,不然數據庫會報錯的。 8. Dbclose 函數原形:Dbclose(DBPROCESS *proc); 功 能:關閉句柄。當不再使用時必須關閉句柄。 9. Dbinit 函數原形:Dbinit() 功 能:初識化數據庫連接。返回值為-1出錯。 10. Dblogin 函數原形:LOGINREC *Dblogin(); DBSETLUSER(login,SOFT); //set the database user DBSETLPWD(login,SOFTPASS);//set password 功 能:根據用戶名和密碼連接數據庫。 11.Dbcount 函數原形:Dbcount(DBPROCESS *proc); 功 能:該函數將得到sql結果集被處理的行數,可以用它來判斷你的select語句是否得到正確的處理。 12.Dbopen 函數原形:DBPROCESS * Dbopen(LOGINREC *login,NULL); 功 能:返回一個操作數據庫的句柄。 另外再介紹兩個關於數據庫的出錯信息的函數: dberrhandle(int *err); dbmsghandle(int* err);
實例代碼
1 #include <stdio.h> 2 #include <stdlib.h> 3 #include <string.h> 4 #include <unistd.h> 5 #include <sqlfront.h> /* sqlfront.h always comes first */ 6 #include <sybdb.h> /* sybdb.h is the only other file you need */ 7 #define SQLDBIP " " //SQL數據庫服務器IP 8 #define SQLDBPORT " " //SQL數據庫服務器端口 9 #define SQLDBNAME " " //SQL數據庫服務器數據庫名 10 #define SQLDBUSER " " //SQL數據庫服務器數據庫用戶名 11 #define SQLDBPASSWD " " //SQL數據庫服務器用戶密碼 12 #define SQLDBSERVER SQLDBIP":"SQLDBPORT 13 #define DBSQLCMD "select * from yancao" 14 int main(int argc, char *argv[]) 15 { 16 int i, ch; 17 LOGINREC *login; //描述客戶端的結構體,在連接時被傳遞到服務器. 18 DBPROCESS *dbproc; //描述連接的結構體,被dbopen()函數返回 19 RETCODE erc; //庫函數中最普遍的返回類型. 20 /*************************************************************/ 21 //在開始調用本庫函數前常常要先調用dbinit()函數 22 if (dbinit() == FAIL) { 23 fprintf(stderr, "%s:%d: dbinit() failed\n", argv[0], __LINE__); 24 exit(1); 25 } 26 //dblogin()函數申請 LOGINREC 結構體,此結構體被傳遞給dbopen()函數,用來創建一個連接。 27 //雖然基本上不會調用失敗,但是檢查它!. 28 if ((login = dblogin()) == NULL) { 29 fprintf(stderr, "%s:%d: unable to allocate login structure\n", argv[0], __LINE__); 30 exit(1); 31 } 32 //LOGINREC結構體不能被直接訪問,要通過以下宏設置,下面設置兩個必不可少的域 33 DBSETLUSER(login, SQLDBUSER); 34 DBSETLPWD(login, SQLDBPASSWD); 35 /*************************************************************/ 36 //dbopen()與服務器建立一個連接. 傳遞 LOGINREC 指針和服務器名字 37 if ((dbproc = dbopen(login, SQLDBSERVER)) == NULL) { 38 fprintf(stderr, "%s:%d: unable to connect to %s as %s\n", 39 argv[0], __LINE__, 40 SQLDBSERVER, SQLDBUSER); 41 exit(1); 42 } 43 // 可以調用dbuser()函數選擇我們使用的數據庫名,可以省略,省略后使用用戶默認數據庫. 44 if (SQLDBNAME && (erc = dbuse(dbproc, SQLDBNAME)) == FAIL) { 45 fprintf(stderr, "%s:%d: unable to use to database %s\n", 46 argv[0], __LINE__, SQLDBNAME); 47 exit(1); 48 } 49 /*************************************************************/ 50 dbcmd(dbproc, DBSQLCMD);//將SQL語句填充到命令緩沖區 51 printf("\n"); 52 if ((erc = dbsqlexec(dbproc)) == FAIL) { 53 fprintf(stderr, "%s:%d: dbsqlexec() failed\n", argv[0], __LINE__); 54 exit(1); //等待服務器執行SQL語句,等待時間取決於查詢的復雜度。 55 } 56 /*************************************************************/ 57 //在調用dbsqlexec()、dbsqlok()、dbrpcsend()返回成功之后調用dbresults()函數 58 printf("then fetch results:\n"); 59 int count = 0; 60 while ((erc = dbresults(dbproc)) != NO_MORE_RESULTS) { 61 struct col { //保存列的所有信息 62 char *name; //列名字 63 char *buffer; //存放列數據指針 64 int type, size, status; 65 } *columns, *pcol; 66 int ncols; 67 int row_code; 68 if (erc == FAIL) { 69 fprintf(stderr, "%s:%d: dbresults failed\n", 70 argv[0], __LINE__); 71 exit(1); 72 } 73 ncols = dbnumcols(dbproc);//返回執行結果的列數目 74 if ((columns = calloc(ncols, sizeof(struct col))) == NULL) { 75 perror(NULL); 76 exit(1); 77 } 78 /* read metadata and bind. */ 79 for (pcol = columns; pcol - columns < ncols; pcol++) { 80 int c = pcol - columns + 1; 81 pcol->name = dbcolname(dbproc, c); //返回指定列的列名 82 pcol->type = dbcoltype(dbproc, c); 83 pcol->size = dbcollen(dbproc, c); 84 printf("%*s(%d)", 20, pcol->name, pcol->size); 85 if ((pcol->buffer = calloc(1, 20)) == NULL) { 86 perror(NULL); 87 exit(1); 88 } 89 erc = dbbind(dbproc, c, NTBSTRINGBIND, 20, (BYTE*)pcol->buffer); 90 if (erc == FAIL) { 91 fprintf(stderr, "%s:%d: dbbind(%d) failed\n", 92 argv[0], __LINE__, c); 93 exit(1); 94 } 95 erc = dbnullbind(dbproc, c, &pcol->status); //(5) 96 if (erc == FAIL) { 97 fprintf(stderr, "%s:%d: dbnullbind(%d) failed\n", 98 argv[0], __LINE__, c); 99 exit(1); 100 } 101 } 102 printf("\n"); 103 /* 打印數據 */ 104 while ((row_code = dbnextrow(dbproc)) != NO_MORE_ROWS) {//讀取行數據 105 switch (row_code) { 106 case REG_ROW: 107 for (pcol = columns; pcol - columns < ncols; pcol++) { 108 char *buffer = pcol->status == -1 ? 109 "null" : pcol->buffer; 110 printf("%*s ", 20, buffer); 111 } 112 printf("\n"); break; 113 case BUF_FULL: break; 114 case FAIL: 115 fprintf(stderr, "%s:%d: dbresults failed\n", 116 argv[0], __LINE__); 117 exit(1); break; 118 default: // (7) 119 printf("data for computeid %d ignored\n", row_code); 120 } 121 } 122 /* free metadata and data buffers */ 123 for (pcol = columns; pcol - columns < ncols; pcol++) { 124 free(pcol->buffer); 125 } 126 free(columns); 127 if (DBCOUNT(dbproc) > -1) /* 得到SQL語句影響的行數 */ 128 fprintf(stderr, "%d rows affected\n", DBCOUNT(dbproc)) 129 } 130 dbclose(dbproc); 131 dbexit(); 132 }