1

我的 MySQL 数据库在我的一张表中有 200 万条记录。我正在开发一个使用 node.js 从表中获取记录的 api。

我正在使用mysql2包连接到数据库。以下是我从表中获取所有记录的代码。

var query1 = dbCon.query('select * from Post');

query1
    .on('error', function (err) {
        // Handle error, an 'end' event will be emitted after this as well
        console.log(err)

    })
    .on('fields', function (fields) {
        // the field packets for the rows to follow
        console.log(fields);
    })
    .on('result', function (row) {
        // Pausing the connnection is useful if your processing involves I/O
        dbCon.pause();

        processRow(row, function () {
            console.log("row is ", row);
            dbCon.resume();
        });
    })
    .on('end', function (row) {
        console.log(row);
    });

数据库连接代码

const mysql = require('mysql2');
const serverConfig = require('../global/serverConfig');
const conPool = mysql.createPool({
    host: serverConfig.dbHost,
    database: serverConfig.dbName,
    user: serverConfig.dbUser,
    password: serverConfig.dbPass,
    multipleStatements: true
    // timezone: 'IST'
})
conPool.on('connection', function (connection) {
   // console.log('Connected to MySql db');
});
conPool.on('error', ()=>{
   // console.log('Not Connected to MySql db');
})
module.exports = conPool.promise();

当我点击 API 时出现错误

错误：TypeError：query1.on 不是函数

请向我建议一个解决方案或任何替代方法来获取和处理如此庞大的数据。

4

0 回答 0