错误:将数据插入表时读取 ECONN重置

Question

我按照本教程(一次插入多行教程(将多行数据插入MySQL表("一次插入多行"一章(。

我对我的代码做了同样的事情，但是如果数据库足够好，我得到了一个 ECONNRESET 错误而不是我的连接。

错误详细信息如下：

{ Error: read ECONNRESET
    at _errnoException (util.js:1022:11)
    at TCP.onread (net.js:628:25)
    --------------------
    at Protocol._enqueue (C:Usersfrederic.fayetDesktopDEVNodeJSTER_V1 - Reprise après pausenode_modulesmysqllibprotocolProtocol.js:144:48)
    at Connection.query (C:Usersfrederic.fayetDesktopDEVNodeJSTER_V1 - Reprise après pausenode_modulesmysqllibConnection.js:200:25)
    at C:Usersfrederic.fayetDesktopDEVNodeJSTER_V1 - Reprise après pauseapp.js:340:24
    at handlePromises (C:Usersfrederic.fayetDesktopDEVNodeJSTER_V1 - Reprise après pauseapp.js:242:9)
    at promise.then (C:Usersfrederic.fayetDesktopDEVNodeJSTER_V1 - Reprise après pauseapp.js:251:20)
    at <anonymous>
    at process._tickCallback (internal/process/next_tick.js:188:7)
  code: 'ECONNRESET',
  errno: 'ECONNRESET',
  syscall: 'read',
  fatal: true }

我的代码如下，用于查询数据库：

db.query(sqlSchedules, [sqlDataSchedules], function (err, result) {
                        if (err) {
                            console.log(err);
                            return; //throw err;
                        }
                        //Get the number of inserted lines:
                        nbLinesSchedulesInserted = result.affectedRows;
                        console.log("Nombre d'éléments insérés : " + result.affectedRows);
                    });

数据库连接是：

db.connect(function(err) {
        if (err) console.error('Error occured during the DB connection.'); 
        console.log("DB connection: OK"); 
    });

sqlDataSchedules 是一个数组，如下所示：

[ [ '848633',
    'Amiens',
    '162700',
    '162700',
    '20190509',
    '20190702',
    2019-05-31T07:27:09.710Z ],
  [ '848633',
    'Villers-Bretonneux',
    '163800',
    '163900',
    '20190509',
    '20190702',
    2019-05-31T07:27:09.710Z ],
  [ '849401',
    'St Quentin',
    '074500',
    '074500',
    '20190527',
    '20190528',
    2019-05-31T07:27:09.711Z ],
  ... 141377 more items ]

SQL 请求是：

INSERT INTO schedules (trainNumber, stopName, baseArrivalTime, baseDepartureTime, beginDate, endDate, updatedOn) VALUES ?

Answer 1

只需更改MySQL max_allowed_packet即可。例如：

max_allowed_packet=100M

在 my.ini 或 my.cnf 中。(不要忘记重启 MySQL 实例服务(它解决了我的问题。

Answer 2

我终于找到了使用 for 循环和异步函数的解决方案：

async function loopOverRequests(data, sqlRequest, tableName) {
    let nbRequests = 0;
    for (var i = 0; i<data.length; i++) {
        nbRequests = nbRequests + await makeTheRequest(data[i], sqlRequest);
    }
    console.log(nbRequests + ' imported in the table `'+ tableName + '`.');
    return new Promise((resolve, reject) => {
        resolve(nbRequests);
    });
}
function makeTheRequest(el, sqlRequest) {
    return new Promise((resolve, reject) => {
        db.query(sqlRequest, el, function (err, result) {
            if (err) {
                console.log(err);
                reject(err); //throw err;
            } else {
                resolve(result.affectedRows);
            }
        });
    });
}