Linux下使用FreeTDS访问MS SQL Server 2005数据库(包含C测试源码)

http://blog.csdn.net/zhangm168/article/details/6859112

Linux下使用FreeTDS访问MS SQL Server 2005数据库(包含C测试源码)

(1)安装freeTDS

FreeTDS为Linux系统提供了TDS协议的开源客户端。由于MS SQL和Sybase使用的恰是TDS协议，所以在Linux中可以用FreeTDS连接MS SQL。

官网：http://www.freetds.org

下载：wget http://ibiblio.org/pub/Linux/ALPHA/freetds/stable/freetds-stable.tgz
安装：

[root@vm01 ~]# tar -zxvf freetds-stable.tgz

[root@vm01 ~]# cd freetds-0.91

[root@vm01 freetds-0.91]# ./configure --prefix=/usr/local/freetds --with-tdsver=8.0 --enable-msdblib

[root@vm01 freetds-0.91]# make

[root@vm01 freetds-0.91]# make install

修改环境变量：

FREETDS_HOME=/usr/local/freetds

export PATH=$FREETDS_HOME/bin:$PATH

库文件加载：

[root@vm01 freetds-0.91]# vim /etc/ld.so.conf.d/freetds.conf

/usr/local/freetds/lib

[root@vm01 freetds-0.91]# ldconfig

(2) 修改配置文件,连接数据库

(i) 添加数据源

[root@vm01 test]# vim /usr/local/freetds/etc/freetds.conf 

#zkl add

[SQL2005]

        host = 192.168.232.133

        port = 1433

        tds version=8.0
#client charset = ISO-8859-1

完成后，使用如下命令即可连接到 SQL Server 2005 .

[root@vm01 test]# tsql -S SQL2005 -U sa -P zkl

locale is "zh_CN.GB18030"

locale charset is "GB18030"

using default charset "GB18030"

1> use test  [使用test数据库]

2> go

1> select * from StuInfo [查询表信息]

2> go

StuID Name
 Age

001 zyh
 24

002 zkl
 21

003 Jim
 24

(3 rows affected)

(ii) 修改协议版本以正常连接SQL Server 2005

修改 freetds 配置文件

[root@vm01 test]# vim /usr/local/freetds/etc/freetds.conf 

[global]

        # TDS protocol version

#;      tds version = 4.2

         tds version=8.0   (这个前面不能有逗号)

连接 SQL SERVER 2005 需要使用的协议版本为 8.0，而使用 4.2 时，连接将会失败。使用 tsql 命令连接时，如果不像步骤(2)中那样配置数据源，则同样需要修改协议，然后才能使用如下命令正常连接数据库：

[root@vm01 test]# tsql -H 192.168.232.133 -p 1433 -U sa -P zkl

注意：第一个p为小写，后面的P是大写。

(3) 使用C++代码连接数据库

首先，确保协议版本是 8.0，然后编译以下C代码，测试与数据库的连接。

test.c:

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

view
plaincopy
to clipboard

#include <stdio.h> 

#include <string.h> 

#include <stdlib.h> 

#include <unistd.h>  

  

#include <sybfront.h> //freetds头文件 

#include <sybdb.h> //freetds 

  

  

int main(void) 

{ 

    char szUsername[32]
= "sa"; 

    char szPassword[32]
= "zkl"; 

    char szDBName[32]
= "test"; //数据库名 

    char szServer[32]
= "192.168.232.133:1433";//数据库服务器:端口 

  

    //初始化db-library 

    dbinit(); 

        

    //连接数据库 

    LOGINREC *loginrec = dblogin(); 

    DBSETLUSER(loginrec, szUsername);        

    DBSETLPWD(loginrec, szPassword); 

    DBPROCESS *dbprocess = dbopen(loginrec, szServer);//连接数据库 

    if(dbprocess
== FAIL) 

    { 

        printf("Conect to MS SQL SERVER fail, exit!\n"); 

        return -1;  

    } 

    printf("Connect to MS SQL SERVER success!\n"); 

        

    if(dbuse(dbprocess,
szDBName) == FAIL) 

        printf("Open database failed!\n"); 

    else 

        printf("Open database success!\n"); 

        

    //查询数据库 

    printf("[查询数据库表]\n"); 

    dbcmd(dbprocess, "select StuID, Name, Age from StuInfo"); 

    if(dbsqlexec(dbprocess)
== FAIL) 

    { 

        printf("Query table 'StuInfo' error.\n"); 

        return -1;  

    } 

      

    DBINT result_code; 

    char szStuID[20]={}; 

    char szName[80]={}; 

    char szAge[10]={}; 

    int rows
= 0; 

    while ((result_code
= dbresults(dbprocess)) != NO_MORE_RESULTS){ 

        if (result_code
== SUCCEED){ 

            dbbind(dbprocess, 1, CHARBIND, (DBINT)0, (BYTE*)szStuID); 

            dbbind(dbprocess, 2, CHARBIND, (DBCHAR)0, (BYTE*)szName); 

            dbbind(dbprocess, 3, CHARBIND, (DBCHAR)0, (BYTE*)szAge); 

            printf("StuID\tName\tAge\n",
szStuID); 

            while (dbnextrow(dbprocess)
!= NO_MORE_ROWS){                         

                printf("%s\t",
szStuID); 

                printf("%s\t",
szName); 

                printf("%s\n",
szAge); 

            } 

        } 

    }        

  

    printf("[插入数据到数据库表]\n"); 

    dbcmd(dbprocess, "insert into StuInfo(StuID, Name, Age) values(888,'James',28)"); 

    if(dbsqlexec(dbprocess)
== FAIL) 

    { 

        printf("insert into table 'StuInfo' error.\n"); 

        return -1;  

    } 

    printf("insert into table 'StuInfo' success.\n"); 

     

    printf("[删除数据库表中的记录]\n"); 

    dbcmd(dbprocess, "delete from StuInfo where StuID=888"); 

    if(dbsqlexec(dbprocess)
== FAIL) 

    { 

        printf("delete from table 'StuInfo' error.\n"); 

        return -1;  

    } 

    printf("delete from table 'StuInfo' success.\n"); 

     

    //关闭数据库连接 

    dbclose(dbprocess); 

 

    return 0; 

}  

