【Prisma，下一代ORM，不仅仅是ORM（下篇）

Copycopy code to clipboard
1model Category {
2  id   Int    @id @default(autoincrement())
3  name String
4  posts Post[]
5}
6
7model Post {
8  id       Int    @id @default(autoincrement())
9  postUUID String @default(uuid())
10  title     String
11  content   String?
12  published Boolean @default(false)
13  createdAt DateTime @default(now())
14  updatedAt DateTime @updatedAt
15  author   User @relation(fields: [authorId], references: [id])
16  authorId Int
17  categories Category[]
18}
19
20model Profile {
21  id           Int     @id @default(autoincrement())
22  bio          String?
23  profileViews Int     @default(0)
24  user   User? @relation(fields: [userId], references: [id])
25  userId Int?  @unique
26}
27
28model User {
29  id   Int    @id @default(autoincrement())
30  name String @unique
31  age  Int    @default(0)
32  posts Post[]
33  profile Profile?
34  avaliable Boolean @default(true)
35  createdAt DateTime @default(now())
36  updatedAt DateTime @updatedAt
37}

Copycopy code to clipboard
1posts Post[]
2profile Profile?

Copycopy code to clipboard
1user   User? @relation(fields: [userId], references: [id])
2userId Int?  @unique

Copycopy code to clipboard
1const user = {
2  profile: {
3
4  }
5  posts: {
6    categories: {
7
8        }
9    }
10}

Copycopy code to clipboard
1const simpleIncludeFields = {
2  profile: true,
3  posts: {
4    include: {
5      categories: true,
6    },
7  },
8};
9
10const createUserWithFullRelations = await prisma.user.create({
11  data: {
12    name: randomName(),
13    age: 21,
14    profile: {
15      create: {
16        bio: randomBio(),
17      },
18    },
19    posts: {
20      create: {
21        title: randomTitle(),
22        content: "鸽置",
23        categories: {
24          create: [{ name: "NodeJS" }, { name: "GraphQL" }],
25        },
26      },
27    },
28  },
29  include: simpleIncludeFields,
30});

Copycopy code to clipboard
1const connectOrCreateRelationsUser = await prisma.user.create({
2  data: {
3    name: randomName(),
4    profile: {
5      connectOrCreate: {
6        where: {
7          id: 9999,
8        },
9        create: {
10          bio: "Created by connectOrCreate",
11        },
12      },
13    },
14    posts: {
15      connectOrCreate: {
16        where: {
17          id: 9999,
18        },
19        create: {
20          title: "Created by connectOrCreate",
21        },
22      },
23    },
24  },
25  select: simpleSelectFields,
26});

Copycopy code to clipboard
1const oneToOneUpdate = await prisma.user.update({
2  where: {
3    name: connectOrCreateRelationsUser.name,
4  },
5  data: {
6    profile: {
7      update: {
8        bio: "Updated Bio",
9      },
10      // update
11      // upsert
12      // delete
13      // disconnect(true)
14      // create
15      // connect
16      // connectOrCreate
17    },
18  },
19  select: simpleSelectFields,
20});

Copycopy code to clipboard
1const oneToMnayUpdate = await prisma.user.update({
2  where: {
3    name: connectOrCreateRelationsUser.name,
4  },
5  data: {
6    posts: {
7      updateMany: {
8        data: {
9          title: "Updated Post Title",
10        },
11        where: {},
12      },
13      // set 与 many, 以及各选项类型
14      // set: [],
15      // update
16      // updateMany
17      // delete
18      // deleteMany
19      // disconnect: [
20      //   {
21      //     id: 1,
22      //   },
23      // ],
24      // connect
25      // create
26      // connectOrCreate
27      // upsert
28    },
29  },
30  select: simpleSelectFields,
31});

Copycopy code to clipboard
1model Key {
2  kid Int    @id @default(autoincrement())
3  key String
4
5  createdAt DateTime @default(now())
6  updatedAt DateTime @updatedAt
7}
8
9model Value {
10  vid   Int    @id @default(autoincrement())
11  key   String
12  value String
13
14  createdAt DateTime @default(now())
15  updatedAt DateTime @updatedAt
16}

