drizzle-team\/drizzle-orm<\/code><\/a> v1.0.0-rc.1\u3002<\/p>\n\u5148\u628a\u540d\u8bcd\u9489\u4f4f\uff1a\u672c\u6587\u91cc\u7684 .prepare()<\/code> \u6307 Drizzle query builder \u7684 prepare\uff1bjit: true<\/code> \u6307 v1.0.0-rc.1 \u65b0\u589e\u7684 opt-in JIT mapper\uff0c\u4e0d\u662f\u628a\u6574\u6761\u67e5\u8be2\u5728\u5e94\u7528\u6784\u5efa\u671f\u7f16\u8bd1\u6210\u673a\u5668\u7801\uff0c\u800c\u662f\u5728\u67e5\u8be2\u51c6\u5907\u9636\u6bb5\u4e3a\u5f53\u524d\u9009\u4e2d\u5b57\u6bb5\u751f\u6210\u5e76\u590d\u7528\u4e13\u7528\u6620\u5c04\u51fd\u6570\u3002\u540e\u6587\u6240\u6709”\u70ed\u8def\u5f84\u53d8\u8584”\u90fd\u6309\u8fd9\u4e2a\u610f\u601d\u8bb2\u3002<\/p>\nORM \u5230\u5e95\u5728\u89e3\u51b3\u4ec0\u4e48\u95ee\u9898<\/h2>\n
\u4e0d\u7ba1\u54ea\u79cd ORM\uff0c\u81f3\u5c11\u90fd\u5f97\u56de\u7b54\u56db\u4ef6\u4e8b\uff1aSchema \u600e\u4e48\u5b9a\u4e49\u3001\u67e5\u8be2\u600e\u4e48\u5199\u3001\u7c7b\u578b\u600e\u4e48\u5bf9\u4e0a\u3001\u8fc1\u79fb\u600e\u4e48\u641e\u3002\u4f60\u8981\u662f\u5149\u7528 pg<\/code> \u6216\u8005 postgres<\/code>\uff08postgres.js\uff09\u8fd9\u79cd\u88f8\u9a71\u52a8\u624b\u5199 SQL\uff0c\u5176\u5b9e\u8fde\u7c7b\u578b\u6620\u5c04\u90fd\u53ea\u89e3\u51b3\u4e86\u4e00\u534a\uff1a\u9a71\u52a8\u7ed9\u4f60\u7684\u5c31\u662f string<\/code> \u548c number<\/code>\uff0crows[0].user_name<\/code> \u8fd9\u5b57\u6bb5\u5728\u4e0d\u5728\u3001\u62fc\u5199\u5bf9\u4e0d\u5bf9\uff0cTS \u5b8c\u5168\u4e0d\u77e5\u9053\u3002<\/p>\n“ORM”\u8fd9\u4e2a\u6807\u7b7e\u4e0b\u9762\uff0c\u4e0d\u540c\u7684\u5e93\u5bf9\u8fd9\u56db\u4ef6\u4e8b\u7ed9\u51fa\u4e86\u5b8c\u5168\u4e0d\u540c\u7684\u7b54\u6848\u3002\u800c Drizzle \u7684\u7b54\u6848\uff0c\u51e0\u4e4e\u51b3\u5b9a\u4e86\u5b83\u5176\u4ed6\u6240\u6709\u7279\u6027\u2014\u2014\u5305\u62ec\u6027\u80fd\u3002<\/p>\n
Schema \u5b9a\u4e49\uff1aDrizzle vs Prisma<\/h2>\n
\u4e0d\u540c ORM \u5728 schema \u5b9a\u4e49\u4e0a\u7684\u9009\u62e9\u5dee\u522b\u5f88\u5927\uff0c\u5206\u522b\u6765\u770b\u3002<\/p>\n
Prisma\uff1a\u6211\u81ea\u5df1\u641e\u4e00\u5957 DSL<\/h3>\n\/\/ schema.prisma\nmodel User {\n id Int @id @default(autoincrement())\n email String @unique\n posts Post[]\n}<\/code><\/pre>\n\u6ce8\u610f\uff0c\u8fd9\u4e0d\u662f TS\uff0c\u662f Prisma \u81ea\u5df1\u7684\u8bed\u8a00\u3002\u7528\u8d77\u6765\u7684\u6d41\u7a0b\u662f\uff1a<\/p>\n
\n- \u5199
.prisma<\/code> \u6587\u4ef6<\/li>\n- \u8dd1\u4e00\u4e0b
prisma generate<\/code><\/li>\n- \u5de5\u5177\u5e2e\u4f60\u751f\u6210
@prisma\/client<\/code>\uff0c\u91cc\u9762\u6709 TS \u7c7b\u578b\u548c\u5404\u79cd\u67e5\u8be2\u65b9\u6cd5<\/li>\n- \u4ee3\u7801\u91cc
import { PrismaClient }<\/code> \u5f00\u7528<\/li>\n<\/ol>\nDSL \u672c\u8eab\u786e\u5b9e\u633a\u5e72\u51c0\uff0c\u8bfb\u8d77\u6765\u8212\u670d\u3002\u4f46\u9ebb\u70e6\u5728\u4e8e\uff1a\u4f60\u6bcf\u6b21\u6539 schema\uff0c\u90fd\u5f97\u91cd\u65b0 generate \u4e00\u4e0b\uff0cIDE \u91cc\u7684\u7c7b\u578b\u624d\u4f1a\u8ddf\u4e0a\u3002\u800c\u4e14\u4f60\u7684\u7c7b\u578b\u662f”\u751f\u6210\u51fa\u6765\u7684”\uff0c\u4e0d\u662f TS \u7f16\u8bd1\u5668\u76f4\u63a5\u4ece schema \u63a8\u5bfc\u7684\u2014\u2014\u8fd9\u4fe9\u4e8b\u5728\u65e5\u5e38\u5f00\u53d1\u91cc\u7684\u624b\u611f\u5b8c\u5168\u4e0d\u4e00\u6837\u3002<\/p>\n
Drizzle\uff1aschema \u5c31\u662f TS \u4ee3\u7801<\/h3>\n\/\/ schema.ts\nimport { pgTable, serial, text, integer } from 'drizzle-orm\/pg-core';\n\nexport const users = pgTable('users', {\n id: serial('id').primaryKey(),\n email: text('email').notNull().unique(),\n});\n\nexport const posts = pgTable('posts', {\n id: serial('id').primaryKey(),\n authorId: integer('author_id').references(() => users.id),\n title: text('title').notNull(),\n});<\/code><\/pre>\n\u5c31\u8fd9\u4e48\u7b80\u5355\uff0c\u7eaf TS\uff0c\u6ca1\u6709 generate \u6b65\u9aa4\uff0c\u4f60\u6572\u5b8c\u952e\u76d8\u7684\u90a3\u4e00\u523b\u7c7b\u578b\u5c31\u53d8\u4e86\u3002<\/p>\n
\u90a3\u8fd9\u73a9\u610f\u513f\u80cc\u540e\u600e\u4e48\u505a\u5230\u7684\uff1f\u770b drizzle-orm\/src\/pg-core\/table.ts:33<\/code> \u7684\u8fd4\u56de\u7c7b\u578b\u5c31\u660e\u767d\u4e86\uff1a<\/p>\nexport type PgTableWithColumns<T extends TableConfig> =\n & PgTable<T>\n & { [Key in keyof T['columns']]: T['columns'][Key]; }\n & { enableRLS: () => ...; };<\/code><\/pre>\npgTable<\/code> \u7684\u8fd4\u56de\u503c\u65e2\u662f<\/strong> PgTable<\/code> \u5b9e\u4f8b\u53c8\u662f<\/strong> columns \u5b57\u5178\u3002\u6240\u4ee5 users.id<\/code> \u4f60\u65e2\u80fd\u5f53\u5bf9\u8c61\u7528\uff08\u5b83\u8fd0\u884c\u65f6\u5e26 mapToDriverValue<\/code> \u8fd9\u4e9b\u65b9\u6cd5\uff09\uff0c\u53c8\u80fd\u5728\u7c7b\u578b\u5c42\u9762\u62ff\u5230\u7cbe\u786e\u7684 PgColumn<{ data: number; ... }><\/code>\u3002\u6574\u6761\u7c7b\u578b\u94fe\u4ece\u5934\u5230\u5c3e\u90fd\u5728 TS \u7f16\u8bd1\u5668\u91cc\u8dd1\uff0c\u4e0d\u9700\u8981\u4efb\u4f55\u5916\u6302\u5de5\u5177\u3002<\/p>\n\u8fd9\u4e00\u4e2a\u9009\u62e9\u5b9a\u4e0b\u4e86 Drizzle \u7684\u6574\u4e2a\u57fa\u8c03\uff1a\u5b83\u628a ORM \u5efa\u7acb\u5728 TS \u7c7b\u578b\u7cfb\u7edf\u672c\u8eab\u4e4b\u4e0a\uff0c\u800c\u4e0d\u662f\u5916\u6302\u4e00\u4e2a schema \u8bed\u8a00<\/strong>\u3002\u540e\u9762\u4f60\u4f1a\u770b\u5230\uff0c\u5f88\u591a\u6027\u80fd\u548c DX \u4e0a\u7684\u4f18\u52bf\uff0c\u90fd\u662f\u4ece\u8fd9\u4e00\u4e2a\u51b3\u5b9a\u4e00\u8def\u63a8\u5bfc\u51fa\u6765\u7684\u3002<\/p>\nTypeORM\uff1a\u88c5\u9970\u5668 + class \u5b9e\u4f53<\/h3>\n@Entity()\nclass User {\n @PrimaryGeneratedColumn() id!: number;\n @Column() email!: string;\n @OneToMany(() => Post, post => post.author) posts!: Post[];\n}<\/code><\/pre>\nTypeORM \u652f\u6301 Active Record \u548c Data Mapper \u4e24\u79cd\u6a21\u5f0f\u3002\u5982\u679c\u8ba9\u5b9e\u4f53\u7ee7\u627f BaseEntity<\/code>\uff0c\u5b9e\u4f8b\u53ef\u4ee5\u81ea\u5e26 .save()<\/code>\u3001.remove()<\/code>\uff1b\u5982\u679c\u7528 Data Mapper\uff0c\u64cd\u4f5c\u4f1a\u96c6\u4e2d\u5230 repository \/ entity manager \u4e0a\u3002\u4f46\u4e0d\u7ba1\u54ea\u79cd\u6a21\u5f0f\uff0c\u5b83\u7684\u6838\u5fc3\u6a21\u578b\u90fd\u662f”\u88c5\u9970\u5668\u5143\u6570\u636e + class \u5b9e\u4f53”\u3002<\/p>\n\u8fd9\u5957\u6a21\u578b\u5bf9\u5f88\u591a Java \/ Ruby \u7a0b\u5e8f\u5458\u5f88\u719f\u6089\uff0c\u4ee3\u4ef7\u4e5f\u5b9e\u5b9e\u5728\u5728\uff1a\u67e5\u8be2\u7ed3\u679c\u901a\u5e38\u8981 hydrate \u6210 class \u5b9e\u4f8b\uff0c\u5173\u7cfb\u3001\u5217\u6620\u5c04\u548c\u751f\u547d\u5468\u671f\u94a9\u5b50\u90fd\u8981\u7ecf\u8fc7\u8fd0\u884c\u65f6\u5143\u6570\u636e\uff1b\u7c7b\u578b\u63a8\u5bfc\u4e5f\u4e0d\u50cf Drizzle \u90a3\u6837\u76f4\u63a5\u4ece TS \u8868\u8fbe\u5f0f\u4e00\u8def\u7b97\u51fa\u6765\u3002<\/p>\n
\u67e5\u8be2\u600e\u4e48\u5199\uff1aDSL \u7684\u54f2\u5b66\u5dee\u5f02<\/h2>\n
Schema \u5b9a\u4e49\u53ea\u662f\u8d77\u70b9\uff0c\u7528\u8d77\u6765\u6700\u76f4\u63a5\u80fd\u611f\u53d7\u5230\u7684\u8fd8\u662f\u67e5\u8be2 DSL\u3002\u5404\u5bb6\u7684\u5dee\u522b\u5728\u8fd9\u91cc\u66f4\u660e\u663e\u3002<\/p>\n
Drizzle\uff1a\u5199\u8d77\u6765\u8ddf SQL \u4e00\u6a21\u4e00\u6837<\/h3>\nconst result = await db\n .select({ id: users.id, email: users.email, postCount: count(posts.id) })\n .from(users)\n .leftJoin(posts, eq(posts.authorId, users.id))\n .where(and(eq(users.active, true), gt(users.createdAt, lastWeek)))\n .groupBy(users.id)\n .having(gt(count(posts.id), 5))\n .orderBy(desc(users.createdAt))\n .limit(20);<\/code><\/pre>\n\u4f60\u76ef\u7740\u8fd9\u6bb5\u4ee3\u7801\u770b\u4e00\u773c\u5c31\u77e5\u9053\u5b83\u5565\u610f\u601d\u2014\u2014\u94fe\u5f0f\u8c03\u7528\u7684\u987a\u5e8f\u8ddf SQL \u5b50\u53e5\u7684\u987a\u5e8f\u4e00\u4e00\u5bf9\u5e94<\/strong>\u3002\u8111\u5b50\u91cc\u60f3\u597d\u4e00\u6761 SQL\uff0c\u76f4\u63a5\u5f80\u4e0b\u6572\u5c31\u884c\uff0c\u4e0d\u7528\u5148\u628a\u5b83\u91cd\u6784\u6210\u67d0\u79cd”\u67e5\u8be2\u5bf9\u8c61\u56fe”\u3002<\/p>\nPrisma\uff1a\u628a\u67e5\u8be2\u5305\u88c5\u6210\u5bf9\u8c61<\/h3>\nconst result = await prisma.user.findMany({\n where: { active: true, createdAt: { gt: lastWeek } },\n include: {\n posts: { take: 5, orderBy: { createdAt: 'desc' } }\n },\n orderBy: { createdAt: 'desc' },\n take: 20,\n});<\/code><\/pre>\n\u8fd9\u98ce\u683c\u66f4\u50cf\u5728”\u63cf\u8ff0\u6211\u8981\u5565”\u800c\u4e0d\u662f”\u544a\u8bc9\u6570\u636e\u5e93\u600e\u4e48\u67e5”\u3002\u7b80\u5355\u573a\u666f\u786e\u5b9e\u633a\u987a\u624b\uff0c\u4e00\u4e2a\u5bf9\u8c61\u585e\u8fdb\u53bb\u5565\u90fd\u6709\u4e86\u3002<\/p>\n
\u4f46\u590d\u6742\u8d77\u6765\u5c31\u5bb9\u6613\u649e\u5899\uff1a<\/p>\n
\n- \u60f3\u7528
GROUP BY ... HAVING<\/code>\uff1f\u5f97\u5207\u5230 groupBy<\/code> API\uff0c\u8bed\u6cd5\u8ddf findMany<\/code> \u5b8c\u5168\u662f\u4e24\u5957<\/li>\n- \u7a97\u53e3\u51fd\u6570\u3001CTE\u3001\u9012\u5f52\u67e5\u8be2\uff1f\u5728
findMany<\/code> \u8fd9\u5957 API \u91cc\u57fa\u672c\u4e0d\u652f\u6301<\/li>\n- \u590d\u6742\u7684
OR<\/code> \/ AND<\/code> \u5d4c\u5957\uff1f\u53ea\u80fd\u5199\u6210\u5c42\u5c42\u5957\u5a03\u7684\u5bf9\u8c61<\/li>\n<\/ul>\nPrisma \u628a SQL \u7684\u4e00\u4e2a\u5b50\u96c6\u5305\u88c5\u5f97\u6f02\u6f02\u4eae\u4eae\uff0c\u4f46\u8d85\u51fa\u8fd9\u4e2a\u5b50\u96c6\u4f60\u901a\u5e38\u5c31\u5f97\u8df3\u5230 $queryRaw<\/code> \/ TypedSQL \u53bb\u5199 SQL\uff1b\u5b83\u80fd\u89e3\u51b3 raw SQL \u95ee\u9898\uff0c\u4f46\u4e0d\u80fd\u50cf Drizzle \u7684 sql<\/code> fragment \u90a3\u6837\u81ea\u7136\u5d4c\u56de\u540c\u4e00\u6761 query builder \u94fe\u91cc\u3002<\/p>\n\u5173\u7cfb\u67e5\u8be2\uff1a\u628a\u5d4c\u5957\u7ec4\u88c5\u5f80\u6570\u636e\u5e93\u63a8<\/h2>\n
\u8fd9\u91cc\u662f\u771f\u6b63\u62c9\u5f00\u5dee\u8ddd\u7684\u5730\u65b9\uff0c\u4e5f\u662f\u540e\u9762\u6027\u80fd\u5dee\u8ddd\u7684\u4e00\u5927\u6765\u6e90\u3002<\/p>\n
Prisma \u7684\u505a\u6cd5<\/strong>\u5206\u4e24\u79cd\u3002relationLoadStrategy: 'query'<\/code> \u4f1a\u5148\u67e5\u7236\u8868\uff0c\u518d\u53d1\u5b50\u67e5\u8be2\uff0c\u6700\u540e\u5728 JS \u91cc\u505a\u5d4c\u5957\u7ec4\u88c5\uff1b\u5d4c\u5957 N \u5c42\u5c31\u4f1a\u6709\u591a\u6b21\u5f80\u8fd4\u3002Prisma 6.0\uff082024\u5e7411\u6708\uff09\u8d77 join<\/code> \u6210\u4e3a\u9ed8\u8ba4 strategy\uff1aPostgres \u4e0b\u4f1a\u7528 LATERAL JOIN<\/code> \u52a0 JSON aggregation\uff0c\u8ba9\u6570\u636e\u5e93\u4fa7\u76f4\u63a5\u7ec4\u88c5\u5d4c\u5957\u7ed3\u679c\u3002<\/p>\n\u6240\u4ee5\u8fd9\u91cc\u771f\u6b63\u7684\u5dee\u5f02\u4e0d\u662f”\u8c01\u4f1a\u4e0d\u4f1a\u4e00\u6761 SQL”\uff0c\u800c\u662f\u8fd9\u4e2a\u80fd\u529b\u662f\u4e0d\u662f Drizzle \u4e00\u5f00\u59cb\u5c31\u56f4\u7ed5 SQL \u5f62\u72b6\u8bbe\u8ba1\u51fa\u6765\u7684<\/strong>\u3002Drizzle RQBv2 \u7684\u505a\u6cd5\u662f\u76f4\u63a5\u751f\u6210\u4e00\u6761\u5173\u7cfb\u67e5\u8be2 SQL\uff0c\u8ba9\u6570\u636e\u5e93\u4e00\u6b21\u6027\u8fd4\u56de\u5d4c\u5957\u597d\u7684\u7ed3\u679c\uff1a<\/p>\nconst result = await db.query.users.findMany({\n with: {\n posts: {\n with: { comments: true },\n limit: 5,\n },\n },\n});<\/code><\/pre>\nPostgres \u4e0b\u751f\u6210\u51fa\u6765\u7684 SQL \u5927\u6982\u957f\u8fd9\u6837\uff1a<\/p>\n
SELECT users.*, (\n SELECT json_agg(p) FROM (\n SELECT posts.*, (\n SELECT json_agg(c) FROM comments c WHERE c.post_id = posts.id\n ) AS comments\n FROM posts WHERE posts.author_id = users.id LIMIT 5\n ) p\n) AS posts\nFROM users;<\/code><\/pre>\n\u4e00\u6b21\u5f80\u8fd4\u5c31\u641e\u5b9a<\/strong>\uff0c\u5d4c\u5957\u7684\u6d3b\u5168\u4ea4\u7ed9 Postgres \u53bb\u505a\u3002\u6838\u5fc3\u7406\u5ff5\uff1aDrizzle \u4fe1\u4efb\u6570\u636e\u5e93\uff0c\u628a\u6d3b\u513f\u5f80\u4e0b\u63a8<\/strong>\u3002<\/p>\n\u8fdb\u9636\u7279\u6027\uff1a\u52a8\u6001\u67e5\u8be2\u4e0e SQL \u7247\u6bb5<\/h2>\n
\u5927\u90e8\u5206 ORM \u9047\u5230”\u6839\u636e\u6761\u4ef6\u62fc\u67e5\u8be2”\u8fd9\u79cd\u573a\u666f\uff0c\u6700\u540e\u90fd\u4f1a\u9000\u5316\u6210\u5b57\u7b26\u4e32\u62fc\u63a5\uff0c\u6216\u8005\u5404\u79cd if...else<\/code> \u5730\u72f1\u3002Drizzle \u6709\u4e00\u62db\u633a\u5999\u7684\uff0c\u5728 drizzle-orm\/src\/pg-core\/query-builders\/select.ts:1056<\/code>\uff1a<\/p>\n$dynamic(): PgSelectDynamic<this> {\n return this;\n}<\/code><\/pre>\n\u8fd0\u884c\u65f6\u4ec0\u4e48\u4e5f\u4e0d\u505a\uff0c\u4f46\u5728\u7c7b\u578b\u5c42\u9762\u628a query builder \u6807\u8bb0\u4e3a”\u53ef\u53d8”\uff0c\u5141\u8bb8\u540e\u7eed\u94fe\u5f0f\u8c03\u7528\uff1a<\/p>\n
function buildQuery(filters: Filters) {\n let q = db.select().from(users).$dynamic();\n if (filters.email) q = q.where(eq(users.email, filters.email));\n if (filters.sortBy) q = q.orderBy(users[filters.sortBy]);\n return q;\n}<\/code><\/pre>\n\u5982\u679c\u4e0d\u8c03 $dynamic()<\/code>\uff0cTS \u4f1a\u76f4\u63a5\u62d2\u7edd\u4f60\u7ed9 q<\/code> \u91cd\u65b0\u8d4b\u503c\u540e\u7684 builder \u518d\u52a0\u6761\u4ef6\u2014\u2014\u56e0\u4e3a\u94fe\u5f0f\u65b9\u6cd5\u7684\u8fd4\u56de\u7c7b\u578b\u4f1a”\u8d8a\u94fe\u8d8a\u7a84”\uff0c\u9650\u5236\u4f60\u80fd\u8c03\u4ec0\u4e48\u3001\u4e0d\u80fd\u8c03\u4ec0\u4e48\u3002$dynamic()<\/code> \u5c31\u662f\u663e\u5f0f\u544a\u8bc9 TS\uff1a”\u6211\u77e5\u9053\u6211\u5728\u52a8\u6001\u62fc\uff0c\u653e\u6211\u4e00\u9a6c”\u3002\u8fd9\u662f\u7c7b\u578b\u5b89\u5168\u548c\u52a8\u6001\u6784\u9020\u4e4b\u95f4\u4e00\u4e2a\u633a\u7cbe\u81f4\u7684\u5e73\u8861\u3002<\/p>\nDrizzle \u8fd8\u81ea\u5e26\u4e00\u4e2a sql<\/code> \u6a21\u677f\u5b57\u9762\u91cf\uff0c\u65e2\u80fd\u585e\u5230\u67e5\u8be2\u91cc\u5f53\u7247\u6bb5\u7528\uff0c\u4e5f\u80fd\u5b8c\u5168\u88f8\u5199 SQL\uff1a<\/p>\n\/\/ \u5d4c\u5230\u67e5\u8be2\u91cc\ndb.select().from(users).where(sql`${users.email} ILIKE ${pattern}`);\n\n\/\/ \u5b8c\u5168\u88f8\u5199\uff0c\u52a8\u6001 identifier \u5fc5\u987b\u767d\u540d\u5355\u6821\u9a8c\u540e\u518d\u62fc\nconst viewName = allowedViews[input.viewName];\nif (!viewName) throw new Error('invalid view name');\nawait db.execute(sql`REFRESH MATERIALIZED VIEW ${sql.identifier(viewName)}`);<\/code><\/pre>\n\u6a21\u677f\u5b57\u7b26\u4e32\u91cc\u7684\u666e\u901a ${}<\/code> \u503c\u4f1a\u8d70\u53c2\u6570\u5316\u6d41\u7a0b\uff08\u5c31\u662f\u524d\u9762\u63d0\u8fc7\u7684 fillPlaceholders<\/code>\uff09\uff0c\u4e0d\u662f\u5b57\u7b26\u4e32\u62fc\u63a5\uff1b\u8868\u540d\u3001\u5217\u540d\u3001view \u540d\u8fd9\u7c7b identifier \u4e0d\u80fd\u5f53\u666e\u901a\u53c2\u6570\u4f20\uff0c\u5fc5\u987b\u4f18\u5148\u7528 schema \u5bf9\u8c61\u3002\u786e\u5b9e\u8981\u52a8\u6001\u4f20 identifier \u65f6\uff0c\u53ef\u4ee5\u7528 sql.identifier()<\/code> \u505a\u65b9\u8a00\u7ea7\u8f6c\u4e49\uff0c\u4f46\u8f93\u5165\u4ecd\u7136\u5fc5\u987b\u5148\u8fc7\u767d\u540d\u5355\uff1bsql.raw()<\/code> \u53ea\u5e94\u8be5\u7528\u4e8e\u5b8c\u5168\u53ef\u4fe1\u7684 SQL \u7247\u6bb5\u3002<\/p>\n\u8fd9\u91cc\u6709\u4e2a\u91cd\u8981\u7684\u533a\u522b\u503c\u5f97\u7279\u522b\u5f3a\u8c03\uff1aDrizzle \u7684 sql<\/code> \u4e0d\u662f”\u7d27\u6025\u51fa\u53e3”\uff0c\u800c\u662f”\u4e00\u7b49\u516c\u6c11”<\/strong>\u3002\u4f60\u53ef\u4ee5\u5728\u4efb\u4f55\u4f4d\u7f6e\u585e\u4e00\u6bb5 sql<\/code> \u7247\u6bb5\u8fdb\u53bb\uff0c\u4e0d\u7528\u653e\u5f03\u7c7b\u578b\u5b89\u5168\u7684\u6574\u6761\u67e5\u8be2\u3002<\/p>\nPrisma \u7684 $queryRaw<\/code> \/ TypedSQL \u66f4\u50cf\u53e6\u4e00\u6761\u67e5\u8be2\u901a\u9053\uff1a\u7c7b\u578b\u5b89\u5168\u5728\u6539\u5584\uff0c\u4f46\u5b83\u548c findMany<\/code> \/ include<\/code> \u8fd9\u5957\u5bf9\u8c61 API \u4e0d\u662f\u540c\u4e00\u4e2a\u53ef\u7ec4\u5408\u7cfb\u7edf\u3002\u9700\u8981\u4e34\u65f6\u585e\u4e00\u4e2a\u7279\u6b8a SQL \u8868\u8fbe\u5f0f\u65f6\uff0cDrizzle \u8fd9\u79cd fragment \u4e00\u7b49\u516c\u6c11\u7684\u6a21\u578b\u66f4\u987a\u624b\u3002<\/p>\n\u7c7b\u578b\u6620\u5c04\uff1a\u67e5\u51fa\u6765\u7684\u4e1c\u897f\u600e\u4e48\u53d8\u6210 TS \u7c7b\u578b<\/h2>\n\u6bcf\u4e00\u5217\u81ea\u5df1\u7ba1\u81ea\u5df1\u7684\u7c7b\u578b\u8f6c\u6362<\/h3>\n
\u6bcf\u4e2a\u5217\u7684 builder \u90fd\u5e26\u4fe9\u5173\u952e\u65b9\u6cd5\uff0cdrizzle-orm\/src\/pg-core\/columns\/jsonb.ts<\/code> \u662f\u6700\u5c0f\u7684\u4f8b\u5b50\uff1a<\/p>\nexport class PgJsonb<...> extends PgColumn<T> {\n getSQLType(): string { return 'jsonb'; }\n\n override mapToDriverValue(value: T['data']): string {\n return JSON.stringify(value);\n }\n\n override mapFromDriverValue(value: T['data'] | string): T['data'] {\n if (typeof value === 'string') {\n try { return JSON.parse(value); } catch { return value as T['data']; }\n }\n return value;\n }\n}<\/code><\/pre>\n\u5c31\u8fd9\u4e48\u7b80\u5355\u2014\u2014\u6bcf\u4e00\u5217\u81ea\u5df1\u8d1f\u8d23 JS \u548c driver \u4e4b\u95f4\u7684\u53cc\u5411\u8f6c\u6362\u3002\u6570\u7ec4\u5217\u4f1a\u9012\u5f52\u8c03 baseColumn.mapFromDriverValue<\/code>\uff08columns\/common.ts:334<\/code>\uff09\uff0c\u6240\u4ee5 text[]<\/code> \u51fa\u6765\u5c31\u662f string[]<\/code>\uff0cinteger[][]<\/code> \u51fa\u6765\u5c31\u662f number[][]<\/code>\uff0c\u7c7b\u578b\u4e00\u70b9\u90fd\u4e0d\u542b\u7cca\u3002<\/p>\n\u8fd9\u91cc\u6709\u4e2a\u7ec6\u8282\u503c\u5f97\u8bf4\uff1a\u8fd9\u4e9b mapper \u5c31\u662f\u666e\u901a\u65b9\u6cd5<\/strong>\uff0c\u6ca1\u6709\u4ec0\u4e48\u5143\u7f16\u7a0b\u3001\u6ca1\u6709\u53cd\u5c04\u3001\u6ca1\u6709\u88c5\u9970\u5668\u3002mapResultRow<\/code> \u6bcf\u6b21\u8dd1\u8d77\u6765\u5c31\u662f\u904d\u5386\u4e00\u4e0b\u5b57\u6bb5\u5217\u8868\uff0c\u6328\u4e2a\u8c03\u5bf9\u5e94\u5217\u7684 mapFromDriverValue<\/code>\u3002\u7b80\u5355\u5230\u51e0\u4e4e\u6ca1\u6709\u8fd0\u884c\u65f6\u5f00\u9500\u3002<\/p>\n\u67e5\u8be2\u7ed3\u679c\u7684\u7c7b\u578b\u4ece\u54ea\u6765<\/h3>\nconst rows = await db\n .select({ id: users.id, email: users.email })\n .from(users);\n\/\/ rows: { id: number; email: string }[] \u2190 TS \u81ea\u52a8\u63a8\u5bfc<\/code><\/pre>\n\u6ce8\u610f\u770b\uff1a\u8fd9\u91cc\u5b8c\u5168\u6ca1\u6709\u4ee3\u7801\u751f\u6210\u3001\u6ca1\u6709\u88c5\u9970\u5668\u3001\u4e5f\u6ca1\u6709\u8fd0\u884c\u65f6\u7684 schema lookup<\/strong>\u3002\u7eaf\u7cb9\u662f .select({...})<\/code> \u7684\u53c2\u6570\u7c7b\u578b\u548c .from(users)<\/code> \u7684\u7c7b\u578b\u7ec4\u5408\u8d77\u6765\uff0c\u8ba9 TS \u81ea\u5df1\u63a8\u5bfc\u51fa\u6765\u7684\u3002<\/p>\n\u8fd9\u5c31\u662f”schema \u5c31\u662f TS”\u5e26\u6765\u7684\u76f4\u63a5\u597d\u5904\uff1a\u65e2\u7136 schema \u672c\u8eab\u662f TS \u8868\u8fbe\u5f0f\uff0c\u90a3\u67e5\u8be2\u7ed3\u679c\u7684\u7c7b\u578b\u63a8\u5bfc\u4e5f\u5c31\u662f\u6b63\u5e38\u7684 TS \u7c7b\u578b\u8fd0\u7b97\uff0c\u4e0d\u9700\u8981\u4efb\u4f55\u5916\u6302\u5de5\u5177\u3002<\/p>\n
Prisma \u5c31\u4e0d\u4e00\u6837\u4e86\u2014\u2014rows<\/code> \u7684\u7c7b\u578b\u662f\u4ece\u751f\u6210\u7684 UserGetPayload<...><\/code> \u6765\u7684\u3002\u4f60\u6539\u5b8c schema \u5fc5\u987b\u91cd\u8dd1 prisma generate<\/code>\uff0cTS \u90a3\u8fb9\u624d\u80fd\u611f\u77e5\u5230\u3002\u8fd9\u4e2a\u5ef6\u8fdf\u542c\u8d77\u6765\u6ca1\u5565\uff0c\u4f46\u65e5\u5e38\u5f00\u53d1\u91cc\u771f\u7684\u70e6\u3002<\/p>\n\u6ca1\u6709\u53d8\u66f4\u8ffd\u8e2a\uff0c\u8fd9\u662f\u597d\u4e8b<\/h3>\n
Drizzle \u67e5\u51fa\u6765\u7684\u6570\u636e\u662f\u7eaf\u5bf9\u8c61\u5b57\u9762\u91cf<\/strong>\uff0c\u4e0d\u662f\u4ec0\u4e48\u5e26\u65b9\u6cd5\u7684\u5b9e\u4f8b\u3002\u4f60\u6ca1\u6cd5\u5199 user.save()<\/code> \u8fd9\u79cd\u4e1c\u897f\uff0c\u60f3\u66f4\u65b0\u5c31\u5f97\u8001\u8001\u5b9e\u5b9e\u5199 db.update(users).set(...).where(eq(users.id, user.id))<\/code>\u3002<\/p>\n\u770b\u8d77\u6765\u5570\u55e6\uff0c\u4f46\u8fd9\u4e2a\u8bbe\u8ba1\u662f\u6709\u610f\u4e3a\u4e4b\u7684\uff1a<\/p>\n
\n- \u7eaf\u5bf9\u8c61 = \u6ca1\u6709 class hydrate\u3001\u6ca1\u6709 proxy\u3001\u6ca1\u6709\u53d8\u66f4\u8ffd\u8e2a\u5bf9\u8c61<\/li>\n
- \u6ca1\u6709\u9690\u5f0f\u72b6\u6001 = \u4e0d\u4f1a”\u810f\u68c0\u67e5”\uff0c\u4e5f\u4e0d\u4f1a\u56e0\u4e3a\u8bbf\u95ee\u67d0\u4e2a\u5c5e\u6027\u5c31\u610f\u5916\u89e6\u53d1\u4e00\u6761\u67e5\u8be2\uff08\u5ef6\u8fdf\u52a0\u8f7d\u7684\u5751\uff09<\/li>\n
- \u62ff\u6765\u76f4\u63a5
JSON.stringify<\/code> \u5c31\u80fd\u6254\u7ed9\u524d\u7aef\uff0c\u4e0d\u7528 .toJSON()<\/code> \u4ec0\u4e48\u7684<\/li>\n<\/ul>\n\u4ee3\u4ef7\u662f\u624b\u5199 update \u8bed\u53e5\u6bd4 user.save()<\/code> \u591a\u6253\u51e0\u4e2a\u5b57\u3002\u4f46\u6362\u6765\u7684\u662f\u53ef\u9884\u6d4b\u6027<\/strong>\uff1a\u770b\u5230\u4e00\u6b21 db.update()<\/code>\uff0c\u5c31\u662f\u4e00\u6b21\u6570\u636e\u5e93\u64cd\u4f5c\uff0c\u6ca1\u6709\u9690\u85cf\u7684\u8c03\u7528\u3002<\/p>\n\u751f\u6001\u548c\u8fd0\u884c\u65f6\uff1a\u80fd\u5728\u54ea\u4e9b\u5730\u65b9\u8dd1<\/h2>\n\u9a71\u52a8\u9002\u914d\uff1a\u5206\u5c42\u67b6\u6784\u7684\u7ea2\u5229<\/h3>\n
Drizzle \u7684\u4ee3\u7801\u7ec4\u7ec7\u672c\u8eab\u5c31\u80fd\u8bf4\u660e\u5b83\u7684\u8bbe\u8ba1\u7406\u5ff5\u3002drizzle-orm\/src\/<\/code> \u4e0b\u9762\u957f\u8fd9\u6837\uff1a<\/p>\npg-core\/ \u2190 \u65b9\u8a00\u62bd\u8c61\uff08SQL \u751f\u6210\u3001query builder\uff09\nnode-postgres\/ \u2190 node.js pg \u9a71\u52a8\u9002\u914d\u5668\npostgres-js\/ \u2190 postgres.js \u9a71\u52a8\u9002\u914d\u5668\nneon-http\/ \u2190 Neon serverless HTTP \u9002\u914d\u5668\nneon-serverless\/ \u2190 Neon WebSocket \u9002\u914d\u5668\npglite\/ \u2190 WASM Postgres \u9002\u914d\u5668\nvercel-postgres\/ \u2190 Vercel \u9002\u914d\u5668\n...<\/code><\/pre>\n\u6838\u5fc3\u903b\u8f91\uff08SQL \u751f\u6210\u3001query builder\uff09\u90fd\u5728 pg-core<\/code> \u91cc\uff0c\u62bd\u8c61\u51fa PgSession<\/code> \u548c PgPreparedQuery<\/code>\uff08pg-core\/session.ts:168<\/code>\uff09\u3002\u6bcf\u4e2a\u9a71\u52a8\u9002\u914d\u5668\u53ea\u7ba1\u5b9e\u73b0 prepareQuery<\/code> \u8fd9\u4e00\u4e2a\u65b9\u6cd5\u2014\u2014\u628a Drizzle \u751f\u6210\u7684 { sql, params }<\/code> \u7ffb\u8bd1\u7ed9\u81ea\u5df1\u5bf9\u5e94\u7684\u9a71\u52a8\u5c31\u5b8c\u4e8b\u4e86\u3002<\/p>\n\u652f\u6301\u7684\u6570\u636e\u5e93\u4e00\u957f\u4e32\uff1aPostgres\u3001MySQL\u3001SQLite\u3001SingleStore\u3001MSSQL\u3001CockroachDB\u3001Gel\uff0c\u5916\u52a0\u5b83\u4eec\u5404\u81ea\u7684 serverless \u53d8\u4f53\u3002<\/p>\n
\u8fd9\u67b6\u6784\u6700\u5b9e\u9645\u7684\u597d\u5904\u662f\uff1a\u540c\u4e00\u5957 schema \u548c\u67e5\u8be2 DSL \u53ef\u4ee5\u590d\u7528\u5728\u4e0d\u540c\u9a71\u52a8\u4e0a<\/strong>\u3002\u4f60\u4eca\u5929\u7528\u672c\u5730 pg<\/code>\uff0c\u660e\u5929\u60f3\u4e0a Neon serverless\uff0c\u901a\u5e38\u4e3b\u8981\u6539\u521d\u59cb\u5316\u548c import\uff0c\u4e1a\u52a1\u67e5\u8be2\u4e0d\u7528\u8ddf\u7740\u91cd\u5199\u3002Prisma 7 \u7684 Driver Adapters \u5df2\u662f\u9ed8\u8ba4\uff0c\u6362\u9a71\u52a8\u7684\u4f53\u9a8c\u4e5f\u6539\u5584\u4e86\u5f88\u591a\uff0c\u4f46\u62bd\u8c61\u6a21\u578b\u4ecd\u7136\u6bd4 Drizzle \u539a\u3002<\/p>\nEdge \/ Serverless\uff1a\u80fd\u8dd1\u5417\uff1f<\/h3>\n
\u73b0\u5728\u5199 TS \u540e\u7aef\u7ed5\u4e0d\u8fc7\u53bb\u7684\u4e00\u4e2a\u95ee\u9898\uff1a\u80fd\u4e0d\u80fd\u6254\u5230 Cloudflare Workers\u3001Vercel Edge Functions\u3001AWS Lambda \u4e0a\u8dd1\uff1f<\/p>\n
Drizzle \u7684\u6838\u5fc3\u5e93\u662f\u7eaf TS\uff0c\u96f6\u539f\u751f\u4f9d\u8d56<\/strong>\u3002V8 isolate\u3001Node \u51b7\u542f\u52a8\u90fd\u6ca1\u95ee\u9898\uff0c\u914d\u4e0a Neon HTTP \u6216 Cloudflare D1 \u6574\u6761\u94fe\u8def\u90fd\u80fd\u585e\u8fdb edge runtime\u3002<\/p>\n\u5bf9\u6bd4\uff1aPrisma 7.0\uff082025\u5e7411\u6708\uff09\u5df2\u5207\u6362\u5230\u7eaf TypeScript \u5b9e\u73b0\uff0c\u79fb\u9664\u4e86 Rust query engine\uff0c\u539f\u751f\u652f\u6301 edge runtime\uff1bTypeORM \u91cd\u5ea6\u4f9d\u8d56\u53cd\u5c04\u548c\u88c5\u9970\u5668\u8fd0\u884c\u65f6\uff0c\u5728 edge runtime \u91cc\u9650\u5236\u4f1a\u591a\u5f88\u591a\u3002<\/p>\n
Bundle size \u4e5f\u662f\u5b9e\u9645\u5dee\u8ddd\uff1aDrizzle \u6838\u5fc3\u548c\u9a71\u52a8\u9002\u914d\u5668\u5f88\u8584\uff1bPrisma 7 \u79fb\u9664 Rust engine \u540e bundle \u5df2\u5927\u5e45\u7f29\u5c0f\uff0c\u4f46\u751f\u6210\u7684 Client \u4ee3\u7801\u4ecd\u7136\u6bd4 Drizzle \u91cd\u3002\u5177\u4f53\u6570\u5b57\u4f1a\u968f\u7248\u672c\u3001bundler \u548c\u76ee\u6807\u5e73\u53f0\u53d8\u5316\uff0c\u6700\u597d\u4ee5\u4f60\u7684\u5b9e\u9645\u6784\u5efa\u4ea7\u7269\u4e3a\u51c6\u3002<\/p>\n
drizzle-kit\uff1a\u8fc1\u79fb\u600e\u4e48\u5904\u7406<\/h3>\n
schema \u5728\u4ee3\u7801\u91cc\u5199\u597d\u4e86\uff0c\u600e\u4e48\u843d\u5230\u751f\u4ea7\u6570\u636e\u5e93\uff1fdrizzle-kit\uff08\u72ec\u7acb\u7684 CLI \u5de5\u5177\uff09\u7ed9\u4e86\u4e09\u6761\u8def\uff1a<\/p>\n
# 1. \u751f\u6210\u8fc1\u79fb SQL\uff08\u751f\u4ea7\u73af\u5883\u63a8\u8350\uff09\ndrizzle-kit generate\n# \u5bf9\u6bd4\u5f53\u524d schema.ts \u548c\u4e0a\u6b21\u7684\u5feb\u7167\uff0c\u751f\u6210 0001_xxx.sql\n\n# 2. \u76f4\u63a5\u63a8\uff08\u5f00\u53d1\u671f\u7528\uff09\ndrizzle-kit push\n# \u4e0d\u751f\u6210\u8fc1\u79fb\u6587\u4ef6\uff0c\u76f4\u63a5 ALTER TABLE \u603c\u8fc7\u53bb\n\n# 3. \u4ece\u5df2\u6709\u6570\u636e\u5e93\u53cd\u5411\u751f\u6210 schema.ts\ndrizzle-kit introspect<\/code><\/pre>\n\u539f\u7406\u4e0d\u590d\u6742\uff1adrizzle-kit \u5728 meta\/<\/code> \u76ee\u5f55\u4e0b\u5b58\u4e00\u4e2a schema \u7684 JSON \u5feb\u7167\uff0cgenerate<\/code> \u7684\u65f6\u5019\u5bf9\u6bd4\u65b0\u65e7\u5feb\u7167\u5f97\u5230 jsonStatements<\/code>\uff08\u770b drizzle-kit\/src\/jsonStatements.ts<\/code> \u548c snapshotsDiffer.ts<\/code>\uff09\uff0c\u518d\u7531 sqlgenerator.ts<\/code> \u7ffb\u8bd1\u6210\u5bf9\u5e94\u65b9\u8a00\u7684 SQL\u3002<\/p>\n\u8ddf Prisma Migrate \u6bd4\uff1a<\/p>\n
\n- \u4e24\u5bb6\u90fd\u662f\u58f0\u660e\u5f0f schema \u2192 \u81ea\u52a8\u751f\u6210\u8fc1\u79fb\uff0c\u8fd9\u70b9\u4e00\u6837<\/li>\n
- Prisma \u7684\u8fc1\u79fb\u5386\u53f2\u585e\u5728
_prisma_migrations<\/code> \u8fd9\u5f20\u8868\u91cc\uff0c\u8fd8\u9700\u8981\u4e00\u4e2a shadow database \u7528\u6765\u68c0\u6d4b\u6f02\u79fb<\/li>\n- Drizzle \u751f\u6210\u7684\u5c31\u662f\u666e\u901a SQL \u6587\u4ef6\uff0c\u4eba\u773c\u53ef\u8bfb\uff0c\u4f60\u968f\u4fbf\u62ff\u7f16\u8f91\u5668\u6253\u5f00\u6539<\/li>\n<\/ul>\n
\u80fd\u624b\u6539<\/strong>\u8fd9\u4ef6\u4e8b\u5728\u5b9e\u9645\u751f\u4ea7\u91cc\u592a\u91cd\u8981\u4e86\u3002\u81ea\u52a8\u751f\u6210\u7684\u8fc1\u79fb\u5076\u5c14\u4f1a\u662f\u4e0d\u5b89\u5168\u7684\u2014\u2014\u6bd4\u5982\u7ed9\u4e00\u5f20\u5927\u8868\u52a0 NOT NULL<\/code> \u5217\uff0c\u6ca1\u6709 DEFAULT<\/code> \u76f4\u63a5\u4e0a\u53ef\u80fd\u9501\u6b7b\u4e00\u6bb5\u65f6\u95f4\u3002\u4f60\u5f97\u80fd\u6253\u5f00\u90a3\u4e2a SQL \u6587\u4ef6\uff0c\u52a0\u4e2a\u9ed8\u8ba4\u503c\uff0c\u6216\u8005\u62c6\u6210”\u52a0\u5217 + \u56de\u586b + \u52a0\u7ea6\u675f”\u8fd9\u79cd\u5206\u6b65\u6d41\u7a0b\u3002Prisma \u4e5f\u80fd\u624b\u6539\uff0c\u4f46 Drizzle \u8fd9\u79cd\u7eaf SQL \u6587\u4ef6\u5fc3\u7406\u8d1f\u62c5\u5c0f\u5f97\u591a\u3002<\/p>\n\u6027\u80fd\uff1a\u524d\u9762\u6240\u6709\u9009\u62e9\u7684\u540e\u679c<\/h2>\n
\u94fa\u57ab\u4e86\u8fd9\u4e48\u4e45\uff0c\u7ec8\u4e8e\u53ef\u4ee5\u56de\u5230\u4e00\u5f00\u59cb\u90a3\u4e2a\u95ee\u9898\uff1aDrizzle \u51ed\u4ec0\u4e48\u8d34\u7740 Go \u8dd1\uff1f<\/strong><\/p>\n\u524d\u9762\u6bcf\u4e00\u7ae0\u7684\u8bbe\u8ba1\u9009\u62e9\u90fd\u5728\u4e3a\u6027\u80fd\u94fa\u8def\uff0c\u73b0\u5728\u94bb\u8fdb\u6e90\u7801\u770b\u770b\u70ed\u8def\u5f84\u4e0a\u5177\u4f53\u7701\u4e86\u4ec0\u4e48\u3002<\/p>\n
\u5047\u8bbe\u4f60\u5199\u4e86\u8fd9\u4e48\u4e00\u6bb5\u4ee3\u7801\uff1a<\/p>\n
const q = db.select().from(users)\n .where(eq(users.id, sql.placeholder('id')))\n .prepare('get_user');\n\nawait q.execute({ id: 1 });<\/code><\/pre>\n\u5982\u679c\u4f60\u5728\u521d\u59cb\u5316 Drizzle \u65f6\u6253\u5f00 jit: true<\/code>\uff0c\u540c\u4e00\u4e2a prepare \u8fc7\u7a0b\u91cc\u8fd8\u4f1a\u751f\u6210\u4e13\u7528\u7684 row mapper\u3002\u4e3a\u4e86\u907f\u514d\u6df7\u5728\u4e00\u8d77\uff0c\u5148\u770b .prepare()<\/code> \u672c\u8eab\uff0c\u518d\u770b JIT mapper\u3002<\/p>\n.prepare()<\/code> \u5230\u5e95\u505a\u4e86\u4ec0\u4e48<\/h3>\nv1.0.0-rc.1 \u628a prepare \u903b\u8f91\u4ece query builder \u4e2d\u62c6\u51fa\uff0c\u79fb\u5230\u4e86 pg-core\/async\/select.ts:104<\/code>\uff1a<\/p>\n_prepare(name?: string, generateName = false): PgAsyncSelectPrepare<this> {\n const { session, config, dialect, joinsNotNullableMap, cacheConfig, usedTables } = this;\n return tracer.startActiveSpan('drizzle.prepareQuery', () => {\n const query = dialect.sqlToQuery(this.getSQL()); \/\/ 1. AST \u2192 SQL + params\n const fieldsList = orderSelectedFields<PgColumn>(fields);\n const mapper = this.dialect.mapperGenerators.rows(fieldsList, joinsNotNullableMap);\n const preparedQuery = session.prepareQuery( \/\/ 2. \u521b\u5efa\u9884\u7f16\u8bd1\u67e5\u8be2\n query, 'arrays', name ?? generateName, mapper,\n { type: 'select', tables: [...usedTables] }, cacheConfig,\n );\n return preparedQuery;\n });\n}<\/code><\/pre>\n\u4e09\u4ef6\u5927\u4e8b\u5728\u67e5\u8be2\u51c6\u5907\u9636\u6bb5\u4e00\u6b21\u6027\u505a\u5b8c\uff0c\u4e4b\u540e\u6267\u884c\u540c\u4e00\u4e2a prepared query \u65f6\u4e0d\u518d\u91cd\u590d\uff1a<\/p>\n
\n- SQL chunk \u7f16\u8bd1\u6210
{ sql, params }<\/code><\/li>\n- select fields \u6392\u5e8f\u5e76\u7ed1\u5b9a row mapper<\/li>\n
- \u8ba9\u5177\u4f53 session \u751f\u6210
PgPreparedQuery<\/code><\/li>\n<\/ul>\nSQL \u7f16\u8bd1\uff1a\u5c31\u662f chunk \u62fc\u5b57\u7b26\u4e32<\/h3>\n
dialect.sqlToQuery()<\/code> \u6700\u7ec8\u4f1a\u8c03\u5230 sql\/sql.ts:170<\/code> \u7684 buildQueryFromSourceParams<\/code>\uff1a<\/p>\nbuildQueryFromSourceParams(chunks: SQLChunk[], _config: BuildQueryConfig): Query {\n \/\/ ...\n const mappedChunks = chunks.map((chunk): QueryWithTypings => {\n if (is(chunk, StringChunk)) return { sql: chunk.value.join(''), params: [] };\n if (is(chunk, Name)) return { sql: escapeName(chunk.value), params: [] };\n \/\/ ... Param \/ Placeholder \/ \u5d4c\u5957 SQL \/ \u6570\u7ec4\n });\n}<\/code><\/pre>\n\u6ce8\u610f\u4e00\u4e2a\u5173\u952e\u7ec6\u8282\uff1aPlaceholder<\/code> \u5728\u8fd9\u4e00\u6b65\u4e0d\u4f1a\u88ab\u66ff\u6362\u6389<\/strong>\uff0c\u5b83\u4f1a\u88ab\u539f\u6837\u585e\u8fdb params<\/code> \u6570\u7ec4\u91cc\u3002\u8fd9\u5c31\u662f\u4e3a\u4ec0\u4e48 SQL \u5b57\u7b26\u4e32\u80fd\u4e00\u6b21\u751f\u6210\u3001\u65e0\u6570\u6b21\u590d\u7528\u7684\u79d8\u5bc6\u2014\u2014\u53c2\u6570\u586b\u5145\u662f\u540e\u9762\u7684\u4e8b\u3002<\/p>\n\u7f16\u8bd1\u7ed3\u679c { sql: "SELECT ... WHERE id = $1", params: [Placeholder('id')] }<\/code> \u88ab\u7f13\u5b58\u5728 PgAsyncPreparedQuery<\/code> \u5b9e\u4f8b\u91cc\u3002<\/p>\n\u9a71\u52a8\u5c42\u4e5f\u63d0\u524d\u628a\u4e1c\u897f\u51c6\u5907\u597d<\/h3>\n
\u53bb\u770b drizzle-orm\/src\/node-postgres\/session.ts:65<\/code>\uff0cprepareQuery<\/code> \u65b9\u6cd5\u91cc\u5e72\u4e86\u4ef6\u806a\u660e\u4e8b\u2014\u2014\u628a pg \u9a71\u52a8\u8981\u7684 QueryConfig<\/code> \u5c01\u88c5\u6210\u4e00\u4e2a executor<\/code> \u95ed\u5305\uff0c\u4e00\u6b21\u6027<\/strong>\u6355\u83b7\u6240\u6709\u914d\u7f6e\uff1a<\/p>\nprepareQuery(query, mode, name, mapper, queryMetadata, cacheConfig) {\n const queryName = typeof name === 'string'\n ? name\n : name === true ? preparedStatementName(query.sql, query.params) : undefined;\n\n const executor = async (params?: unknown[]) => {\n return this.client.query({\n name: queryName, \/\/ \u2190 \u5173\u952e\n rowMode: mode === 'arrays' ? 'array' : undefined,\n text: query.sql,\n types: typeConfig,\n }, params).then((r) => mode === 'raw' ? r : r.rows);\n };\n\n return new PgAsyncPreparedQuery(executor, query, mapper, ...);\n}<\/code><\/pre>\n\u95ed\u5305\u521b\u5efa\u5b8c\u5c31\u5b9a\u578b\u4e86\uff0c\u4e4b\u540e\u6bcf\u6b21\u6267\u884c\u90fd\u662f\u540c\u4e00\u4e2a executor<\/code> \u76f4\u63a5\u8c03\u7528\u3002\u6ce8\u610f\uff1aQueryConfig<\/code> \u5bf9\u8c61\u5b57\u9762\u91cf\u4ecd\u7136\u662f\u5728 executor<\/code> \u91cc\u521b\u5efa\u7684\uff0c\u6bcf\u6b21\u8c03\u7528\u90fd\u4f1a\u6709\u4e00\u4e2a\u5f88\u5c0f\u7684\u5bf9\u8c61\u5206\u914d\uff1b\u771f\u6b63\u88ab\u590d\u7528\u7684\u662f SQL\u3001queryName<\/code>\u3001mapper \u548c\u95ed\u5305\u91cc\u6355\u83b7\u7684\u914d\u7f6e\u3002<\/p>\nname<\/code> \u5b57\u6bb5\u662f\u6574\u4ef6\u4e8b\u7684\u70b9\u775b\u4e4b\u7b14<\/strong>\uff1apg \u9a71\u52a8\u770b\u5230 QueryConfig.name<\/code> \u6709\u503c\uff0c\u5c31\u4f1a\u4f7f\u7528 named prepared statement\u3002\u7b2c\u4e00\u6b21\u5728\u67d0\u4e2a\u8fde\u63a5\u4e0a\u6267\u884c\u65f6\uff0cPostgres \u4f1a\u6309\u8fd9\u4e2a name \u7f13\u5b58\u89e3\u6790\u540e\u7684 statement\uff1b\u4e4b\u540e\u540c\u4e00\u8fde\u63a5\u4e0a\u7684\u540c\u540d\u8c03\u7528\u53ef\u4ee5\u590d\u7528\u5b83\uff0c\u7701\u6389\u91cd\u590d parse \u7684\u5f00\u9500\uff0c\u5e76\u4e14\u5728\u591a\u6b21\u6267\u884c\u540e\uff08\u9ed8\u8ba4\u7b2c 6 \u6b21\u8d77\uff09Postgres \u8fd8\u53ef\u80fd\u5207\u6362\u5230 generic plan\uff0c\u540e\u7eed\u6267\u884c\u76f4\u63a5\u590d\u7528\u540c\u4e00\u4e2a plan\uff0c\u4e0d\u518d\u91cd\u65b0\u89c4\u5212\u3002\u81f3\u4e8e plan \u662f custom \u8fd8\u662f generic\u3001\u4f55\u65f6\u590d\u7528\uff0cPostgres \u81ea\u5df1\u8fd8\u6709\u4e00\u5957\u7b56\u7565\uff08plan_cache_mode<\/code>\uff09\uff0c\u4e0d\u5b9c\u7b80\u5355\u8bf4\u6210”\u6c38\u8fdc\u8df3\u8fc7 plan”\u3002<\/p>\n\u503c\u5f97\u6ce8\u610f\u7684\u662f\uff0crc.1 \u91cc\u5982\u679c\u4f60\u8c03 .prepare()<\/code> \u4e0d\u4f20 name\uff0cDrizzle \u4f1a\u81ea\u52a8\u6839\u636e SQL \u548c params \u751f\u6210\u4e00\u4e2a\u786e\u5b9a\u6027\u7684 statement name\uff08preparedStatementName(query.sql, query.params)<\/code>\uff09\uff0c\u6240\u4ee5\u5373\u4f7f\u4e0d\u624b\u52a8\u547d\u540d\u4e5f\u80fd\u4eab\u53d7 server-side prepare\u3002<\/p>\n\u6709\u610f\u601d\u7684\u662f\uff1aDrizzle \u81ea\u5df1\u5176\u5b9e\u5565\u90fd\u6ca1\u505a<\/strong>\uff0c\u5b83\u5c31\u662f\u628a\u8fd9\u4e2a name<\/code> \u900f\u4f20\u4e0b\u53bb\u3002\u6240\u8c13”server-side prepare”\u7684\u6d3b\u513f\uff0c\u662f pg \u9a71\u52a8\u548c Postgres \u670d\u52a1\u5668\u4e4b\u95f4\u5b8c\u6210\u7684\u3002Drizzle \u53ea\u662f\u8db3\u591f\u806a\u660e\u5730\u7ad9\u5728\u4e86\u6b63\u786e\u7684\u4f4d\u7f6e\u3002<\/p>\n\u70ed\u8def\u5f84\uff1aexecute()<\/code> \u65b0\u589e fastPath \u4f18\u5316<\/h3>\n\u770b drizzle-orm\/src\/pg-core\/async\/session.ts:61<\/code>\uff1a<\/p>\nasync execute(placeholderValues: Record<string, unknown> = {}): Promise<T['execute']> {\n const { query, logger, executor, mapper, fastPath } = this;\n\n if (fastPath) {\n const params = query.params.length === 0\n ? query.params\n : fillPlaceholders(query.params, placeholderValues); \/\/ 1\n logger.logQuery(sql, params);\n const res = executor(params); \/\/ 2\n if (!mapper) return res;\n return res.then((rows) => mapper(rows)); \/\/ 3\n }\n \/\/ \u975e fastPath \u8d70 tracing span...\n}<\/code><\/pre>\n