[cpp] view
plaincopy

#include <stdio.h>  

#include <string.h>  

#include <stdlib.h>  

#include <unistd.h>   

   

#include <sybfront.h> //freetds头文件  

#include <sybdb.h> //freetds  

   

   

int main(void)  

{  

    char szUsername[32] = "sa";  

    char szPassword[32] = "zkl";  

    char szDBName[32] = "test"; //数据库名  

    char szServer[32] = "192.168.232.133:1433";//数据库服务器:端口  

   

    //初始化db-library  

    dbinit();  

         

    //连接数据库  

    LOGINREC *loginrec = dblogin();  

    DBSETLUSER(loginrec, szUsername);         

    DBSETLPWD(loginrec, szPassword);  

    DBPROCESS *dbprocess = dbopen(loginrec, szServer);//连接数据库  

    if(dbprocess == FAIL)  

    {  

        printf("Conect to MS SQL SERVER fail, exit!\n");  

        return -1;   

    }  

    printf("Connect to MS SQL SERVER success!\n");  

         

    if(dbuse(dbprocess, szDBName) == FAIL)  

        printf("Open database failed!\n");  

    else  

        printf("Open database success!\n");  

         

    //查询数据库  

    printf("[查询数据库表]\n");  

    dbcmd(dbprocess, "select StuID, Name, Age from StuInfo");  

    if(dbsqlexec(dbprocess) == FAIL)  

    {  

        printf("Query table 'StuInfo' error.\n");  

        return -1;   

    }  

       

    DBINT result_code;  

    char szStuID[20]={};  

    char szName[80]={};  

    char szAge[10]={};  

    int rows = 0;  

    while ((result_code = dbresults(dbprocess)) != NO_MORE_RESULTS){  

        if (result_code == SUCCEED){  

            dbbind(dbprocess, 1, CHARBIND, (DBINT)0, (BYTE*)szStuID);  

            dbbind(dbprocess, 2, CHARBIND, (DBCHAR)0, (BYTE*)szName);  

            dbbind(dbprocess, 3, CHARBIND, (DBCHAR)0, (BYTE*)szAge);  

            printf("StuID\tName\tAge\n", szStuID);  

            while (dbnextrow(dbprocess) != NO_MORE_ROWS){                          

                printf("%s\t", szStuID);  

                printf("%s\t", szName);  

                printf("%s\n", szAge);  

            }  

        }  

    }         

   

    printf("[插入数据到数据库表]\n");  

    dbcmd(dbprocess, "insert into StuInfo(StuID, Name, Age) values(888,'James',28)");  

    if(dbsqlexec(dbprocess) == FAIL)  

    {  

        printf("insert into table 'StuInfo' error.\n");  

        return -1;   

    }  

    printf("insert into table 'StuInfo' success.\n");  

      

    printf("[删除数据库表中的记录]\n");  

    dbcmd(dbprocess, "delete from StuInfo where StuID=888");  

    if(dbsqlexec(dbprocess) == FAIL)  

    {  

        printf("delete from table 'StuInfo' error.\n");  

        return -1;   

    }  

    printf("delete from table 'StuInfo' success.\n");  

      

    //关闭数据库连接  

    dbclose(dbprocess);  

  

    return 0;  

}   

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

Makefile:

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

default:
gcc test.c -o test -L/usr/local/freetds/lib -lsybdb -I/usr/local/freetds/include

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