NodeJS + MySQL: Cannot enqueue Query after invoking quit.?

Question

[Archakov Dennis]

var mysql = require('mysql');

class DB {

	constructor(){

		this.connection = mysql.createConnection({
		  host     : 'localhost',
		  user     : 'root',
		  password : '123',
		  database : 'test',
		  socketPath: '/Applications/MAMP/tmp/mysql/mysql.sock'
		});

		this.connection.config.queryFormat = (query, values) => {
			if (!values) return query;
				return query.replace(/\:(\w+)/g, (txt, key) => {
				if (values.hasOwnProperty(key)) {
					return mysql.escape(values[key]);
				}
				return txt;
			});
		};

		this.connection.connect();

	}

	query(q, params, callback){
		var _this = this;
		this.connection.query(q, params, (err, rows, fields) => {
			_this.connection.end();
			callback(err, rows, fields);
		});
	}

}

module.exports = DB;

На первом запросе все ок. Но, когда отправляется второй запрос на БД, то ошибка:
Error: Cannot enqueue Query after invoking quit.

Не могу понять в чем проблема, вроде _this.connection.end(); вызываю.

Answer 1

[Владлен Хеллсайт]

А зачем такие громоздкие конструкции, может стоит использовать KnexJS?
Да и вы создаёте не poll, а это очень не хорошо.

Comments

[Archakov Dennis]

Могли бы объяснить коротко, почему не хорошо? Я читал, что они сами соединение закрывают. Но, пока не уверен, моему проекту нужно такое или нет

[Владлен Хеллсайт]

Im Archakov: ну poll соединений он сам выбирает взять доступное соединение и если таковых нет откроет новое, но если будет лимит открытых соединений просто будет ждать, а это не есть хорошо для асинхронных операций, в любом проекте стоит использовал poll-ы даже в консольных. Благодаря этому не будет строится очередь на запрос в соединении.

[Archakov Dennis]

Владлен Хеллсайт: спасибо. Уже юзаю KnexJS