GPT

Database Utility Functions

// app/lib/db.utils.server.ts import { sql } from './db.server'; export async function withTransaction ( callback: (transaction: typeof sql) = Promise ): Promise { try { await sqlBEGIN; const result = await callbac

Prompt text

Original English text. Replace placeholders with your own details.

// app/lib/db.utils.server.ts
import { sql } from './db.server';

export async function withTransaction<T>(
 callback: (transaction: typeof sql) => Promise<T>
): Promise<T> {
 try {
 await sql`BEGIN`;
 const result = await callback(sql);
 await sql`COMMIT`;
 return result;
 } catch (error) {
 await sql`ROLLBACK`;
 throw error;
 }
}

export async function createPaginatedQuery<T>(
 baseQuery: string,
 page: number,
 pageSize: number,
 params: any[] = []
): Promise<{ data: T[]; total: number; pages: number }> {
 const offset = (page - 1) * pageSize;
 const countQuery = `SELECT COUNT(*) as total FROM (${baseQuery}) as subquery`;
 
 const [{ total }] = await sql.raw(countQuery, params);
 const data = await sql.raw<T[]>(
 `${baseQuery} LIMIT ${pageSize} OFFSET ${offset}`,
 params
 );

 return {
 data,
 total: parseInt(total),
 pages: Math.ceil(total / pageSize)
 };
}

export async function executeInBatch<T>(
 items: T[],
 batchSize: number,
 callback: (batch: T[]) => Promise<void>
): Promise<void> {
 for (let i = 0; i < items.length; i += batchSize) {
 const batch = items.slice(i, i + batchSize);
 await callback(batch);
 }
}

Source & attribution

Instructa AI Prompts · Instructa AI Prompts

Source-listed license: CC-BY-4.0. Prompt text is preserved; titles and previews may be shortened for display. Source examples are not NexGateHub test results.

View original source ↗ · Source credits & licenses

Explore more prompts →