0

我有一个 C++ 代码，可以根据这些文件的内容解析文件并更新 MySQL 数据库。我在 Windows 10 和 MySQL 5.7 中运行我的代码，我的基础使用 InnoDB 引擎。MySQL 调用是通过我自己的 libmysql 包装器执行的。

为了优化此代码，我将更新请求附加到缓冲区中，直到达到缓冲区的最大大小，然后同时发送整个缓冲区（包含 N 个更新）。整个过程在单个事务中完成。

这是我的代码的外观：

MySQLWrapper.StartTransaction();

string QueryBuffer = "";

// Element count is the number of elements parsed from the files
for( int i = 0 ; i < ElementCount ; ++i )
{
bool FlushBuffer = 
( i> 0 && ! (( i + 1 ) % N) )    ||
( i == ElementCount - 1 ); // determines if we have reached the buffer max number of requests

QueryBuffer += "INSERT INTO mytable (myfield) VALUES (" Element[ i ] ");";

if( FlushBuffer )
{
MySQLWrapper.SendRequest( QueryBuffer );
QueryBuffer.assign("");
}
}
MySQLWrapper.Commit();

SendRequest(string Request) 的实现基本上是：

void SendRequest(string Request)
{
mysql_query( SQLSocket, Request.c_str())
}

但是，在提交事务时，事务恰好已被破坏：MySQL 指示状态不正确，无法提交。我试图做同样的事情，但只发送一个请求，并且在提交时不会发生此错误。

所以，我的两个问题是：

  1. 你知道为什么一次发送多个请求会破坏我的交易吗？
  2. 你认为使用缓冲的请求列表真的可以优化我的代码吗？
4

1 回答 1

0

与其创建多个 INSERT，不如创建一个具有多个值的 INSERT。IOW，在循环之前，有INSERT INTO TABLE (columns), 然后在循环内，为每个值集附加(values),。

MySQLWrapper.StartTransaction();

string QueryBuffer = "INSERT INTO mytable (myfield) VALUES ";

// Element count is the number of elements parsed from the files
for( int i = 0 ; i < ElementCount ; ++i )
{
    bool FlushBuffer = 
    ( i> 0 && ! (( i + 1 ) % N) )    ||
    ( i == ElementCount - 1 ); // determines if we have reached the buffer max number of requests

    QueryBuffer += "(" Element[ i ] ")";
    if( flushbuffer ) {
        QueryBuffer += ";";
    } else {
        QueryBuffer += ",";
    }

    if( FlushBuffer )
    {
        MySQLWrapper.SendRequest( QueryBuffer );
        QueryBuffer.assign("");
    }
}
MySQLWrapper.Commit();

生成的 SQL 语句将类似于：

INSERT INTO mytable
(myfield)
VALUES
(1),
(2),
(3),
(3);
于 2018-06-06T12:25:48.560 回答