@galaxar/feat-db

1.3.1 • Public • Published

@galaxar/feat-db

Datasource features set

Features

  • prisma

Prisma

Config

{
    "prisma": { modelPath, ttlCacheService, datasources, log }
}

Usage

const prisma = app.getService('prisma');

Prisma helpers

  • $pushQuery - Returns a new where with specified condition merged into where, will merge same keys into an AND array

  • $pushOrQuery - Returns a new where with specified condition merged into where, will merge same keys into an OR array

  • $model - Returns a business logic model from modelPath

//<modulePath>\User.js
class User {
    constructor(prisma) {
        this.model = prisma.user;
    }

    async upsert_(input) {
        const { email, ...others } = input;

        return this.model.upsert({
            where: { email },
            create: input,
            update: others,
        });
    }
}

export default User;

Usage

const prisma = app.getService('prisma');
const User = prisma.$model('user');

await User.upsert_({
    email: 'test999@email.com',
    name: 'test999',                
});
  • $setupCache(this, entries) - Setup cache (list or map)
    • $setupCache should be called in the Model's constructor after model is assigned
    • entries is a map of cache key to { where, type, [mapByKey] }
    • Model with $setupCache has the following two methods:
      • async cache_(key) - fetch data from cache by key, run query if cache missed
      • resetCache(key)
//<modulePath>\User.js
class User {
    constructor(prisma) {
        this.model = prisma.user;
        prisma.$setupCache(this, {
            'list': { where: {}, type: 'list' },
            'map': { where: {}, type: 'map', mapByKey: 'email' },
        });
    }
}

export default User;

Usage

const prisma = app.getService('prisma');
const User = prisma.$model('UserWithCache');

const map = await User.cache_('map');
const list = await User.cache_('list');

Model helpers

  • retryCreate_(createOptions /* the same as prisma */, dataFactory /* if duplicate, the factory will be call to generate new creation data */)
const nanoid = app.getService('nanoid');

const session = await LoginSession.retryCreate_(
    {
        data: {
            id: nanoid.next(),
            userId: user.id,
            expiresAt: new Date(expiresAt),
            lastHeartbeat: nowDate,
        },
    },
    (input) => ({
        ...input,
        data: {
            ...input.data,
            id: nanoid.next(),
        },
    })
);

Package Sidebar

Install

npm i @galaxar/feat-db

Weekly Downloads

0

Version

1.3.1

License

MIT

Unpacked Size

32.4 kB

Total Files

9

Last publish

Collaborators

  • rockie