diff --git a/src/adapter/socket/mysql.js b/src/adapter/socket/mysql.js index 37c243ea..37151b85 100644 --- a/src/adapter/socket/mysql.js +++ b/src/adapter/socket/mysql.js @@ -93,6 +93,9 @@ export default class extends Base { this.connection.on('error', () => { this.close(); }); + this.connection.on('close', () => { + this.close(); + }); //PROTOCOL_CONNECTION_LOST this.connection.on('end', () => { this.connection = null;