我们使用 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();
}
谢谢