程序问答   发布时间:2022-06-02  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了我想使用 typedi 在服务构造函数中注入 Repositories 容器大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
@H_772_0@如何解决我想使用 typedi 在服务构造函数中注入 Repositories 容器? 开发过程中遇到我想使用 typedi 在服务构造函数中注入 Repositories 容器的问题如何解决?下面主要结合日常开发的经验,给出你关于我想使用 typedi 在服务构造函数中注入 Repositories 容器的解决方法建议,希望对你解决我想使用 typedi 在服务构造函数中注入 Repositories 容器有所启发或帮助;

我想在我的 Userservice 中注入存储库。

但我不知道该怎么做。 我正在使用 typescript、typedi 和 sequelize。

我认为,服务的加载速度比加载器快。

当我尝试注入我在数据库加载器中设置的存储库时,发生错误。

这样的错误:serviceNotFoundError:在容器中找不到带有“存储库”标识符的服务。通过显式调用“Container.set”函数或使用“@service()”装饰器在使用前注册它。

因此,我使用 console.log 检查了“userRepo”,结果未定义。 我还在 createuser 中检查了 Container.get('repositorIEs'),它是集中加载的。我的意思是,我可以获得我的 Container 实例。

我只是无法在构造函数中加载存储库实例。

我应该怎么做才能在构造函数中加载存储库? 我应该将 sequelize 更改为 typeorm 以加载它吗?

// ** Userservice.ts **
import { Inject,service } from 'typedi';
import { UserRepository } from '../repositorIEs/user.repository';
import { UserCreationAttributes } from '../models/interface/User.interface';
import { User,usermodel,UserStatic } from '../models/User';

@service()
export default class Userservice {
  constructor(@Inject('repositorIEs') private userRepo: UserRepository) {}

  public async createuser(userData: UserCreationAttributes): Promise<Boolean> {
    try {
      await thiS.UserRepo.create(userData);
      return true;
    } catch (err) {
      console.log(err);
      return false;
    }
  }
}
// ** Database Loader **
import { Sequelize } from 'sequelize';
import config from '../config';
import Logger from './logger';
import { UserStatic } from '../models/User';
import { FeedStatic } from '../models/Feed';
import { CommentStatic } from '../models/Comment';
import { VerificationStatic } from '../models/Verification';
import { initializeModels } from '../models';
import { initializeRepositorIEs,RepositorIEs } from '../repositorIEs';
import { Container } from 'typedi';

export interface Models {
  User: UserStatic;
  Feed: FeedStatic;
  Comment: CommentStatic;
  Verification: VerificationStatic;
}

export default async function loadSequelize() {
  const sequelize = new Sequelize(
    config.database,config.databaseUsername,config.databasepassword,{
      host: config.databaseHost,port: config.databasePort,dialect: 'POSTGRes',},);

  try {
    await sequelize.authenticate();
    const models: Models = initializeModels(sequelizE);
    const repositorIEs: RepositorIEs = initializeRepositorIEs(models);
    await sequelize.sync({ force: true });

    // This part might be loaded after services were loaded
    Container.set('models',models);
    Container.set('repositorIEs',repositorIEs);


    console.log('load finish');
  } catch (err) {
    Logger.error(err);
  }
}

// ** ./repositorIEs/index.ts **
import { Models } from '../loaders/database';
import { UserRepository } from './user.repository';

export interface RepositorIEs {
  UserRepository: UserRepository;
}
export const initializeRepositorIEs = (models: Models): RepositorIEs => {
  const usersRepository = new UserRepository(modelS.User);
  const repositorIEs: RepositorIEs = {
    UserRepository: usersRepository,};
  return repositorIEs;
};
// ** ./repositorIEs/base.repository.ts **
import { Model,Buildoptions,Findoptions } from 'sequelize/types';
import { IFilter } from './filter/base.filter';

export type RichModel = typeof Model & {
  new (values?: Record<String,unkNown>,options?: Buildoptions): Model;
};

export interface IMeta {
  globalCount: number;
  countAfterFiltering: number;
}

export interface IWithMeta<M extends Model> {
  Meta: IMeta;
  data: M[];
}

export abstract class BaseRepository<
  M extends Model,C extends object,F extends IFilter = IFilter
> {
  constructor(public _model: RichModel,private filterFactory: new () => F) {}

  private async getCount(where?: Record<String,unkNown>): Promise<number> {
    const count = await this._model.count({ where });
    return count;
  }

  async getAll(params?: Findoptions,filter?: F): Promise<IWithMeta<M>> {
    const { from: offset,count: limit } = filter || {};
    const result = await this._model.findAndCountAll({
      order: [['ID','ASC']],offset: offset,limit: limit,...params,});

    const globalCount = await this.getCount();
    const countAfterFiltering = ((result.count as unkNown) as Record<
      String,unkNown
    >[]).length;

    return {
      Meta: { globalCount,countAfterFiltering },data: result.rows as M[],};
  }

  async getByID(ID: String | number): Promise<M> {
    const result = await this._model.findByPk(ID);
    return result as M;
  }

  async get(where: Record<String,unkNown>): Promise<M> {
    const result = await this._model.findOne({ where });
    return result as M;
  }

  async updateByID(ID: String | number,data: C): Promise<M> {
    const result = await this._model.update(data,{
      where: { ID },returning: true,});

    const [,models] = result;

    return models[0] as M;
  }

  async deleteByID(ID: String | number): Promise<voID> {
    await this._model.destroy({
      where: { ID },});
  }

  async create(data: C): Promise<M> {
    const model = await this._model.create(data);
    return (model as unkNown) as M;
  }
}
// ** ./repositorIEs/user.repository.ts
import { BaseRepository,IWithMeta,RichModel } from './base.repository';
import { usermodel,UserStatic } from '../models/User';
import { UserCreationAttributes } from '../models/interface/User.interface';
import { IFilter } from './filter/base.filter';
import { UserFilter } from './filter/user.filter';
import { service } from 'typedi';

@service()
export class UserRepository extends BaseRepository<
  usermodel,UserCreationAttributes,IFilter
> {
  constructor(private model: UserStatiC) {
    super(<RichModel>model,IFilter);
  }

  async getAllUsers(): Promise<IWithMeta<usermodel>> {
    const users = await this.getAll();
    return users;
  }

  async getoneByFilter({
    email,password,}: UserFilter): Promise<usermodel | null> {
    const user = await this.model.findOne({
      where: {
        email,});
    return user;
  }

  async getadminOneByFilter({
    email,isadmin: true,});
    return user;
  }
}
@H_772_0@解决方法

首先,尝试将 initializeRepositories 调用放在 reflect-metadata 调用之后,以测试执行顺序是否会受到影响。您不需要在数据库连接文件内部调用。

从我在旧文档中看到的内容来看,要使用 Container.set 设置所有存储库,您需要提供一个包含带有 id 的对象的数组。

Container.set([{ id: 'userRepository',value: new UserRepository() }])

如果你只需要设置一个仓库:

Container.set('userRepository',new UserRepository())

在上述两种情况下,您都使用 like:Container.get('userRepository');

如果您想将引用保留为 repositories,您的 initializeRepositories 方法是可以的,但用法必须如下:

@Inject('repositories') repositories: { UserRepository: UserRepository}; 

repositorieS.UserRepository

如果您不需要通过该方法设置存储库,您只需在 @service('userRepository') 类中放置一个装饰器 UserRepository 即可。

大佬总结

以上是大佬教程为你收集整理的我想使用 typedi 在服务构造函数中注入 Repositories 容器全部内容,希望文章能够帮你解决我想使用 typedi 在服务构造函数中注入 Repositories 容器所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。