1 Star 0 Fork 2

jingnx/freetds-samples

forked from 金泉/freetds-samples 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
sample1.c 5.70 KB
一键复制 编辑 原始数据 按行查看 历史
金泉 提交于 2021-02-14 17:45 . update sample1.c.
/***************************************************************
* 链接freetds-devel库: /usr/lib64/libsybdb.so.5.1.0
* $ gcc sample1.c -L/usr/lib64 -lsybdb -o sample1
* Windows Server 防火墙需要创建mssql入站规则:打开默认的1433端口
***************************************************************/
#include <sybfront.h>
#include <sybdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
typedef struct __mssql_conn
{
char SQL_SERVER_IP[16];
char SQL_SERVER_PORT[8];
char SQL_SERVER[32];
char user[32];
char pass[64];
char db[16];
char table[32];
DBINT result_code; //定义保存数据库交易结果的类型
DBPROCESS *dbprocess; //数据库连接结果的句柄
}MSSQL_CONN;
void mssql_conn_construct(MSSQL_CONN* conn, char* SQL_SERVER_IP, int SQL_SERVER_PORT,
char* user, char* pass,
char* db )
{
//char s_port[25];
//itoa(SQL_SERVER_PORT, s_port, 10); //here 10 means decimal
strcpy(conn->SQL_SERVER_IP, SQL_SERVER_IP);
sprintf(conn->SQL_SERVER_PORT, "%d", SQL_SERVER_PORT);
sprintf(conn->SQL_SERVER, "%s:%d", SQL_SERVER_IP, SQL_SERVER_PORT);
strcpy(conn->user, user);
strcpy(conn->pass, pass);
strcpy(conn->db, db);
//strcpy(conn->table, table);
}
int mssql_conn_open(MSSQL_CONN* conn)
{
//建立到MSSQL数据库的连接------------------------
dbinit(); //使用dbinit()函数, 进行freetds操作之前的初始化操作
LOGINREC *loginrec = dblogin(); //建立一个到数据库的连接的句柄
DBSETLUSER(loginrec, conn->user); //向句柄中添加连接数据库的用户
DBSETLPWD(loginrec, conn->pass); //向数据库连接句柄中添加密码
conn->dbprocess = dbopen(loginrec, conn->SQL_SERVER); //连接数据库,并返回数据库连接结果的句柄
if(conn->dbprocess == FAIL) //如果连接失败
{
fprintf(stderr, "Connect Fail\n"); //在标准错误中输出信息
//exit(EXIT_FAILURE); //进程异常退出
return 1;
}
else //如果连接成功
{
printf("Connect success\n");
}
if(dbuse(conn->dbprocess, conn->db) == FAIL) //使用某个数据库,如果使用失败
{
dbclose(conn->dbprocess); //关闭数据库连接句柄, 并且回收相关资源
//exit(EXIT_FAILURE); //进程异常退出
return 2;
}
return 0;
}
int main(int argc, char* argv[])
{
MSSQL_CONN conn;
mssql_conn_construct(&conn, "172.24.1.122", 1433,
"sa", "passw0rd",
"testDB");
//建立到MSSQL数据库的连接------------------------
mssql_conn_open(&conn);
//开始进行数据库中数据查询的工作------------------
char mssqlbuf[1024]; //定义保存数据库查询语句的字符串
memset(mssqlbuf, 0x00, sizeof(mssqlbuf)); //开始初始化字符串
char sql[1024]; memset(sql, 0, 1024);
sprintf(mssqlbuf, "SELECT name, age FROM testTable"); //组装操作sql的语句, 将sql语句保存到mssqlbuf
dbcmd(conn.dbprocess, mssqlbuf); //将刚刚组装好的sql命令, 使用dbcmd命令保存到数据库连接句柄的缓存中
if(dbsqlexec(conn.dbprocess) == FAIL) //如果执行的命令失败
{
dbclose(conn.dbprocess); //关闭数据库操作进程
exit(EXIT_FAILURE); //程序异常退出
}
char name[100]; //定义两个变量来保存绑定出来的数据
char age[10];
memset(name, 0x00, sizeof(name)); //对数组进行初始化
memset(age, 0x00, sizeof(age));
//开始对数据取出的进行操作-------------------------
if((conn.result_code = dbresults(conn.dbprocess)) != NO_MORE_RESULTS && conn.result_code == SUCCEED) //如果sql命令执行成功
{
int nCols = dbnumcols(conn.dbprocess);
//开始绑定数据
dbbind(conn.dbprocess, 1, CHARBIND, (DBCHAR)0, (BYTE*)name); //将数据库中查找到的name(sql命令中我们查找的时候name位于结果的第一个), 绑定给本地的name
dbbind(conn.dbprocess, 2, CHARBIND, (DBCHAR)0, (BYTE*)age); //将数据库中查找到的age(sql命令中我们查找的时候age位于结果的第二个), 绑定给本地的age
while(dbnextrow(conn.dbprocess) != NO_MORE_ROWS) //开始遍历结果集合, 并且没执行一次判断一次是否还有后续数据
{
//这里添加你想要的对取出数据的操作
printf("name: %s, age: %s\n", name, age); //使用printf输出我们取出的name(本机变量), age(本机变量)
memset(name, 0, sizeof(name)); memset(age, 0, sizeof(argc));
}
int nRows = dbcount(conn.dbprocess); //统计及结果集被处理的行数
printf("nCols=%d\tnRows=%d\n", nCols, nRows);
}
dbclose(conn.dbprocess); //关闭数据库连接
return 0;
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
C
1
https://gitee.com/jingnx/freetds-samples.git
git@gitee.com:jingnx/freetds-samples.git
jingnx
freetds-samples
freetds-samples
master

搜索帮助

0d507c66 1850385 C8b1a773 1850385