nestJS中TypeORM如何根据请求参数动态查询表？

Question

假设有两个数据库，其中date数据库的表每天一张，表名根据日期创建：20230801,20230802...

要根据请求的接口参数日期范围，动态去连接表查询该如何操作呢？

imports: [
        TypeOrmModule.forRoot({
            name: 'db1Connection', // 指定连接名称
            type: 'mysql',
            host: 'localhost',
            port: 3306,
            username: 'root',
            password: '123456',
            database: 'date',
            entities: [Date],
            autoLoadEntities:true, // 自动加载实体
            synchronize: true,
        }),
        TypeOrmModule.forRoot({
            name: 'db2Connection', // 指定连接名称
            type: 'mysql',
            host: 'localhost',
            port: 3306,
            username: 'root',
            password: '123456',
            database: 'test',
            entities: [Goods],
            autoLoadEntities:true, // 自动加载实体
            synchronize: true,
        }),
        TypeOrmModule.forFeature([Date], 'db1Connection'),
        TypeOrmModule.forFeature([Goods], 'db2Connection')
    ],

实体指定表名查询是OK的。

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

@Entity('good')
export class Goods {
  @PrimaryGeneratedColumn()
  id: number;

  @Column({ length: 128 })
  name: string;

  @Column()
  desc: string;

  @Column()
  price: number;

  @Column()
  sum: number;

}

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

@Entity()
export class Date {
  @PrimaryGeneratedColumn()
  id: number;

  @Column({ length: 128 })
  title: string;

  @Column()
  content: string;

  @Column()
  userId: number;
}

上面的实体没有指定表名，每次查询自动创建了一个 date 表 。。
目前数据库有如下表：
20230801
20230802
20230803

我想的是根据查询的参数去动态查询这些表，可能是一张也可能是多张表

import { Injectable, Inject } from '@nestjs/common';
import { Repository, EntityManager } from 'typeorm';
import { InjectRepository, InjectEntityManager, } from '@nestjs/typeorm';

import { Date } from 'src/entitys/date.entity';
import { Goods } from 'src/entitys/goods.entity';

@Injectable()
export class DateService {
  constructor(
    @InjectRepository(Date, 'db1Connection') private dateRepository: Repository<Date>,
    @InjectRepository(Goods, 'db2Connection') private goodsRepository: Repository<Goods>,
  ) {}


  async findByDate() {

  }

  async findAll() {

  }

  async findGoods() {
    return this.goodsRepository.find();
  }
}

Answer 1

用注解定义实体，是程序加载的时候就定义了，@Entity() 不传参数相当于用class 名作为表名。

实体可以分离定义：

import {EntitySchema} from "typeorm";

export const CategoryEntity = new EntitySchema({
    name: "category",
    columns: {
        id: {
            type: Number,
            primary: true,
            generated: true
        },
        name: {
            type: String
        }
    }
});

然后再使用：

// 请求数据
const categoryRepository = getRepository<Category>(CategoryEntity);
const category = await categoryRepository.findOne(1); // category is properly typed!

// 插入一条新category到数据库
const categoryDTO = {
  // 注意id是自动生成的，请参考上面的架构定义。
  name: 'new category',
};
const newCategory = await categoryRepository.save(categoryDTO);

参考：typeorm