Soc*_*tes 5 mysql connection-pooling node.js
如何检查 MySQL 数据库是否已准备好接受来自 Node MySQL 连接池的某些查询?
我有一个由三个容器组成的 Docker 环境:
数据库容器运行 MySQL 数据库。api 容器连接到该数据库。所有三个容器同时启动。Web 服务器容器在 0.5 秒后启动。2 秒后 api 容器启动。20秒后数据库服务器启动。
目前,API 会在数据库启动并运行之前尝试访问数据库的表。这会导致诸如连接被拒绝之类的错误。以下代码段始终以消息“查询数据库时出错!”结束。当MySQL数据库尚未启动时:
const sql: string = 'SELECT * FROM sometable;';
MySQL.createPool({
connectionLimit: 10,
acquireTimeout: 30000,
waitForConnections: true,
database: 'mydatabase',
host: 'localhost',
multipleStatements: true,
password: 'mypassword',
user: 'root',
}).query(sql, (err, result) => {
if (result) {
console.log('Successfully queried database.');
} else {
console.log('Error querying database!');
}
});
Run Code Online (Sandbox Code Playgroud)
使用中的版本:
OS: Ubuntu 19.10
Node: v13.6.0
MySQL (Node API): "@types/mysql": "2.15.8" and "mysql": "2.17.1"
MySQL (Docker Database): mysql:5.7.28
TypeScript: 3.7.4
Run Code Online (Sandbox Code Playgroud)
我想检查(并等待)API 中的数据库准备情况,可能使用我用于查询的连接池。那可能吗?
setTimeout():(用 Javascript 而不是打字稿回答)
'use strict';
const dbpool = require('mysql').createPool({
connectionLimit: 10,
acquireTimeout: 30000,
waitForConnections: true,
database: 'mydatabase',
host: 'localhost',
multipleStatements: true,
password: 'mypassword',
user: 'root',
});
const sql = 'SELECT * FROM sometable;';
const attemptConnection = () =>
dbpool.getConnection((err, connection) => {
if (err) {
console.log('error connecting. retrying in 1 sec');
setTimeout(attemptConnection, 1000);
} else {
connection.query(sql, (errQuery, results) => {
connection.release();
if (errQuery) {
console.log('Error querying database!');
} else {
console.log('Successfully queried database.');
}
});
}
});
attemptConnection();
Run Code Online (Sandbox Code Playgroud)
这是我的测试运行:
$ sudo service mysql stop; node test.js & sudo service mysql start
[1] 24737
error connecting. retrying in 1 sec
error connecting. retrying in 1 sec
$ Successfully queried database.
Run Code Online (Sandbox Code Playgroud)
仅供参考,该程序永远不会结束,因为它需要dbpool.end();