c语言编程中高效操作MSSQL

撸码网

2024-08-29 18:04:03

0次

1. MSSQL简介

MSSQL是一种关系型数据库管理系统，它被广泛应用于企业级应用程序中。在C语言编程中，通过ODBC可以实现与MSSQL的连接，进而对数据库进行高效的操作和管理。

2. ODBC连接MSSQL

ODBC是一种数据库标准连接接口，它可以连接各种不同类型的数据库。在C语言中，ODBC提供了实现与MSSQL连接的方法。

2.1 连接字符串

在连接MSSQL时，需要提供以下信息构造连接字符串：

数据源名称（DSN）：用于连接数据库

服务器名称：连接MSSQL所在的服务器名称

用户名和密码：用于登录MSSQL的用户名和密码

默认数据库：连接成功后默认使用的数据库

连接字符串的格式如下：



"DSN=<数据源名称>;SERVER=<服务器名称>;UID=<用户名>;PWD=<密码>;DATABASE=<默认数据库>"

其中，尖括号内的信息需要根据实际情况填写。

2.2 连接MSSQL

连接MSSQL需要调用ODBC库中的函数。以下是连接MSSQL的基本步骤：

加载ODBC库

定义连接句柄

构造连接字符串

连接MSSQL

处理连接错误

代码实现如下：



#include <windows.h>


#include <sql.h>


#include <sqlext.h>


SQLHANDLE henv;   // 环境句柄


SQLHANDLE hdbc;   // 连接句柄


// 连接MSSQL的函数


int connect_database(char *DSN, char *username, char *password) {


  SQLRETURN retcode;


  SQLCHAR outstr[1024];


  SQLSMALLINT outstrlen;


  // Step 1: 加载ODBC库


  retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*) SQL_OV_ODBC3, 0);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  // Step 2: 定义连接句柄


  retcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  // Step 3: 构造连接字符串


  SQLCHAR *dsn = (SQLCHAR*) DSN;


  SQLCHAR *uid = (SQLCHAR*) username;


  SQLCHAR *pwd = (SQLCHAR*) password;


  retcode = SQLDriverConnect(hdbc, NULL, dsn, SQL_NTS, outstr, sizeof(outstr), &outstrlen, SQL_DRIVER_NOPROMPT);


  // Step 4: 连接MSSQL


  if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {


    // 连接成功，打印连接信息


    printf("Connected MSSQL.\\n");


    printf("%s\\n", outstr);


  }


  else {


    // 处理错误


    return -1;


  }


  return 0;


}

以上代码中需要注意几点：

ODBC库需要加载成功

连接句柄需要定义成功

构造字符串时注意数据类型转换

连接信息打印需要在连接成功后执行

3. MSSQL操作

连接成功后，就可以通过调用ODBC库中的函数来进行MSSQL的操作了。

3.1 执行SQL语句

执行SQL语句需要调用ODBC库中的SQLExecDirect函数。以下是执行SQL语句的基本步骤：

定义状态变量和SQL语句变量

执行SQL语句

处理执行结果

代码实现如下：



// 执行SQL语句的函数


