pool

alfateam · Jun 26, 2024 · 967503e · 967503e
1 parent 23b52b3
commit 967503e
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 6 deletions.
diff --git a/src/drizzle/benchmark-pg.ts b/src/drizzle/benchmark-pg.ts
@@ -14,7 +14,9 @@ async function benchmark() {
 
 async function warmup() {
 	//to initate possible lazy loaded pool
-	await postgres.query.customers.findFirst();
+	for (let i = 0; i < 12; i++) {        
+		await postgres.query.customers.findFirst();
+    }
 }
 
 async function getRowsWithRelations() {

diff --git a/src/drizzle/postgres.ts b/src/drizzle/postgres.ts
@@ -3,7 +3,7 @@ import postgres from "postgres";
 import * as schema from './schema';
 
 
-export const connection = postgres('postgres://postgres:postgres@postgres/postgres', { max: 1 });
+export const connection = postgres('postgres://postgres:postgres@postgres/postgres', { max: 10 });
 
 export const db = drizzle(connection, {
   schema,

diff --git a/src/orange/benchmark-pg.ts b/src/orange/benchmark-pg.ts
@@ -17,7 +17,9 @@ async function benchmark() {
 
 async function warmup() {
     //to initate possible lazy loaded pool
-    await pg.customers.getOne();
+    for (let i = 0; i < 12; i++) {        
+        await pg.customers.getOne();
+    }
 }
 
 async function getRowsWithRelations() {

diff --git a/src/orange/postgres.ts b/src/orange/postgres.ts
@@ -1,4 +1,4 @@
 import map from './map';
 
-export default map.postgres('postgres://postgres:postgres@postgres/postgres', { size: 1});
+export default map.postgres('postgres://postgres:postgres@postgres/postgres', { size: 10});
 
diff --git a/src/prisma/benchmark-pg.ts b/src/prisma/benchmark-pg.ts
@@ -6,7 +6,7 @@ const ITERATIONS = Number.parseInt(process.env.ITERATIONS);
 const prisma = new PrismaClient({
     datasources: {
         db: {
-            url: `${process.env.POSTGRES_URL}?connection_limit=1`,
+            url: `${process.env.POSTGRES_URL}?connection_limit=10`,
         },
     },
     log: [
@@ -30,7 +30,9 @@ async function benchmark() {
 }
 
 async function warmup() {
-    await prisma.order.findMany({ take: 1 });
+    for (let i = 0; i < 12; i++) {        
+        await prisma.order.findMany({ take: 1 });        
+    }
 }
 
 async function getRowsWithRelations() {