Prisma ORMは、Fastifyサーバーでデータベースをクエリするために使用される次世代ORMです。プレーンなSQLクエリの記述、knex.jsのようなクエリビルダー、またはTypeORM、MikroORM、Sequelizeのような従来のORMの代替として使用できます。Prisma ORMはRESTおよびGraphQL APIの構築に使用でき、マイクロサービスアーキテクチャとモノリシックアーキテクチャの両方とスムーズに統合します。

さらに、当社の追加ツールでPrisma ORMの利用を強化できます
• Prisma Accelerateは、データベースクエリを高速化するグローバルデータベースキャッシュおよびスケーラブルな接続プールです。
• Prisma Pulseは、型安全な方法でリアクティブなリアルタイムアプリケーションを構築することを可能にします。

PrismaとFastifyのコード例

PrismaはFastifyと完全に統合する便利なデータベースアクセスレイヤーを提供します。

以下に示すコードは、Fastifyを使用してAPIサーバーを構築する際にPrismaを様々に利用する方法を示しています。

REST API

Prismaは、データベース内のデータを読み書きするために、ルートハンドラー内で使用されます。

1import fastify from 'fastify'
2import { PrismaClient } from '@prisma/client'
3
4const prisma = new PrismaClient()
5const app = fastify()
6
7app.get('/feed', async (req, res) => {
8  const posts = await prisma.post.findMany({
9    where: { published: true },
10    include: { author: true },
11  })
12  res.json(posts)
13})
14
15app.post('/post', async (req, res) => {
16  const { title, content, authorEmail } = req.body
17  const post = await prisma.post.create({
18    data: {
19      title,
20      content,
21      published: false,
22      author: { connect: { email: authorEmail } },
23    },
24  })
25  res.json(post)
26})
27
28app.put('/publish/:id', async (req, res) => {
29  const { id } = req.params
30  const post = await prisma.post.update({
31    where: { id },
32    data: { published: true },
33  })
34  res.json(post)
35})
36
37app.delete('/user/:id', async (req, res) => {
38  const { id } = req.params
39  const user = await prisma.user.delete({
40    where: {
41      id,
42    },
43  })
44  res.json(user)
45})
46
47app.listen(3000)

GitHubで探索

FastifyプラグインでのPrisma

GraphQL API

Prismaスキーマ

REST API

Prismaは、データベース内のデータを読み書きするために、ルートハンドラー内で使用されます。

1import fastify from 'fastify'
2import { PrismaClient } from '@prisma/client'
3
4const prisma = new PrismaClient()
5const app = fastify()
6
7app.get('/feed', async (req, res) => {
8  const posts = await prisma.post.findMany({
9    where: { published: true },
10    include: { author: true },
11  })
12  res.json(posts)
13})
14
15app.post('/post', async (req, res) => {
16  const { title, content, authorEmail } = req.body
17  const post = await prisma.post.create({
18    data: {
19      title,
20      content,
21      published: false,
22      author: { connect: { email: authorEmail } },
23    },
24  })
25  res.json(post)
26})
27
28app.put('/publish/:id', async (req, res) => {
29  const { id } = req.params
30  const post = await prisma.post.update({
31    where: { id },
32    data: { published: true },
33  })
34  res.json(post)
35})
36
37app.delete('/user/:id', async (req, res) => {
38  const { id } = req.params
39  const user = await prisma.user.delete({
40    where: {
41      id,
42    },
43  })
44  res.json(user)
45})
46
47app.listen(3000)