C++ ADO封装实现SQLserver参数化的增删查改代码

好的，下面是一个简单的 C++ ADO 封装实现 SQL Server 参数化的增删查改的代码示例：
#include <iostream>
#include <string>
#include <comutil.h> // 需要包含此头文件

#pragma comment(lib, "comsuppw.lib") // 需要链接此库文件

class ADOHelper
{
public:
ADOHelper()
{
::CoInitialize(NULL);
m_conn.CreateInstance("ADODB.Connection");
}

~ADOHelper()
{
if (m_conn != NULL)
{
if (m_conn->State == adStateOpen)
m_conn->Close();
m_conn.Release();
}
::CoUninitialize();
}

bool Open(const std::string&amp; connStr)
{
try
{
m_conn->ConnectionString = _bstr_t(connStr.c_str());
m_conn->Open("", "", "", adConnectUnspecified);
return true;
}
catch (_com_error&amp; e)
{
std::cerr << "Open database error: " << e.ErrorMessage() << std::endl;
return false;
}
}

bool Close()
{
try
{
if (m_conn->State == adStateOpen)
m_conn->Close();
return true;
}
catch (_com_error&amp; e)
{
std::cerr << "Close database error: " << e.ErrorMessage() << std::endl;
return false;
}
}

bool ExecuteNonQuery(const std::string&amp; sql, const std::vector<_variant_t>&amp; parameters)
{
try
{
_CommandPtr cmd;
cmd.CreateInstance("ADODB.Command");
cmd->ActiveConnection = m_conn;
cmd->CommandText = _bstr_t(sql.c_str());
cmd->CommandType = adCmdText;

for (size_t i = 0; i < parameters.size(); ++i)
{
_ParameterPtr param = cmd->CreateParameter("", adVariant, adParamInput, 0, parameters[i]);
cmd->Parameters->Append(param);
}

cmd->Execute(NULL, NULL, adExecuteNoRecords);
return true;
}
catch (_com_error&amp; e)
{
std::cerr << "ExecuteNonQuery error: " << e.ErrorMessage() << std::endl;
return false;
}
}

bool ExecuteScalar(const std::string&amp; sql, const std::vector<_variant_t>&amp; parameters, _variant_t&amp; result)
{
try
{
_CommandPtr cmd;
cmd.CreateInstance("ADODB.Command");
cmd->ActiveConnection = m_conn;
cmd->CommandText = _bstr_t(sql.c_str());
cmd->CommandType = adCmdText;

for (size_t i = 0; i < parameters.size(); ++i)
{
_ParameterPtr param = cmd->CreateParameter("", adVariant, adParamInput, 0, parameters[i]);
cmd->Parameters->Append(param);
}

result = cmd->Execute(NULL, NULL, adCmdText | adExecuteNoRecords);
return true;
}
catch (_com_error&amp; e)
{
std::cerr << "ExecuteScalar error: " << e.ErrorMessage() << std::endl;
return false;
}
}

bool ExecuteReader(const std::string&amp; sql, const std::vector<_variant_t>&amp; parameters, _RecordsetPtr&amp; rs)
{
try
{
_CommandPtr cmd;
cmd.CreateInstance("ADODB.Command");
cmd->ActiveConnection = m_conn;
cmd->CommandText = _bstr_t(sql.c_str());
cmd->CommandType = adCmdText;

for (size_t i = 0; i < parameters.size(); ++i)
{
_ParameterPtr param = cmd->CreateParameter("", adVariant, adParamInput, 0, parameters[i]);
cmd->Parameters->Append(param);
}

rs = cmd->Execute(NULL, NULL, adCmdText);
return true;
}
catch (_com_error&amp; e)
{
std::cerr << "ExecuteReader error: " << e.ErrorMessage() << std::endl;
return false;
}
}

private:
_ConnectionPtr m_conn;
};

int main()
{
ADOHelper ado;
ado.Open("Provider=SQLOLEDB;Data Source=(local);Initial Catalog=TestDB;Integrated Security=SSPI;");

// 插入数据
std::string insertSql = "INSERT INTO [dbo].[Person] ([Name], [Age]) VALUES (?, ?)";
std::vector<_variant_t> insertParams = { _variant_t("John"), _variant_t(30) };
ado.ExecuteNonQuery(insertSql, insertParams);

// 查询数据
std::string selectSql = "SELECT [ID], [Name], [Age] FROM [dbo].[Person] WHERE [Age] >= ?";
std::vector<_variant_t> selectParams = { _variant_t(30) };
_RecordsetPtr rs;
ado.ExecuteReader(selectSql, selectParams, rs);
while (!rs->EndOfFile)
{
std::cout << "ID: " << rs->Fields->Item["ID"]->Value.intVal << ", ";
std::cout << "Name: " << (char*)_bstr_t(rs->Fields->Item["Name"]->Value) << ", ";
std::cout << "Age: " << rs->Fields->Item["Age"]->Value.intVal << std::endl;
rs->MoveNext();
}

// 更新数据
std::string updateSql = "UPDATE [dbo].[Person] SET [Age] = ? WHERE [Name] = ?";
std::vector<_variant_t> updateParams = { _variant_t(35), _variant_t("John") };
ado.ExecuteNonQuery(updateSql, updateParams);

// 删除数据
std::string deleteSql = "DELETE FROM [dbo].[Person] WHERE [ID] = ?";
std::vector<_variant_t> deleteParams = { _variant_t(1) };
ado.ExecuteNonQuery(deleteSql, deleteParams);

ado.Close();
return 0;
}
登录后复制
以上代码仅供参考，具体实现要根据自己的需求进行调整。