не мог получить ответ

Question

Я строю остальные API с помощью node.js и MySQL.Но в моем GET я получаю сообщение об ошибке «не могу получить ответ» с router.get, который использует mysql.Вот мой код, mt это помогает.

server.js

const http =  require('http');
const app = require('./app');
const port = process.env.PORT || 3000;
const server = http.createServer(app);
server.listen(port);

app.js

const express = require('express');
const app = express();
const userRoutes = require('./api/routes/user');
var mysql = require("mysql");
//Database connection
app.use(function(req, res, next){
    res.locals.connection = mysql.createConnection({
        host     : 'localhost',
        user     : 'root',
        password : ' ',
        database : 'achai_db'
    });
    res.locals.connection.connect();
    next();
});

user.js

const express = require('express');
const router = express.Router();
router.get('/', function(req, res, next) {
    res.locals.connection.query('SELECT * from users', function (error, results, fields) {
        if (error) throw error;
        res.send(JSON.stringify({"status": 200, "error": null, "response": results}));
    });
});
module.exports = router;

В этом user.js, если я использую get без использования mysql, соединение работает.

Answer 1

Вы должны понимать природу JavaScript (асинхронное программирование), и вы не должны открывать mysql соединение в каждом запросе, вы можете использовать пул соединений и поддерживать соединение открытым, просто получить соединение и освободить его после запроса.

обновлено app.js

const express = require('express');
const app = express();
const userRoutes = require('./api/routes/user');
const mysql = require('mysql');
//Database connection
const pool = mysql.createPool({
    host     : 'localhost',
    user     : 'root',
    password : ' ',
    database : 'achai_db'
});
app.use(function(req, res, next){
    pool.getConnection(function(err, connection) {
        res.locals.connection = connection;
        next(err);
    });      
});

обновлено user.js

const express = require('express');
const router = express.Router();
router.get('/', function(req, res, next) {
    res.locals.connection.query('SELECT * from users', function (error, results, fields) {
        res.locals.connection.release();
        if (error) throw error;
        //res.json({"status": 200, "error": null, "response": results});
        res.send(JSON.stringify({"status": 200, "error": null, "response": results}));
    });
});
module.exports = router;