Copycopy code to clipboard
1import { PrismaClient as PrismaKeyClient, Key } from "./prisma-key/client";
2import { PrismaClient as PrismaValueClient } from "./prisma-value/client";
3
4const keyClient = new PrismaKeyClient();
5const valueClient = new PrismaValueClient();

Copycopy code to clipboard
1const key1 = await keyClient.key.create({
2  data: {
3    key: uuidv4(),
4  },
5  select: {
6    key: true,
7  },
8});
9
10const value1 = await valueClient.value.create({
11  data: {
12    key: key1.key,
13    value: "林不渡",
14  },
15  select: {
16    key: true,
17    value: true,
18  },
19});

Copycopy code to clipboard
1async function main() {
2  // Setup TypeORM Connection
3  const connection = await createConnection({
4    type: "sqlite",
5    database: IS_PROD
6      ? "./dist/src/with-typeorm/typeorm-value.sqlite"
7      : "./src/with-typeorm/typeorm-value.sqlite",
8    entities: [ValueEntity],
9    synchronize: true,
10    dropSchema: true,
11  });
12
13  await ValueEntity.clear();
14  await prisma.prismaKey.deleteMany();
15
16  const key1 = await prisma.prismaKey.create({
17    data: {
18      key: uuidv4(),
19    },
20    select: {
21      key: true,
22    },
23  });
24
25  const insertValues = await ValueEntity.createQueryBuilder()
26    .insert()
27    .into(ValueEntity)
28    .values([
29      {
30        key: key1.key,
31        value: "林不渡",
32      },
33    ])
34    .execute();
35
36  const keys = await prisma.prismaKey.findMany();
37
38  for (const keyItem of keys) {
39    const key = keyItem.key;
40
41    console.log(`Search By: ${key}`);
42
43    const value = await ValueEntity.createQueryBuilder("value")
44      .where("value.key = :key")
45      .setParameters({
46        key,
47      })
48      .getOne();
49
50    console.log("Search Result: ", value);
51    console.log("===");
52  }
53
54  await prisma.$disconnect();
55  await connection.close();
56}

Copycopy code to clipboard
1// server.ts
2export const server = new ApolloServer({
3  schema,
4  introspection: true,
5  context: { prisma },
6});
7
8// Todo.resolver.ts
9// 更多   Query/Mutation 参考代码仓库
10@Resolver(TodoItem)
11export default class TodoResolver {
12  constructor() {}
13
14  @Query((returns) => [TodoItem!]!)
15  async QueryAllTodos(@Ctx() ctx: IContext): Promise<TodoItem[]> {
16    return await ctx.prisma.todo.findMany({ include: { creator: true } });
17  }
18
19  @Query((returns) => TodoItem, { nullable: true })
20  async QueryTodoById(
21    @Arg("id", (type) => Int) id: number,
22    @Ctx() ctx: IContext
23  ): Promise<TodoItem | null> {
24    return await ctx.prisma.todo.findUnique({
25      where: {
26        id,
27      },
28      include: { creator: true },
29    });
30  }
31
32  @Mutation((returns) => TodoItem, { nullable: true })
33  async UpdateTodo(
34    @Arg("updateParams", (type) => UpdateTodoInput) params: UpdateTodoInput,
35    @Ctx() ctx: IContext
36  ): Promise<TodoItem | null> {
37    try {
38      const origin = await ctx.prisma.todo.findUnique({
39        where: { id: params.id },
40      });
41
42      if (!origin) {
43        throw new Error();
44      }
45
46      return await ctx.prisma.todo.update({
47        where: {
48          id: params.id,
49        },
50        data: {
51          title: params.title ?? origin?.title!,
52          content: params?.content ?? origin?.content!,
53          type: params?.type ?? origin?.type!,
54        },
55        include: { creator: true },
56      });
57    } catch (error) {
58      return null;
59    }
60  }
61}