C语言连接SQL Server数据库

前言

在日常的软件开发中，经常会用到与数据库的连接操作。而在C语言中，连接SQL Server数据库也是一件非常常见的事情。下面将详细介绍如何使用C语言连接SQL Server数据库。

准备工作

安装ODBC驱动

首先，我们需要下载并安装ODBC驱动。ODBC（开放式数据库连?接）是一种连接数据库的标准接口，可以使不同的应用程序和数据库管理系统协同工作，从而在一个统一的界面下完成数据库操作。

通过访问Microsoft的官网，我们可以下载相应版本的ODBC驱动。注意要根据操作系统和应用程序的位数来选择相应版本的驱动。下载完后，安装即可。

创建ODBC数据源

在安装ODBC驱动后，我们需要创建ODBC数据源。在Windows中，我们可以在“控制面板”>“管理工具”>“ODBC数据源(32位)”中找到ODBC数据源管理员。在管理员中，我们可以创建用户数据源和系统数据源。

用户数据源只对当前用户可见，而系统数据源对系统中所有用户都可见。在创建数据源时，需要选择SQL Server驱动，然后填写数据库服务器名称和登录信息。填写完成后，就可以测试连接是否成功。

建立连接

在安装ODBC驱动并创建数据源后，我们就可以开始建立连接了。下面是建立连接的具体步骤：

引入头文件

在C语言中，连接SQL Server数据库需要引入头文件 sql.h 和 sqlext.h。

#include <stdio.h>
#include <stdlib.h>
#include <sql.h>
#include <sqlext.h>

定义变量

在建立连接前，需要定义一些变量。

SQLHANDLE henv; // 环境句柄
SQLHANDLE hdbc; // 连接句柄
SQLRETURN retcode; // 返回值

初始化环境句柄

环境句柄是ODBC连接所需的一个对象，它可以管理ODBC配置和连接。我们需要调用SQLAllocHandle函数来初始化环境句柄。

retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error allocating SQL environment handle.\n");
    return -1;
}

设置ODBC版本

我们需要调用SQLSetEnvAttr函数来设置ODBC版本。通常情况下，我们可以设置为3。

retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, 0);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error setting ODBC version.\n");
    return -1;
}

初始化连接句柄

连接句柄是ODBC连接所需的另一个对象，它可以管理一个数据库连接。我们需要调用SQLAllocHandle函数来初始化连接句柄。

retcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error allocating SQL connection handle.\n");
    return -1;
}

连接数据库

在初始化连接句柄后，我们可以调用SQLConnect函数来连接数据库。需要传入ODBC数据源名称、用户名、密码等信息。

SQLCHAR* dsn = "mydsn";
SQLCHAR* uid = "myusername";
SQLCHAR* pwd = "mypassword";
retcode = SQLConnect(hdbc, (SQLCHAR*)dsn, SQL_NTS, (SQLCHAR*)uid, SQL_NTS, (SQLCHAR*)pwd, SQL_NTS);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error connecting SQL Server.\n");
    return -1;
}

执行SQL语句

定义变量

在执行SQL语句前，需要定义一些变量。

SQLHANDLE hstmt; // 语句句柄
SQLCHAR* sql = "SELECT * FROM mytable"; // 要执行的SQL语句
SQLRETURN result; // 执行结果

初始化语句句柄

语句句柄是ODBC执行SQL语句所需的对象，它管理一个SQL语句的执行状态、返回结果等信息。我们需要调用SQLAllocHandle函数来初始化语句句柄。

retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error allocating SQL statement handle.\n");
    return -1;
}

执行SQL语句

在初始化语句句柄后，我们可以调用SQLExecDirect函数来执行SQL语句。需要传入语句句柄和要执行的SQL语句。

retcode = SQLExecDirect(hstmt, (SQLCHAR*)sql, SQL_NTS);
if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
    printf("Error executing SQL statement.\n");
    return -1;
}

获取执行结果

执行SQL语句后，我们可以调用SQLFetch函数来获取查询结果。

while (SQLFetch(hstmt) == SQL_SUCCESS) {
    // 处理查询结果
}

关闭连接

在完成数据库操作后，我们需要关闭连接。

关闭语句句柄

首先，需要调用SQLFreeHandle函数来关闭语句句柄。

SQLFreeHandle(SQL_HANDLE_STMT, hstmt);

关闭连接句柄

最后，需要调用SQLDisconnect函数来关闭连接句柄。

SQLDisconnect(hdbc);

释放环境句柄

如果不再使用ODBC连接，需要释放环境句柄。

SQLFreeHandle(SQL_HANDLE_ENV, henv);

完整代码示例

下面是完整代码示例：

#include <stdio.h>
#include <stdlib.h>
#include <sql.h>
#include <sqlext.h>
int main() {
    // 初始化环境句柄
    SQLHANDLE henv;
    SQLHANDLE hdbc;
    SQLRETURN retcode;
    retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error allocating SQL environment handle.\n");
        return -1;
    }
    retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, 0);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error setting ODBC version.\n");
        return -1;
    }
    // 初始化连接句柄
    retcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error allocating SQL connection handle.\n");
        return -1;
    }
    // 连接数据库
    SQLCHAR* dsn = "mydsn";
    SQLCHAR* uid = "myusername";
    SQLCHAR* pwd = "mypassword";
    retcode = SQLConnect(hdbc, (SQLCHAR*)dsn, SQL_NTS, (SQLCHAR*)uid, SQL_NTS, (SQLCHAR*)pwd, SQL_NTS);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error connecting SQL Server.\n");
        return -1;
    }
    // 执行SQL语句
    SQLHANDLE hstmt;
    retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error allocating SQL statement handle.\n");
        return -1;
    }
    SQLCHAR* sql = "SELECT * FROM mytable";
    retcode = SQLExecDirect(hstmt, (SQLCHAR*)sql, SQL_NTS);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        printf("Error executing SQL statement.\n");
        return -1;
    }
    while (SQLFetch(hstmt) == SQL_SUCCESS) {
        // 处理查询结果
    }
    // 关闭连接
    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
    SQLDisconnect(hdbc);
    SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
    SQLFreeHandle(SQL_HANDLE_ENV, henv);
    return 0;
}

总结

通过以上步骤，我们可以轻松使用C语言连接SQL Server数据库并进行数据操作。在实际开发过程中，需要根据具体的需求进行相应的修改和优化。