数据库C语言如何连接SQLServer数据库

1. 介绍

C语言是一种非常常用的编程语言，在开发过程中需要与数据库进行连接，而SQLServer是一种常用的数据库。本文将详细介绍如何在C语言中连接SQLServer数据库。

2. 准备工作

2.1 下载ODBC驱动

在连接SQLServer数据库之前，需要下载ODBC驱动。微软官方提供了ODBC Driver for SQLServer，可以在官网上下载并安装。

2.2 创建数据库

在连接SQLServer数据库之前，需要先创建一个数据库。可以使用SQL Server Management Studio工具，也可以在Azure Portal中创建。

3. 连接数据库

连接SQLServer数据库需要使用ODBC API。下面是连接数据库的步骤：

导入头文件

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

定义一些变量，如连接句柄、语句句柄等

SQLHENV env; // ODBC Environment
SQLHDBC dbc; // Connection handle
SQLHSTMT stmt; // Statement handle
SQLRETURN retcode; // Return code 
  

初始化环境

SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_UINTEGER);
SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);
  

连接数据库

retcode = SQLConnect(dbc, (SQLCHAR *) "my_database", SQL_NTS, (SQLCHAR *) "my_username", SQL_NTS, (SQLCHAR *) "my_password", SQL_NTS);
  

注意：其中"my_database"是你创建的数据库名称，"my_username"和"my_password"是你连接数据库时使用的用户名和密码。

创建语句句柄

retcode = SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt);
  

4. 查询数据库

连接上数据库之后，可以使用SQL语句进行查询。下面是查询的一个例子：

SELECT * FROM my_table

执行查询的步骤如下：

将查询语句放入语句句柄中

SQLCHAR *query = (SQLCHAR *)"SELECT * FROM my_table"; // SQL query
SQLExecDirect(stmt, query, SQL_NTS);
  

注意：其中"my_table"是你查询的表名。

获取查询结果

SQLCHAR column1[256], column2[256], column3[256], column4[256];
SQLBindCol(stmt, 1, SQL_C_CHAR, &column1, sizeof(column1), NULL);
SQLBindCol(stmt, 2, SQL_C_CHAR, &column2, sizeof(column2), NULL);
SQLBindCol(stmt, 3, SQL_C_CHAR, &column3, sizeof(column3), NULL);
SQLBindCol(stmt, 4, SQL_C_CHAR, &column4, sizeof(column4), NULL);
while(SQLFetch(stmt) != SQL_NO_DATA) {
    printf("%s %s %s %s\n", column1, column2, column3, column4);
}
  

注意：需要使用SQLBindCol函数将查询结果绑定到变量中，然后使用SQLFetch函数逐行获取查询结果。

5. 关闭连接

连接数据库之后，需要使用SQLDisconnect函数断开与数据库的连接：

SQLDisconnect(dbc);
  

6. 完整代码

下面是完整的连接SQLServer数据库的代码：

#include <stdio.h>
#include <sql.h>
#include <sqlext.h>  
int main() {
    SQLHENV env; // ODBC Environment
    SQLHDBC dbc; // Connection handle
    SQLHSTMT stmt; // Statement handle
    SQLRETURN retcode; // Return code 
    // Initialize the ODBC environment
    SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
    SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_UINTEGER);
    // Connect to the database
    SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);
    retcode = SQLConnect(dbc, (SQLCHAR *) "my_database", SQL_NTS, (SQLCHAR *) "my_username", SQL_NTS, (SQLCHAR *) "my_password", SQL_NTS);
    if(!SQL_SUCCEEDED(retcode)) {
        printf("Failed to connect to database!");
        SQLFreeHandle(SQL_HANDLE_DBC, dbc);
        SQLFreeHandle(SQL_HANDLE_ENV, env);
        return 1;
    }
    // Create statement handle
    retcode = SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt);
    if(!SQL_SUCCEEDED(retcode)) {
        printf("Failed to allocate statement handle!");
        SQLDisconnect(dbc);
        SQLFreeHandle(SQL_HANDLE_DBC, dbc);
        SQLFreeHandle(SQL_HANDLE_ENV, env);
        return 1;
    }
    // Execute a SQL query
    SQLCHAR *query = (SQLCHAR *)"SELECT * FROM my_table";
    SQLExecDirect(stmt, query, SQL_NTS);
    // Get query results
    SQLCHAR column1[256], column2[256], column3[256], column4[256];
    SQLBindCol(stmt, 1, SQL_C_CHAR, &column1, sizeof(column1), NULL);
    SQLBindCol(stmt, 2, SQL_C_CHAR, &column2, sizeof(column2), NULL);
    SQLBindCol(stmt, 3, SQL_C_CHAR, &column3, sizeof(column3), NULL);
    SQLBindCol(stmt, 4, SQL_C_CHAR, &column4, sizeof(column4), NULL);
    while(SQLFetch(stmt) != SQL_NO_DATA) {
        printf("%s %s %s %s\n", column1, column2, column3, column4);
    }
    // Clean up resources
    SQLDisconnect(dbc);
    SQLFreeHandle(SQL_HANDLE_DBC, dbc);
    SQLFreeHandle(SQL_HANDLE_STMT, stmt);
    SQLFreeHandle(SQL_HANDLE_ENV, env);
    return 0;
}

7. 总结

本文介绍了如何在C语言中连接SQLServer数据库，并且使用ODBC API执行SQL查询。连接数据库需要下载ODBC驱动，创建数据库，并且使用SQLConnect函数连接数据库。执行查询需要将SQL语句放入语句句柄中，使用SQLBindCol函数将查询结果绑定到变量中，然后使用SQLFetch函数逐行获取查询结果。