21xrx.com
2024-09-19 09:21:49 Thursday
登录
文章检索 我的文章 写文章
如何在C++中调用SQL Server存储过程？
2023-06-27 22:01:16 深夜i     --     --
C++ SQL Server 存储过程 调用

在C++开发中，使用SQL Server存储过程可以提高程序执行效率，并且可以减少对数据库的频繁访问。但是，如何在C++中调用SQL Server存储过程呢？本文将为您详细介绍。

一、连接SQL Server数据库

首先，我们需要在C++程序中连接SQL Server数据库，这可以使用ODBC（Open Database Connectivity）实现。可以使用ODBC连接数据库的原因在于，ODBC是一个标准的API，支持多种数据库，包括SQL Server、MySQL等。连接SQL Server数据库的代码示例如下：



#include <sqltypes.h>


#include <sql.h>


#include <sqlext.h>


#include <string>


using namespace std;


// 定义连接句柄


SQLHENV env;


SQLHDBC dbc;


// 连接数据库


SQLRETURN connect() {


  // 创建环境句柄


  SQLRETURN retcode;


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


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


    cout << "环境句柄创建失败" << endl;


    return retcode;


  


  // 设置ODBC版本及行为


  retcode = SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, 0);


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


    SQLFreeHandle(SQL_HANDLE_ENV, env);


    cout << "ODBC版本设置失败" << endl;


    return retcode;


  }


  // 分配数据库连接句柄


  SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);


  // 连接数据库


  std::string driver = "DRIVER={SQL Server Native Client 11.0};SERVER=127.0.0.1;UID=sa;PWD=123456;DATABASE=test;";


  char* connstr = new char[driver.length() + 1];


  strcpy_s(connstr, driver.length() + 1, driver.c_str());


  retcode = SQLDriverConnect(dbc, NULL, (SQLCHAR*)connstr, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_COMPLETE);


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


    SQLFreeHandle(SQL_HANDLE_DBC, dbc);


    SQLFreeHandle(SQL_HANDLE_ENV, env);


    delete[] connstr;


    cout << "连接数据库失败" << endl;


    return retcode;


  }


  delete[] connstr;


  return retcode;


}

上面的代码创建了一个连接句柄env和一个数据库连接句柄dbc，然后通过SQLAllocHandle函数分配连接句柄env和数据库连接句柄dbc，最后使用SQLDriverConnect函数连接数据库，其中的连接字符串可以根据具体情况进行修改。

二、调用存储过程

连接数据库成功后，我们可以使用SQL语句调用存储过程，代码示例如下：



// 调用存储过程


SQLRETURN call_proc() {


  // 准备调用存储过程的SQL语句


  std::string sqlstr = "{CALL my_proc(?,?)}";


  SQLCHAR* sql = new SQLCHAR[sqlstr.length() + 1];


  strcpy_s((char*)sql, sqlstr.length() + 1, sqlstr.c_str());


  // 定义参数


  SQLCHAR* inparam1 = new SQLCHAR[10];


  strcpy_s((char*)inparam1, 10, "hello");


  SQLCHAR* outparam2 = new SQLCHAR[11];


  SQLLEN outparam2len;


  // 准备执行存储过程的语句


  SQLHSTMT stmt;


  SQLRETURN retcode;


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


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


    delete[] sql;


    delete[] inparam1;


    delete[] outparam2;


    cout << "分配语句句柄失败" << endl;


    return retcode;


  }


  // 绑定输入参数


  retcode = SQLBindParameter(stmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, 5, 0, inparam1, 0, NULL);


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


    SQLFreeHandle(SQL_HANDLE_STMT, stmt);


    delete[] sql;


    delete[] inparam1;


    delete[] outparam2;


    cout << "绑定输入参数失败" << endl;


    return retcode;


  }


  // 绑定输出参数


  retcode = SQLBindParameter(stmt, 2, SQL_PARAM_OUTPUT, SQL_C_CHAR, SQL_VARCHAR, 11, 0, outparam2, 0, &outparam2len);


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


    SQLFreeHandle(SQL_HANDLE_STMT, stmt);


    delete[] sql;


    delete[] inparam1;


    delete[] outparam2;


    cout << "绑定输出参数失败" << endl;


    return retcode;


  }


  // 执行存储过程的语句


  retcode = SQLExecDirect(stmt, sql, SQL_NTS);


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


    SQLFreeHandle(SQL_HANDLE_STMT, stmt);


    delete[] sql;


    delete[] inparam1;


    delete[] outparam2;


    cout << "调用存储过程失败" << endl;


    return retcode;


  }


  // 获取输出参数


  SQLFetch(stmt);


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


    SQLFreeHandle(SQL_HANDLE_STMT, stmt);


    delete[] sql;


    delete[] inparam1;


    delete[] outparam2;


    cout << "获取输出参数失败" << endl;


    return retcode;


  }


  cout << "调用存储过程成功，输出：" << outparam2 << endl;


  SQLFreeHandle(SQL_HANDLE_STMT, stmt);


  delete[] sql;


  delete[] inparam1;


  delete[] outparam2;


  return retcode;


}

上面的代码准备了两个参数inparam1、outparam2，其中inparam1为输入参数，outparam2为输出参数，使用SQLBindParameter函数进行参数绑定，然后使用SQLExecDirect函数执行存储过程的语句，最后使用SQLFetch函数获取输出参数。

总结

以上就是在C++中调用SQL Server存储过程的方法，通过ODBC连接数据库，使用SQL语句调用存储过程，并获取执行结果。如果遇到问题可以参考以上代码，或查阅相关文档进行学习。

  
  

评论区

{{item['qq_nickname']}}
()
回复
回复