C++ MySQL Connector查询结果指针作用域问题及解决咨询

我来帮你拆解一下遇到的两个核心问题，然后给出针对性的解决方案：

问题1：参数传递导致外部指针未更新 #

你当前的函数参数sql::ResultSet * result是按值传递的——简单说，函数内部的result只是你传入的外部指针的一个副本。当你在函数里执行result = statement->executeQuery(query)时，只是修改了这个副本的指向，完全不会影响外部的原始指针变量。这就是为什么函数内部打印"Result is not null"，但外部的指针还是NULL的根本原因。

问题2：Statement生命周期导致ResultSet失效 #

还有一个容易忽略的严重问题：你在函数里执行了delete statement;，但MySQL Connector/C++中，executeQuery返回的ResultSet是依赖于创建它的Statement的。当你销毁Statement时，对应的ResultSet会被自动关闭并失效，就算你成功把ResultSet指针传回外部，使用它时也会出现崩溃、读取错误数据等未定义行为。

解决方案 #

方案1：使用指针引用+外部管理Statement（兼容现有代码风格） #

修改函数签名，将ResultSet*改为指针引用，同时把Statement也作为输出参数交给外部管理，确保它的生命周期覆盖ResultSet的使用期：

bool MySQLConnector::ExecuteQuery( const std::string& query, sql::ResultSet*& result, sql::Statement*& stmt ) {
    result = nullptr;
    stmt = connection->createStatement();
    try {
        result = stmt->executeQuery( query );
    } catch( sql::SQLException &e ) {
        std::cerr << "SQL错误: " << e.what() << std::endl;
        std::cerr << "SQL状态码: " << e.getSQLState() << std::endl;
        delete stmt;
        stmt = nullptr;
        return false;
    }

    if( result == nullptr ) {
        printf( "Result is null File: %s Line %i\n", __FILE__, __LINE__ );
        delete stmt;
        stmt = nullptr;
        return false;
    } else {
        printf("Result is not null File: %s Line %i\n", __FILE__, __LINE__ );
    }
    return true;
}

外部调用示例：

void foo() {
    MySQLConnector conn; // 假设已完成初始化
    sql::ResultSet* result = nullptr;
    sql::Statement* stmt = nullptr;

    if( conn.ExecuteQuery("SELECT * FROM your_table", result, stmt) ) {
        // 处理查询结果
        while( result->next() ) {
            std::cout << "列值: " << result->getString("column_name") << std::endl;
        }
        // 处理完毕后销毁Statement，这会自动释放对应的ResultSet
        delete stmt;
    }
}

方案2：使用智能指针管理（现代C++推荐方式） #

如果你想避免手动管理内存的风险，可以使用智能指针封装Statement和ResultSet，让它们的生命周期自动绑定：

#include <memory>

// 封装查询结果的结构体
struct QueryResult {
    std::unique_ptr<sql::Statement> stmt;
    std::unique_ptr<sql::ResultSet> result;
};

QueryResult MySQLConnector::ExecuteQuery( const std::string& query ) {
    QueryResult res;
    res.stmt.reset( connection->createStatement() );
    try {
        res.result.reset( res.stmt->executeQuery( query ) );
    } catch( sql::SQLException &e ) {
        std::cerr << "SQL错误: " << e.what() << std::endl;
        std::cerr << "SQL状态码: " << e.getSQLState() << std::endl;
        // 发生错误时自动释放资源
        res.stmt.reset();
        res.result.reset();
    }
    return res;
}

外部调用示例：

void foo() {
    MySQLConnector conn;
    auto queryRes = conn.ExecuteQuery("SELECT * FROM your_table");

    if( queryRes.result ) {
        // 处理查询结果
        while( queryRes.result->next() ) {
            std::cout << "列值: " << queryRes.result->getString("column_name") << std::endl;
        }
        // 无需手动释放资源，智能指针会在queryRes销毁时自动清理Statement和ResultSet
    }
}

内容的提问来源于stack exchange，提问作者HunterLee