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

如何连接SQL数据库？步骤与技巧解析。

admin
行业动态
2025-03-07
6

连接SQL数据库要连接SQL数据库，通常需要使用数据库驱动程序和相应的连接字符串。以下是一个Python示例，展示如何使用 pyodbc库连接到SQL Server数据库：“

python，import pyodbc# 定义连接字符串，conn_str = (， "DRIVER={SQL Server};"， "SERVER=your_server_name;"， "DATABASE=your_database_name;"， "UID=your_username;"， "PWD=your_password"，)# 建立连接，conn = pyodbc.connect(conn_str)# 创建一个游标对象，cursor = conn.cursor()# 执行查询，cursor.execute("SELECT FROM your_table_name")# 获取结果，rows = cursor.fetchall()# 打印结果，for row in rows:， print(row)# 关闭连接，cursor.close()，conn.close()，

“请将占位符替换为实际的服务器名称、数据库名称、用户名和密码。

在C语言中连接SQL Server数据库，通常采用ODBC（Open Database Connectivity）接口，以下是详细的步骤和示例代码：

一、准备工作

1、安装必要的库和驱动

安装ODBC驱动：可以从Microsoft官网或使用包管理器（如apt-get、yum等）安装ODBC驱动，在Ubuntu上可以使用以下命令安装：

     sudo apt-get install unixodbc unixodbc-dev

安装SQL Server Native Client：提供了更为专用的功能和优化，可从Microsoft官网下载并安装。

2、配置ODBC数据源

进入控制面板，打开“管理工具” -> “ODBC数据源(32位或64位)”。

在“用户DSN”或“系统DSN”中点击“添加”。

选择合适的SQL Server ODBC驱动，按步骤填写连接信息（服务器、数据库名、用户凭证等）。

测试连接成功后保存数据源。

二、编写C代码连接数据库

1、包含必要的头文件

如何连接SQL数据库？步骤与技巧解析。第1张

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

2、初始化环境

分配环境句柄，并设置ODBC版本环境属性。

   void initialize_environment(SQLHENV env, SQLHDBC dbc) {
       SQLRETURN ret;
       // 分配环境句柄
       ret = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, env);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error allocating environment handle
");
           exit(EXIT_FAILURE);
       }
       // 设置ODBC版本环境属性
       ret = SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (void )SQL_OV_ODBC3, 0);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error setting ODBC version
");
           SQLFreeHandle(SQL_HANDLE_ENV, env);
           exit(EXIT_FAILURE);
       }
       // 分配连接句柄
       ret = SQLAllocHandle(SQL_HANDLE_DBC, env, dbc);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error allocating connection handle
");
           SQLFreeHandle(SQL_HANDLE_ENV, env);
           exit(EXIT_FAILURE);
       }
   }

3、建立连接

使用SQLDriverConnect函数通过提供的数据源名称（DSN）、用户名和密码来连接到SQL Server。

   void connect_to_database(SQLHDBC dbc, const char connection_string) {
       SQLRETURN ret;
       // 连接到数据库
       ret = SQLDriverConnect(dbc, NULL, (SQLCHAR )connection_string, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_NOPROMPT);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error connecting to the database
");
           SQLFreeHandle(SQL_HANDLE_DBC, dbc);
           exit(EXIT_FAILURE);
       } else {
           printf("Connected to the database successfully!
");
       }
   }

4、执行查询

分配语句句柄，并使用SQLExecDirect函数执行SQL查询。

   void execute_query(SQLHDBC dbc, const char query) {
       SQLHSTMT stmt;
       SQLRETURN ret;
       // 分配语句句柄
       ret = SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error allocating statement handle
");
           SQLFreeHandle(SQL_HANDLE_DBC, dbc);
           exit(EXIT_FAILURE);
       }
       // 执行SQL查询
       ret = SQLExecDirect(stmt, (SQLCHAR )query, SQL_NTS);
       if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
           fprintf(stderr, "Error executing query
");
           SQLFreeHandle(SQL_HANDLE_STMT, stmt);
           SQLFreeHandle(SQL_HANDLE_DBC, dbc);
           exit(EXIT_FAILURE);
       } else {
           printf("Query executed successfully
");
           // 处理查询结果...
       }
       // 释放语句句柄
       SQLFreeHandle(SQL_HANDLE_STMT, stmt);
   }

5、处理结果集

使用SQLFetch函数获取查询结果，并使用SQLGetData函数读取每一列的数据。

   void process_results(SQLHSTMT stmt) {
       SQLCHAR col1[256];
       SQLCHAR col2[256];
       while (SQLFetch(stmt) == SQL_SUCCESS) {
           SQLGetData(stmt, 1, SQL_C_CHAR, col1, sizeof(col1), NULL);
           SQLGetData(stmt, 2, SQL_C_CHAR, col2, sizeof(col2), NULL);
           printf("Col1: %s, Col2: %s
", col1, col2);
       }
   }

6、关闭连接和释放资源

在完成数据库操作后，需要关闭连接并释放分配的句柄。

   void close_connection(SQLHDBC dbc) {
       SQLDisconnect(dbc);
       SQLFreeHandle(SQL_HANDLE_DBC, dbc);
   }

三、完整示例代码

以下是一个将上述步骤整合在一起的完整示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <sql.h>
#include <sqlext.h>
void initialize_environment(SQLHENV env, SQLHDBC dbc);
void connect_to_database(SQLHDBC dbc, const char connection_string);
void execute_query(SQLHDBC dbc, const char query);
void process_results(SQLHSTMT stmt);
void close_connection(SQLHDBC dbc);
int main() {
    SQLHENV henv;
    SQLHDBC hdbc;
    const char connection_string = "DSN=mydsn;UID=myusername;PWD=mypassword"; // 根据实际配置修改
    const char query = "SELECT  FROM my_table"; // 根据实际查询修改
    // 初始化环境
    initialize_environment(&henv, &hdbc);
    // 连接到数据库
    connect_to_database(hdbc, connection_string);
    // 执行查询
    execute_query(hdbc, query);
    // 处理结果集...（此处省略，可根据需要调用process_results函数）
    // 关闭连接
    close_connection(hdbc);
    return 0;
}