大佬教程收集整理的这篇文章主要介绍了我想使用 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,请注明来意。