Repository Pattern

// TypeORM repository
@Injectable()
export class TypeOrmEmployeeRepository extends Repository<Employee> {
  constructor(dataSource: DataSource) {
    super(Employee, dataSource.createEntityManager());
  }
}

// MikroORM repository
@Injectable()
export class MikroOrmEmployeeRepository extends BaseEntityRepository<Employee> {
  constructor(em: EntityManager) {
    super(em, Employee);
  }
}

@Module({
  imports: [
    TypeOrmModule.forFeature([Employee]),
    MikroOrmModule.forFeature([Employee]),
  ],
  providers: [TypeOrmEmployeeRepository, MikroOrmEmployeeRepository],
})
export class EmployeeModule {}

@Injectable()
export class EmployeeService extends TenantAwareCrudService<Employee> {
  constructor(
    readonly typeOrmRepo: TypeOrmEmployeeRepository,
    readonly mikroOrmRepo: MikroOrmEmployeeRepository,
  ) {
    super(typeOrmRepo, mikroOrmRepo);
  }
}

@Injectable()
export class TypeOrmEmployeeRepository extends Repository<Employee> {
  async findActiveByOrganization(orgId: string): Promise<Employee[]> {
    return this.createQueryBuilder("e")
      .leftJoinAndSelect("e.user", "u")
      .where("e.organizationId = :orgId", { orgId })
      .andWhere("e.isActive = true")
      .orderBy("u.firstName", "ASC")
      .getMany();
  }
}