GPT

Database Utility Functions

// src/utils/dbUtils.js import { db } from '../db/index.js'; import { sql } from 'drizzle-orm'; export async function withTransaction(callback) { try { await db.execute(sqlBEGIN); const result = await callback(db);

Prompt text

Original English text. Replace placeholders with your own details.

// src/utils/dbUtils.js
import { db } from '../db/index.js';
import { sql } from 'drizzle-orm';

export async function withTransaction(callback) {
 try {
 await db.execute(sql`BEGIN`);
 const result = await callback(db);
 await db.execute(sql`COMMIT`);
 return result;
 } catch (error) {
 await db.execute(sql`ROLLBACK`);
 throw error;
 }
}

export async function createPaginatedQuery(
 baseQuery,
 page,
 pageSize,
 params = []
) {
 const offset = (page - 1) * pageSize;
 const countQuery = `SELECT COUNT(*) as total FROM (${baseQuery}) as subquery`;
 
 const [{ total }] = await db.execute(countQuery, params);
 const data = await db.execute(
 `${baseQuery} LIMIT ${pageSize} OFFSET ${offset}`,
 params
 );

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

export async function executeInBatch(items, batchSize, callback) {
 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 →