Prismaメモ

yarn add -D -E prisma

yarn add -D -E @prisma/client

npx prisma init

DATABASE_URL="mongodb://username:password@localhost:27017/mydb"

generator client {
  provider = "prisma-client-js"
}

datasource db {
-  provider = "postgresql"
+  provider = "mongodb"
  url      = env("DATABASE_URL")
}

npx prisma generate

model User {
  id String @id @default(auto()) @map("_id") @db.ObjectId

  name           String
  supportingClub Club   @default(VisselKobe)
}

enum Club {
  VisselKobe
  GambaOsaka
  CerezoOsaka
  KyotoSanga
  FCOsaka
  NaraClub
}

model Product {
  id   String @id @default(auto()) @map("_id") @db.ObjectId
  name String

  // 埋め込みデータPhotoの配列
  photos Photo[]
}

// 埋め込みデータの定義
type Photo {
  width  Int
  height Int
  url    String
}

// 参照元モデル
model Post {
  id String @id @default(auto()) @map("_id") @db.ObjectId

  // リレーションフィールド
  // データベースには実体のないフィールドとなる
  // Post.userIdをUser.idの外部キーとする
  user User @relation(fields: [userId], references: [id])

  // リレーションスカラーフィールド
  // データーベースでは外部キーとなる
  userId String @db.ObjectId
}

// 参照先モデル
model User {
  id String @id @default(auto()) @map("_id") @db.ObjectId

  // リレーションフィールド
  // データベースには実体のないフィールドとなる
  // 複数のPostと関係があるので配列型にする
  profile Post[]
}

// 多モデルその1
model Post {
  id Int @id @default(autoincrement())
  categories CategoriesOnPosts[]
}

// 多モデルその2
model Category {
  id Int @id @default(autoincrement())
  posts CategoriesOnPosts[]
}

// 中間モデル
model CategoriesOnPosts {
  post Post @relation(fields: [postId], references: [id])
  postId Int

  category Category @relation(fields: [categoryId], references: [id])
  categoryId Int
  
  // 複合主キーを設定
  @@id([postId, categoryId])
}

// 多モデルその1
model Post {
  id Int @id @default(autoincrement())
  categories Category[]
}

// 多モデルその2
model Category {
  id Int @id @default(autoincrement())
  posts Post[]
}

// 参照元モデル
model Post {
  id String @id @default(auto()) @map("_id") @db.ObjectId

  // リレーション "WrittenPosts"
  author   User   @relation(name: "WrittenPosts", fields: [authorId], references: [id])
  authorId String @unique @db.ObjectId

  // リレーション "PinnedPost"
  pinnedBy   User?   @relation(name: "PinnedPost", fields: [pinnedById], references: [id])
  pinnedById String? @unique @db.ObjectId
}

// 参照先モデル
model User {
  id String @id @default(auto()) @map("_id") @db.ObjectId

  // リレーション "WrittenPosts"
  writtenPosts Post[] @relation(name: "WrittenPosts")

  // リレーション "PinnedPost"
  pinnedPost Post? @relation(name: "PinnedPost")
}

yarn add -D -E prisma
npx prisma init

DATABASE_URL="postgresql://${POSTGRES_USER}:${POSTGRES_PASSWORD}@localhost:5432/mydb?schema=public"

generator client {
  provider = "prisma-client-js"
}

datasource db {
  provider = "postgresql"
  url      = env("DATABASE_URL")
}

npx prisma migrate dev --name init

yarn add -D -E @prisma/client
npx prisma generate

  await prisma.user.create({
    data: {
      name: "Hoge",
      email: "hoge@fuga.com",
      // 入れ子で作成
      posts: {
        create: {
          title: "Kon'nichiwa!",
        },
      },
      // 入れ子で作成
      profile: {
        create: {
          bio: "Nemui.",
        },
      },
    },
  });

  // リレーションデータのうちpostsの全カラムも取得する
  const allUsers = await prisma.user.findMany({
    include: { posts: true },
  });

  // リレーションデータのうちposts.titleのみ取得する
  const allUsers2 = await prisma.user.findMany({
    include: {
      posts: {
        select: {
          title: true,
        },
      },
    },
  });

  // user.nameとuser.posts.titleのみを取得する
  const allUsers3 = await prisma.user.findMany({
    select: {
      name: true,
      posts: {
        select: {
          title: true,
        },
      },
    },
  });

model Product {
  id          Int    @id @default(autoincrement())
  name        String
  description String
}

import { Prisma } from "@prisma/client";
import { z } from "zod";

// Zodによるレコードの文字列型チェックと文字数，パターンチェックを行うスキーマの定義
export const ProductCreateInput = z.object({
  name: z.string().max(100),
  description: z.string().max(1000),
}) satisfies z.Schema<Prisma.ProductCreateInput>;

import { PrismaClient } from "@prisma/client";
import { ProductCreateInput } from "./validate";

const prisma = new PrismaClient().$extends({
  query: {
    // Client Extensionsのカスタムクエリ定義
    product: {
      create({ args, query }) {
        args.data = ProductCreateInput.parse(args.data)
        return query(args)
      },
      update({ args, query }) {
        args.data = ProductCreateInput.partial().parse(args.data)
        return query(args)
      },
      updateMany({ args, query }) {
        args.data = ProductCreateInput.partial().parse(args.data)
        return query(args)
      },
      upsert({ args, query }) {
        args.create = ProductCreateInput.parse(args.create)
        args.update = ProductCreateInput.partial().parse(args.update)
        return query(args)
      },
    },
  },
})

const newUser: User = await prisma.user.create({
  data: {
    name: "Hoge",
    // Userテーブルに対して1対多関係であるPostテーブルにレコードを同時に追加する
    posts: {
      create: [
        { title: "Fuga" },
        { title: "Piyo" },
      ],
    },
  },
});

// Emailレコード中のUser.nameが"Hoge"なレコードはstarをtrueにする
await prisma.email.updateMany({
  where: {
    // relatedなデータのフィールドに対しても条件づけできる
    user: {
      name: "Hoge",
    },
  },
  data: {
    star: true,
  },
})

const [30olds, nUser] = prisma.$transaction([
  prisma.user.findMany({ where: { age: 30 } }),
  prisma.user.count(),
]);

// Promiseを返すメソッドを作れば汎用性が上がる
function updateMatch(winner: Club, loser: Club, difference: number): Promise<void> {
  return await prisma.$transaction(async (client) => {
    // 1. クエリその1実行
    await client.club.update({
      where: {
        name: winner.name
      },
      data: {
        point: {
          increment: difference === 0 ? 1 : 3,
        },
        goalDifference: {
          increment: difference,
        },
      },
    });

    // 2. クエリ以外の処理を実行
    if (winner.name === loser.name) {
      // エラーを投げたときはトランザクション中止によりロールバックされる
      throw new Error(`A winner and a loser are the same club: ${winner.name}`);
    }

    // 3. クエリその2実行
    await client.club.update({
      where: {
        name: loser.name
      },
      data: {
        point: {
          increment: difference === 0 ? 1 : 0,
        },
        goalDifference: {
          decrement: difference,
        },
      },
    });

    // 処理が完了するとトランザクションはコミットされる．
  });
}

await updateMatch(VisselKobe, GambaOsaka, 1);