实例讲解C++连接各种数据库，包含SQL Server、MySQL、Oracle、ACCESS、SQLi ...

 
C++ 是一种通用的编程语言，可以使用不同的库和驱动程序来连接各种数据库。以下是一些示例代码，演示如何使用 C++ 连接 SQL Server、MySQL、Oracle、ACCESS、SQLite 和 PostgreSQL、MongoDB 数据库。

• 连接 SQL Server 数据库
  

要使用 C++ 连接 SQL Server 数据库，可以使用 Microsoft 的 ADODB 库。以下是一个示例代码：

1. #include <iostream>
2. #import "C:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF", "EndOfFile")
4. int main() {
5.     CoInitialize(NULL); // 初始化 COM 库
6.     _ConnectionPtr pConnection("ADODB.Connection"); // 创建 Connection 对象
7.     _bstr_t strConnect = "Provider=SQLOLEDB;Data Source=localhost;Initial Catalog=MyDatabase;User ID=sa;Password=123456"; // 连接字符串
8.     pConnection->Open(strConnect, NULL, NULL, NULL); // 连接数据库
10.     if (pConnection->State) {
11.         _CommandPtr pCommand("ADODB.Command"); // 创建 Command 对象
12.         _bstr_t strSQL = "SELECT * FROM MyTable"; // SQL 查询语句
13.         pCommand->ActiveConnection = pConnection; // 设置连接对象
14.         pCommand->CommandText = strSQL; // 设置 SQL 语句
15.         _RecordsetPtr pRecordset("ADODB.Recordset"); // 创建 Recordset 对象
16.         pRecordset->Open(pCommand.GetInterfacePtr(), _variant_t((IDispatch *) pConnection, true), adOpenUnspecified, adLockUnspecified, -1); // 执行查询并返回结果集
18.         while (!pRecordset->EndOfFile) { // 遍历结果集
19.             // 处理数据
20.         }
21.     }
23.     pConnection->Close(); // 关闭连接
24.     CoUninitialize(); // 关闭 COM 库
25.     return 0;
26. }

复制代码

• 连接 MySQL 数据库
  

要使用 C++ 连接 MySQL 数据库，可以使用 MySQL Connector/C++ 库。以下是一个示例代码：

1. #include <mysql_driver.h>
2. #include <mysql_connection.h>
3. #include <cppconn/driver.h>
4. #include <cppconn/exception.h>
5. #include <cppconn/resultset.h>
6. #include <cppconn/statement.h>
8. int main() {
9.     sql::mysql::MySQL_Driver *driver;
10.     sql::Connection *con;
11.     sql::Statement *stmt;
12.     sql::ResultSet *res;
14.     driver = sql::mysql::get_mysql_driver_instance(); // 获取 MySQL 驱动程序实例
15.     con = driver->connect("tcp://localhost:3306", "user", "password"); // 连接数据库
16.     stmt = con->createStatement(); // 创建 Statement 对象
17.     res = stmt->executeQuery("SELECT * FROM MyTable"); // 执行查询并返回结果集
19.     while (res->next()) { // 遍历结果集
20.         // 处理数据
21.     }
23.     delete res; // 删除结果集对象
24.     delete stmt; // 删除 Statement 对象
25.     delete con; // 删除连接对象
26.     return 0;
27. }

复制代码

• 连接 Oracle 数据库
  

要使用 C++ 连接 Oracle 数据库，可以使用 Oracle 提供的 ODBC 驱动程序。以下是一个示例代码：

1. #include <iostream>
2. #include <windows.h>
3. #include <occi.h>
5. using namespace oracle::occi;
7. int main() {
8.     Environment *env = Environment::createEnvironment(); // 创建 OCCI 环境
9.     Connection *conn = env->createConnection("DRIVER={Oracle ODBC Driver};SERVER=localhost;DATABASE=MyDatabase;UID=user;PWD=password"); // 连接数据库
11.     if (conn->isValid()) {
12.         Statement *stmt = conn->createStatement("SELECT * FROM MyTable"); // 创建 Statement 对象
13.         ResultSet *res = stmt->executeQuery(); // 执行查询并返回结果集
15.         while (res->next()) { // 遍历结果集
16.             // 处理数据
17.         }
18.     }
20.     conn->close(); // 关闭连接
21.     env->terminate(); // 关闭 OCCI 环境
22.     return 0;
23. }

复制代码

• 连接 Access 数据库
  

要使用 C++ 连接 Access 数据库，可以使用 Microsoft 的 ADODB 库。以下是一个示例代码：

1. #include <iostream>
2. #import "C:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF", "EndOfFile")
4. int main() {
5.     CoInitialize(NULL); // 初始化 COM 库
6.     _ConnectionPtr pConnection("ADODB.Connection"); // 创建 Connection 对象
7.     _bstr_t strConnect = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=C:\\MyDatabase.mdb;Persist Security Info=False"; // 连接字符串
8.     pConnection->Open(strConnect, "", "", adConnectUnspecified); // 连接数据库
10.     if (pConnection->State) {
11.         _CommandPtr pCommand("ADODB.Command"); // 创建 Command 对象
12.         _bstr_t strSQL = "SELECT * FROM MyTable"; // SQL 查询语句
13.         pCommand->ActiveConnection = pConnection; // 设置连接对象
14.         pCommand->CommandText = strSQL; // 设置 SQL 语句
15.         _RecordsetPtr pRecordset("ADODB.Recordset"); // 创建 Recordset 对象
16.         pRecordset->Open(pCommand.GetInterfacePtr(), _variant_t((IDispatch *) pConnection, true), adOpenUnspecified, adLockUnspecified, -1); // 执行查询并返回结果集
18.         while (!pRecordset->EndOfFile) { // 遍历结果集
19.             // 处理数据
20.         }
21.     }
23.     pConnection->Close(); // 关闭连接
24.     CoUninitialize(); // 关闭 COM 库
25.     return 0;
26. }

复制代码

• 连接 SQLite 数据库
  

要使用 C++ 连接 SQLite 数据库，可以使用SQLite C++库。以下是一个示例代码：

1. #include <iostream>
2. #include <sqlite3.h>
3. #include <cassert>
5. int main() {
6.     sqlite3* db;
7.     int rc;
8.     std::string sql;
10.     // 打开数据库
11.     rc = sqlite3_open("MyDatabase.db", &db);
12.     assert(rc == SQLITE_OK);
14.     // 创建表格
15.     sql = "CREATE TABLE IF NOT EXISTS MyTable(id INTEGER PRIMARY KEY, name TEXT);";
16.     rc = sqlite3_exec(db, sql.c_str(), NULL, NULL, NULL);
17.     assert(rc == SQLITE_OK);
19.     // 插入数据
20.     sql = "INSERT INTO MyTable(name) VALUES('hello');";
21.     rc = sqlite3_exec(db, sql.c_str(), NULL, NULL, NULL);
22.     assert(rc == SQLITE_OK);
24.     // 查询数据
25.     sql = "SELECT * FROM MyTable;";
26.     rc = sqlite3_exec(db, sql.c_str(), callback, 0, 0);
27.     assert(rc == SQLITE_OK);
29.     // 关闭数据库
30.     sqlite3_close(db);
31.     return 0;
32. }

复制代码

• 连接 PostgreSQL 数据库
  

要使用 C++ 连接 PostgreSQL 数据库，可以使用 PostgreSQL C++ 驱动程序。以下是一个示例代码：
[code]#include #include #include void callback(void* arg, int argc, char** argv, char** cols) {    for (int i = 0; i < argc; i++) {        std::cout