easy-database-connector

import { query, execute, queryWithPagination, transaction } from 'easy-database-connector'; import 'dotenv/config'; // Ensure environment variables are loaded interface User { id: number; name: string; email: string; active: boolean; } async function runExample() { // Basic query const users = await query<User>({ sql: 'SELECT * FROM users WHERE active = @p0', parameters: [true] }); console.log('Active users:', users); // Paged query with caching const pagedUsers = await queryWithPagination<User>({ sql: 'SELECT * FROM users', parameters: [], page: 1, pageSize: 10, orderBy: 'name ASC', cache: { key: 'users:page1', ttl: 300 // 5 minutes } }); console.log('Paged users:', pagedUsers.rows); // Encrypted data insertion (requires MSSQL encryption setup) // Ensure environment variables for encryption are set: MSSQL_SYNNETRIC_KEY_NAME, MSSQL_CERTIFICATE_NAME, MASTER_KEY_PASSWORD try { await execute({ sql: 'INSERT INTO secure_data (data) VALUES (@p0)', parameters: ['sensitive information'], encryption: { open: { aes: true, masterkey: true }, data: ['0'] } }); console.log('Sensitive data inserted (encrypted).'); } catch (e) { console.error('Failed to insert encrypted data. Check MSSQL encryption setup and .env config.', e); } // Transaction example await transaction(async (trx) => { await execute({ sql: 'INSERT INTO users (name) VALUES (@p0)', parameters: ['John Doe'], transaction: trx }); await execute({ sql: 'INSERT INTO logs (action) VALUES (@p0)', parameters: ['user_john_created'], transaction: trx }); }); console.log('Transaction completed: User and log created.'); } runExample().catch(console.error);