c++ - Mysql C++ 连接器中的批量插入

Question

我们使用 mysql connector for c++（官方库），但是 c++ 库中没有batchupdate或batchinsert方法（尽管在 java 中这些方法确实存在）。

为了做到这一点，我尝试了类似下面的方法并且它奏效了。但是在这种情况下，如果我们每分钟插入数千行数据，大约 30 分钟 mysql 会消耗掉我们计算机中的所有内存（它有 32G 内存）。

这种用法有错吗，如果有，我们该怎么办？（我们循环运行下面的代码）：

 try {
        //autoClose parameter is false in our case
        if (!autoClose) {
            con->setAutoCommit(false);
        }

        stmt = con->prepareStatement(queryBuilder);

        this->setPreparedStatements(insertData);

        result = stmt->executeUpdate();
        stmt->close();

        if (getAutoGeneratedKey) {
            std::string lastIdQuery = "SELECT LAST_INSERT_ID()";
            stmt = con->prepareStatement(lastIdQuery);
            ResultSet *rs = stmt->executeQuery();
            while (rs->next()) {
                result = rs->getInt(1);
            }

            rs->close();
            delete rs;
            stmt->close();
        }

        if (autoClose) { //autoClose parameter is false in our case
            con->close();
        }

谢谢

标签： c++mysqllibmysql

Answer 1

您忘记删除 Prepared Statement stmt。

https://dev.mysql.com/doc/connector-cpp/1.1/en/connector-cpp-examples-prepared-statements.html

笔记

您必须使用 delete 显式释放 sql::PreparedStatement 和 sql::Connection 对象。