kysely-data-api

import { Kysely } from 'kysely'; import { DataApiDialect } from 'kysely-data-api'; import { RDSDataService } from '@aws-sdk/client-rds-data'; // Define your database schema interface (replace with your actual schema) interface Database { person: { id: number; first_name: string; last_name: string; }; // Add other tables here } async function initializeDb() { const dataApi = new DataApiDialect({ mode: 'mysql', // or 'postgres' driver: { client: new RDSDataService({ region: process.env.AWS_REGION ?? 'us-east-1' }), database: process.env.DB_NAME ?? 'my_database', secretArn: process.env.DB_SECRET_ARN ?? '<arn of secret containing credentials>', resourceArn: process.env.DB_RESOURCE_ARN ?? '<arn of database>', }, }); const db = new Kysely<Database>({ dialect: dataApi }); try { const results = await db.selectFrom('person').selectAll().execute(); console.log('Query results:', results); } catch (error) { console.error('Database query failed:', error); } finally { // In serverless environments, explicit connection closing is often not needed // as the Lambda invocation ends, but for local testing, consider: // await db.destroy(); } } initializeDb();