C++连接数据库SqlServer、MySql、Oracle、Access、SQLite、PostgreSQL、MongoDB、Redis_Mysql

c++是一种通用的编程语言，可以使用不同的库和驱动程序来连接各种数据库。以下是一些示例代码，演示如何使用 c++ 连接 sql server、mysql、oracle、access、sqlite 、 postgresql、mongodb、redis数据库。

连接 sql server 数据库

要使用 c++ 连接 sql server 数据库，可以使用 microsoft 的 adodb 库。以下是一个示例代码：

#include <iostream>
#import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("eof", "endoffile")

int main() {
    coinitialize(null); // 初始化 com 库
    _connectionptr pconnection("adodb.connection"); // 创建 connection 对象
    _bstr_t strconnect = "provider=sqloledb;data source=localhost;initial catalog=mydatabase;user id=sa;password=123456"; // 连接字符串
    pconnection->open(strconnect, null, null, null); // 连接数据库

    if (pconnection->state) {
        _commandptr pcommand("adodb.command"); // 创建 command 对象
        _bstr_t strsql = "select * from mytable"; // sql 查询语句
        pcommand->activeconnection = pconnection; // 设置连接对象
        pcommand->commandtext = strsql; // 设置 sql 语句
        _recordsetptr precordset("adodb.recordset"); // 创建 recordset 对象
        precordset->open(pcommand.getinterfaceptr(), _variant_t((idispatch *) pconnection, true), adopenunspecified, adlockunspecified, -1); // 执行查询并返回结果集

        while (!precordset->endoffile) { // 遍历结果集
            // 处理数据
        }
    }

    pconnection->close(); // 关闭连接
    couninitialize(); // 关闭 com 库
    return 0;
}

连接 mysql 数据库

要使用 c++ 连接 mysql 数据库，可以使用 mysql connector/c++ 库。以下是一个示例代码：

#include <mysql_driver.h>
#include <mysql_connection.h>
#include <cppconn/driver.h>
#include <cppconn/exception.h>
#include <cppconn/resultset.h>
#include <cppconn/statement.h>

int main() {
    sql::mysql::mysql_driver *driver;
    sql::connection *con;
    sql::statement *stmt;
    sql::resultset *res;

    driver = sql::mysql::get_mysql_driver_instance(); // 获取 mysql 驱动程序实例
    con = driver->connect("tcp://localhost:3306", "user", "password"); // 连接数据库
    stmt = con->createstatement(); // 创建 statement 对象
    res = stmt->executequery("select * from mytable"); // 执行查询并返回结果集

    while (res->next()) { // 遍历结果集
        // 处理数据
    }

    delete res; // 删除结果集对象
    delete stmt; // 删除 statement 对象
    delete con; // 删除连接对象
    return 0;
}

连接 oracle 数据库

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

#include <iostream>
#include <windows.h>
#include <occi.h>

using namespace oracle::occi;

int main() {
    environment *env = environment::createenvironment(); // 创建 occi 环境
    connection *conn = env->createconnection("driver={oracle odbc driver};server=localhost;database=mydatabase;uid=user;pwd=password"); // 连接数据库

    if (conn->isvalid()) {
        statement *stmt = conn->createstatement("select * from mytable"); // 创建 statement 对象
        resultset *res = stmt->executequery(); // 执行查询并返回结果集

        while (res->next()) { // 遍历结果集
            // 处理数据
        }
    }

    conn->close(); // 关闭连接
    env->terminate(); // 关闭 occi 环境
    return 0;
}

连接 access 数据库

要使用 c++ 连接 access 数据库，可以使用 microsoft 的 adodb 库。以下是一个示例代码：

#include <iostream>
#import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("eof", "endoffile")

int main() {
    coinitialize(null); // 初始化 com 库
    _connectionptr pconnection("adodb.connection"); // 创建 connection 对象
    _bstr_t strconnect = "provider=microsoft.jet.oledb.4.0;data source=c:\\mydatabase.mdb;persist security info=false"; // 连接字符串
    pconnection->open(strconnect, "", "", adconnectunspecified); // 连接数据库

    if (pconnection->state) {
        _commandptr pcommand("adodb.command"); // 创建 command 对象
        _bstr_t strsql = "select * from mytable"; // sql 查询语句
        pcommand->activeconnection = pconnection; // 设置连接对象
        pcommand->commandtext = strsql; // 设置 sql 语句
        _recordsetptr precordset("adodb.recordset"); // 创建 recordset 对象
        precordset->open(pcommand.getinterfaceptr(), _variant_t((idispatch *) pconnection, true), adopenunspecified, adlockunspecified, -1); // 执行查询并返回结果集

        while (!precordset->endoffile) { // 遍历结果集
            // 处理数据
        }
    }

    pconnection->close(); // 关闭连接
    couninitialize(); // 关闭 com 库
    return 0;
}

