Function simulateUnexpectedError

test/integration/pool.test.js:91–101

(connection)

  describe('network / connection errors', () => {
    it('should obtain new connection when old connection is abruptly closed', async () => {
      function simulateUnexpectedError(connection) {
        // should never be returned again
        if (dialect === 'mssql') {
          connection = attachMSSQLUniqueId(connection);
        }
        if (dialect === 'db2') {
          sequelize.connectionManager.pool.destroy(connection);
        } else {
          connection.emit('error', { code: 'ECONNRESET' });
        }
      }

      const sequelize = Support.createSequelizeInstance({
        pool: { max: 1, idle: 5000 }