一个连接SqlServer数据库并执行增删查改的C++代码示例,要求带代码注释
时间: 2024-02-12 22:05:40 浏览: 106
以下是使用 C++ 连接 SQL Server 数据库并执行增删查改操作的示例代码,注释中标注了主要的代码功能:
```c++
#include <iostream>
#include <windows.h>
#include <sqltypes.h>
#include <sql.h>
#include <sqlext.h>
#include <string>
using namespace std;
int main()
{
//连接数据库
SQLHENV env; // 环境句柄
SQLHDBC dbc; // 连接句柄
SQLHSTMT stmt; // 语句句柄
SQLRETURN ret; // 函数返回值
// 分配环境句柄
ret = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
cout << "Error: Failed to allocate environment handle." << endl;
return -1;
}
// 设置环境句柄属性
ret = SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_INTEGER);
if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
cout << "Error: Failed to set environment attribute." << endl;
return -1;
}
// 分配连接句柄
ret = SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);
if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
cout << "Error: Failed to allocate connection handle." << endl;
return -1;
}
// 设置连接属性
string connStr = "DRIVER={SQL Server};SERVER=服务器名;DATABASE=数据库名;UID=用户名;PWD=密码;";
SQLCHAR* connStrPtr = (SQLCHAR*)connStr.c_str();
ret = SQLDriverConnect(dbc, NULL, connStrPtr, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_NOPROMPT);
if (ret != SQL_SUCCESS && ret != SQL_SUCCESS_WITH_INFO) {
cout << "Error: Failed to connect to database." << endl;
return -1;
}
// 执行查询操作
SQLLEN rows; // 返回的行数
SQLCHAR name[50], age[50]; // 保存返回的数据
SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt); // 分配语句句柄
SQLExecDirect(stmt, (SQLCHAR*)"SELECT * FROM 表名", SQL_NTS); // 执行查询语句
while (SQLFetch(stmt) == SQL_SUCCESS) { // 遍历结果集并输出数据
SQLGetData(stmt, 1, SQL_C_CHAR, name, 50, NULL);
SQLGetData(stmt, 2, SQL_C_CHAR, age, 50, NULL);
cout << name << "\t" << age << endl;
}
SQLFreeHandle(SQL_HANDLE_STMT, stmt); // 释放语句句柄
// 执行插入操作
SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt); // 分配语句句柄
SQLExecDirect(stmt, (SQLCHAR*)"INSERT INTO 表名 (字段名1, 字段名2) VALUES ('数据1', '数据2')", SQL_NTS); // 执行插入语句
SQLRowCount(stmt, &rows); // 获取受影响的行数
cout << "Insert rows: " << rows << endl;
SQLFreeHandle(SQL_HANDLE_STMT, stmt); // 释放语句句柄
// 执行修改操作
SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt); // 分配语句句柄
SQLExecDirect(stmt, (SQLCHAR*)"UPDATE 表名 SET 字段名1='修改后的数据1' WHERE 字段名2='数据2'", SQL_NTS); // 执行更新语句
SQLRowCount(stmt, &rows); // 获取受影响的行数
cout << "Update rows: " << rows << endl;
SQLFreeHandle(SQL_HANDLE_STMT, stmt); // 释放语句句柄
// 执行删除操作
SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt); // 分配语句句柄
SQLExecDirect(stmt, (SQLCHAR*)"DELETE FROM 表名 WHERE 字段名='数据'", SQL_NTS); // 执行删除语句
SQLRowCount(stmt, &rows); // 获取受影响的行数
cout << "Delete rows: " << rows << endl;
SQLFreeHandle(SQL_HANDLE_STMT, stmt); // 释放语句句柄
// 关闭连接
SQLDisconnect(dbc); // 断开连接
SQLFreeHandle(SQL_HANDLE_DBC, dbc); // 释放连接句柄
SQLFreeHandle(SQL_HANDLE_ENV, env); // 释放环境句柄
return 0;
}
```
需要注意的是,在实际应用中,需要根据具体情况对连接字符串和 SQL 语句进行修改。同时,为了保证数据安全,建议使用参数化查询。
阅读全文