连接 sqlite 数据库

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

#include <iostream>
#include <sqlite3.h>
#include <cassert>

int main() {
    sqlite3* db;
    int rc;
    std::string sql;

    // 打开数据库
    rc = sqlite3_open("mydatabase.db", &db);
    assert(rc == sqlite_ok);

    // 创建表格
    sql = "create table if not exists mytable(id integer primary key, name text);";
    rc = sqlite3_exec(db, sql.c_str(), null, null, null);
    assert(rc == sqlite_ok);

    // 插入数据
    sql = "insert into mytable(name) values('hello');";
    rc = sqlite3_exec(db, sql.c_str(), null, null, null);
    assert(rc == sqlite_ok);

    // 查询数据
    sql = "select * from mytable;";
    rc = sqlite3_exec(db, sql.c_str(), callback, 0, 0);
    assert(rc == sqlite_ok);

    // 关闭数据库
    sqlite3_close(db);
    return 0;
}

连接 postgresql 数据库

要使用 c++ 连接 postgresql 数据库，可以使用 postgresql c++ 驱动程序。以下是一个示例代码：

#include <iostream>
#include <postgresql/libpq-fe.h>
#include <cassert>

void callback(void* arg, int argc, char** argv, char** cols) {
    for (int i = 0; i < argc; i++) {
        std::cout << cols[i] << ": " << argv[i] << std::endl;
    }
}

int main() {
    pgconn* conn = pqconnectdb("host=localhost dbname=mydatabase user=user password=password");
    assert(pqstatus(conn) == connection_ok);

    // 执行查询
    pgresult* res = pqexec(conn, "select * from mytable");
    assert(pqresultstatus(res) == pgres_tuples_ok);

    // 遍历结果集
    for (int i = 0; i < pqntuples(res); i++) {
        callback(null, pqnfields(res), pqgetvalue(res, i), pqgetisnull(res, i));
    }

    // 关闭连接
    pqfinish(conn);
    return 0;
}

连接mongodb数据库

#include <iostream>
#include <mongocxx/client.hpp>
#include <mongocxx/instance.hpp>
#include <bsoncxx/json.hpp>
#include <bsoncxx/types.hpp>

int main() {
    mongocxx::instance instance{};
    mongocxx::client conn{mongocxx::uri{"mongodb://localhost:27017"}};

    // 连接到数据库
    mongocxx::database db = conn["mydatabase"];

    // 创建文档
    bsoncxx::builder::stream::document doc{};
    doc << "name" << "john doe"
        << "age" << 30
        << "email" << "johndoe@example.com";

    // 插入文档到集合
    db["mycollection"].insert(doc.view());

    // 查询文档
    mongocxx::cursor cursor = db["mycollection"].find({});
    while (cursor) {
        bsoncxx::document::view doc = cursor->view();
        std::cout << doc["name"].get_string() << std::endl;
        std::cout << doc["age"].get_int32() << std::endl;
        std::cout << doc["email"].get_string() << std::endl;
        cursor++;
    }

    return 0;
}

这个示例使用了mongodb c++驱动程序来连接到mongodb数据库，创建文档并将其插入到集合中，然后查询并打印文档的内容。

连接redis数据库

#include "stdafx.h"
#include <windows.h>
#include <hiredis.h>

#pragma comment(lib, "win32_interop.lib")
#pragma comment(lib, "hiredis.lib")

int main()
{
    //redis默认监听端口为6387 可以再配置文件中修改 
    rediscontext* prediscontext = redisconnect("127.0.0.1", 6379);
    if (null == prediscontext || prediscontext->err)
    {
        printf("%s \r\n", prediscontext->errstr);
        printf("connect to redis server failed \n");
        return -1;
    }

    //输入redis密码
    const char *pszredispwd = "123456";
    redisreply *predisreply = (redisreply*)rediscommand(prediscontext, "auth %s", pszredispwd);
    if (null != predisreply)
    {
        freereplyobject(predisreply);
    }
    //用get命令获取数据
    char szredisbuff[256] = { 0 };
    sprintf_s(szredisbuff, "get %s", "name");
    predisreply = (redisreply*)rediscommand(prediscontext, szredisbuff);
    if (null == predisreply)
    {
        printf("get data error!");
        return -1;
    }

    if (null == predisreply->str)
    {
        freereplyobject(predisreply);
        return -1;
    }

    string strres(predisreply->str);
    freereplyobject(predisreply);

    //向redis写入数据
    predisreply = (redisreply *)rediscommand(prediscontext, "set keyname huantest");
    if (null != predisreply)
    {
        freereplyobject(predisreply);
    }

    return 0;
}