typeorm stream

entity.ts

import {Column, CreateDateColumn, Entity, PrimaryGeneratedColumn} from 'typeorm'

@Entity()
export class Test {
  @PrimaryGeneratedColumn() id: number
  @Column() category: string

  @CreateDateColumn() createdAt: Date
}

index.ts

import {createConnection, getRepository} from 'typeorm'
import {Test} from './entity'

async function main() {
  await createConnection({
    type: 'mysql',
    url: 'mysql://root@localhost/temp',
    entities: [Test],
    synchronize: true,
    logging: true,
  })

  const repository = getRepository(Test)
  const query = repository.createQueryBuilder('t')
    .select('t.category')
    .groupBy('t.category')

  console.log('getMany', await query.getMany())
  console.log('getRawMany', await query.getRawMany())
  const stream = await query.stream()

  stream.on('result', (e) => console.log('result', e))
  stream.on('end', (e) => console.log('end'))
  for await(const row of stream) {
    console.log('stream', row)
  }
}

main()