int execute_sql(char *sql) {


  SQLRETURN retcode;


  SQLHSTMT hstmt;


  SQLINTEGER sqlcode;


  // Step 1: 定义状态变量和SQL语句变量


  retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  // Step 2: 执行SQL语句


  SQLCHAR* query = (SQLCHAR*) sql;


  retcode = SQLExecDirect(hstmt, query, SQL_NTS);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    SQLCloseCursor(hstmt);


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


  // Step 3: 处理执行结果


  retcode = SQLFetch(hstmt);


  if (retcode == SQL_NO_DATA) {


    // 执行成功


    SQLCloseCursor(hstmt);


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return 0;


  }


  else if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {


    // 执行成功，但结果不为空


    SQLCloseCursor(hstmt);


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return 1;


  }


  else {


    // 处理错误


    SQLCloseCursor(hstmt);


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


}

以上代码中需要注意几点：

状态变量和SQL语句变量需要定义成功

SQL语句需要进行数据类型转换

执行结果需要根据返回值进行判断

3.2 插入数据

插入数据需要使用SQL语句INSERT INTO。以下是插入数据的基本步骤：

定义状态变量和SQL语句变量

将数据绑定到SQL语句

执行SQL语句并提交

处理执行结果

代码实现如下：



// 插入数据的函数


int insert_data(char *temperature, char *humidity) {


  SQLRETURN retcode;


  SQLHSTMT hstmt;


  // Step 1: 定义状态变量和SQL语句变量


  retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  // Step 2: 将数据绑定到SQL语句


  SQLCHAR* sql = (SQLCHAR*)"INSERT INTO weather (temperature, humidity) VALUES (?, ?)";


  retcode = SQLPrepare(hstmt, sql, SQL_NTS);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


  SQLLEN cbTemp = strlen(temperature);


  SQLLEN cbHumidity = strlen(humidity);


  SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, cbTemp, 0, temperature, cbTemp, NULL);


  SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, cbHumidity, 0, humidity, cbHumidity, NULL);


  // Step 3: 执行SQL语句并提交


  retcode = SQLExecute(hstmt);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


  SQLLEN rowCount;


  retcode = SQLRowCount(hstmt, &rowCount);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


  // Step 4: 处理执行结果


  SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


  return 0;


}

以上代码中需要注意几点：

状态变量和SQL语句变量需要定义成功

数据需要进行数据类型转换

执行结果需要返回受影响的行数

3.3 查询数据

查询数据需要使用SQL语句SELECT。以下是查询数据的基本步骤：

定义状态变量和SQL语句变量

执行SQL语句并获取结果数据

处理结果数据

代码实现如下：



// 查询数据的函数


int query_data() {


  SQLRETURN retcode;


  SQLHSTMT hstmt;


  SQLCHAR buf[1024];


  SQLLEN cbData;


  // Step 1: 定义状态变量和SQL语句变量


  retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    return -1;


  }


  // Step 2: 执行SQL语句并获取结果数据


  SQLCHAR* sql = (SQLCHAR*)"SELECT temperature, humidity FROM weather";


  retcode = SQLExecDirect(hstmt, sql, SQL_NTS);


  if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


    // 处理错误


    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


    return -1;


  }


  // Step 3: 处理结果数据


  while (TRUE) {


    retcode = SQLFetch(hstmt);


    if (retcode == SQL_NO_DATA) {


      break;


    }


    else if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


      // 处理错误


      SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


      return -1;


    }


    retcode = SQLGetData(hstmt, 1, SQL_C_CHAR, buf, sizeof(buf), &cbData);


    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


      // 处理错误


      SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


      return -1;


    }


    printf("Temperature: %s; ", buf);


    retcode = SQLGetData(hstmt, 2, SQL_C_CHAR, buf, sizeof(buf), &cbData);


    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {


      // 处理错误


      SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


      return -1;


    }


    printf("Humidity: %s\\n", buf);


  }


  SQLFreeHandle(SQL_HANDLE_STMT, hstmt);


  return 0;


}

以上代码中需要注意几点：

状态变量和SQL语句变量需要定义成功

获取结果数据需要通过SQLGetData函数

处理结果数据需要根据实际需求进行

4. 总结

使用C语言编程操作MSSQL需要掌握ODBC库的基本使用方法，以及MSSQL的常用操作方法。通过本文的介绍，读者可以了解如何连接MSSQL、执行SQL语句、插入数据和查询数据，并在实践中不断提高效率和精度。

免责声明：本文来自互联网，本站所有信息（包括但不限于文字、视频、音频、数据及图表），不保证该信息的准确性、真实性、完整性、有效性、及时性、原创性等，版权归属于原作者，如无意侵犯媒体或个人知识产权，请来电或致函告之，本站将在第一时间处理。猿码集站发布此文目的在于促进信息交流，此文观点与本站立场无关，不承担任何责任。

上一篇：C语言访问MSSQL数据库实战之旅

下一篇：C语言环境下操作MSSQL数据库的表结构研究

相关阅读

数据库标签

SQL热门

SQL更新

免责申明：本站所有文章、数据仅供参考，广告商的言论与行为均与猿码集无关！谨防受骗！ 侵权及不实信息举报邮箱至：amarlboro@yeah.net 渝ICP备2023009929号-1