constructor()

in src/connectors/sql-input-connector.ts [8:28]


  constructor(config: any) {
    config.options = config.options || {};
    this.query = config.query;
    config.options.rowCollectionOnRequestCompletion = true;
    this.connection = new Sequelize(
      config.database,
      config.username,
      config.password,
      {
        dialect: config.dialect,
        dialectOptions: config.options,
        host: config.host,
        operatorsAliases: false,
        pool: {
          idle: 10000,
          max: 5,
          min: 0,
        },
      }
    );
  }