export function sqlStreamReader()

in src/stream/reader.ts [17:36]

• 20 lines of code
• 2 McCabe index (conditional complexity)

export function sqlStreamReader(config: any) {
  const client = knex({
    client: config.dialect,
    connection: {
      host: config.host,
      user: config.username,
      password: config.password,
      database: config.database,
      options: config.options,
    },
  });
  const query = config.query;
  if (!query) {
    throw new Error('query cannot be null or empty');
  }
  return client
    .raw(query)
    .stream()
    .on('end', () => client.destroy());
}