当前位置：首页 > 行业动态 > 正文

c 读取access数据库

admin
行业动态
2025-02-27
1

简答使用C语言连接和读取Access数据库，通常需要借助ODBC（开放数据库连接）接口。确保已安装Microsoft Access数据库引擎和ODBC驱动程序。通过包含` 和`头文件，使用SQL语句连接到Access数据库并执行查询操作。

在C语言中读取Access数据库，通常采用ODBC（Open Database Connectivity）驱动的方式，这种方法具有广泛的兼容性和灵活性，适用于多种数据库操作场景，以下是详细步骤及相关代码示例：

准备工作

1、安装必要的驱动：确保系统上安装了Microsoft Access Database Engine驱动程序，以便通过ODBC连接到Access数据库文件。

2、配置ODBC数据源：在Windows系统中，打开控制面板中的“管理工具”，找到“ODBC数据源（32位或64位）”，在“用户DSN”或“系统DSN”标签页中，点击“添加”按钮，选择“Microsoft Access Driver (*.mdb, *.accdb)”，然后填写数据源名称（DSN），并选择要连接的Access数据库文件。

编写C代码

1、包含头文件：使用ODBC API时，需要包含相应的头文件。

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

2、初始化ODBC环境：分配环境句柄并设置ODBC版本。

c 读取access数据库

   SQLHENV hEnv;
   SQLHDBC hDbc;
   SQLHSTMT hStmt;
   SQLRETURN ret;
   void initODBC() {
       // 初始化环境句柄
       ret = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &hEnv);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to allocate ODBC environment handle
");
           exit(EXIT_FAILURE);
       }
       // 设置ODBC版本
       ret = SQLSetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION, (void *)SQL_OV_ODBC3, 0);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to set ODBC version
");
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
   }

3、连接数据库：使用已经配置的DSN连接Access数据库。

   void connectToDatabase(const char *dsn) {
       // 分配连接句柄
       ret = SQLAllocHandle(SQL_HANDLE_DBC, hEnv, &hDbc);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to allocate ODBC connection handle
");
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
       // 连接到数据库
       ret = SQLConnect(hDbc, (SQLCHAR *)dsn, SQL_NTS, NULL, 0, NULL, 0);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to connect to the database
");
           SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
   }

4、执行SQL查询：连接成功后，可以执行SQL查询语句。

   void executeQuery(const char *query) {
       // 分配语句句柄
       ret = SQLAllocHandle(SQL_HANDLE_STMT, hDbc, &hStmt);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to allocate ODBC statement handle
");
           SQLDisconnect(hDbc);
           SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
       // 执行SQL查询
       ret = SQLExecDirect(hStmt, (SQLCHAR *)query, SQL_NTS);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Failed to execute SQL query
");
           SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
           SQLDisconnect(hDbc);
           SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
   }

5、读取查询结果：执行查询后，读取结果并输出。

c 读取access数据库

   void fetchResults() {
       SQLCHAR columnName[128];
       SQLCHAR columnValue[128];
       SQLSMALLINT columns;
       SQLSMALLINT columnNameLength;
       SQLSMALLINT columnValueLength;
       // 获取列数
       ret = SQLNumResultCols(hStmt, &columns);
       if (ret != SQL_SUCCESS) {
           fprintf(stderr, "Error getting number of columns
");
           SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
           SQLDisconnect(hDbc);
           SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
       // 循环读取每行数据
       while ((ret = SQLFetch(hStmt)) == SQL_SUCCESS) {
           for (int i = 1; i <= columns; i++) {
               ret = SQLGetData(hStmt, i, SQL_C_CHAR, columnValue, sizeof(columnValue), NULL);
               if (ret == SQL_SUCCESS) {
                   printf("%s: %s
", columnName, columnValue);
               } else {
                   fprintf(stderr, "Error getting data from column %d
", i);
               }
           }
       }
       if (ret != SQL_NO_DATA) {
           fprintf(stderr, "Error fetching data
");
           SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
           SQLDisconnect(hDbc);
           SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
           SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
           exit(EXIT_FAILURE);
       }
   }

6、释放资源：关闭语句句柄、连接句柄和环境句柄。

   void cleanup() {
       SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
       SQLDisconnect(hDbc);
       SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
       SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
   }

7、主函数：调用上述函数，实现完整的数据库读取流程。

   int main() {
       initODBC();
       connectToDatabase("DSN=MyAccessDB;"); // 替换为实际的DSN名称
       executeQuery("SELECT * FROM MyTable"); // 替换为实际的SQL查询语句
       fetchResults();
       cleanup();
       return 0;
   }