javascript - Hur man dynamiskt ansluter till en MongoDB-databas med Nest.js

Jag behöver skapa en separat databas för varje enhet i min klients app. Jag kommer att bestämma databasnamnet baserat på vilken subdomän förfrågan kommer från. Hur kan jag uppnå det och ansluta dynamiskt till en databas med hjälp av NestJS och Mongoose?

UserService

async findOneByEmail(email: string, subdomain: string): Promise<User | any> {
    const liveConnections = await Databases.getConnection(subdomain)

    const user = await liveConnections.model(User.name, UserSchema).find()
    // { 'securityInfo.email': email }
    if (!user)
        throw new HttpException(
            {
                status: HttpStatus.BAD_REQUEST,
                error: 'user not found',
                field: 'user',
            },
            HttpStatus.BAD_REQUEST
        )

    return user
}

klass som jag skapar

class DataBases extends Mongoose {
    private clientOption = {
        keepAlive: true,
        useNewUrlParser: true,
        useUnifiedTopology: true,
    }

    private databases: { [key: string]: Connection } = {}

    private getConnectionUri = (companyName = '') =>
        `mongodb+srv://${process.env.MONGODB_USERNAME}:${process.env.MONGODB_PASSWORD}@cluster0.2lukt.mongodb.net/${companyName}?retryWrites=true&w=majority`

    public async getConnection(companyName = ''): Promise<Connection> {
        const connection = this.databases[companyName]
        return connection ? connection : await this.createDataBase(companyName)
    }

    private async createDataBase(comapnyName = ''): Promise<Connection> {
        //  create new connection and if the database not exists just create new one
        const newConnection = await this.createConnection(
            this.getConnectionUri(comapnyName),
            this.clientOption
        )
        this.databases[comapnyName] = newConnection
        return newConnection
    }
}



 

Svar #1

Jag fixar det. Databasklassen som jag skapade fungerar riktigt bra och om du känner till ett bättre sätt, vänligen berätta. Vad jag var tvungen att ändra är sättet jag använder anslutningen till MongoDB på. Och nu kan jag ansluta till olika databaser beroende på subdomänen.

Jag hoppas att det kommer att hjälpa någon!

UserService

async findOneByEmail(email: string, subdomain: string): Promise<User | any> {
    const liveConnections = await Databases.getConnection(subdomain)
    const user = await liveConnections
        .model(User.name, UserSchema)
        .findOne({ 'securityInfo.email': email })
        .exec()
    if (!user)
        throw new HttpException(
            {
                status: HttpStatus.BAD_REQUEST,
                error: 'user not found',
                field: 'user',
            },
            HttpStatus.BAD_REQUEST
        )

    return user
}