const { Client } = require('pg');
const client = new Client({ connectionString: process.env.DATABASE_URL });

async function checkSpecificTxs() {
    await client.connect();
    const res = await client.query(`
        SELECT id, source_ref_id, metadata 
        FROM transactions 
        WHERE source_ref_id IN ('TEST_ORDER_999', 'TEST_ORDER_1000')
    `);
    console.log(JSON.stringify(res.rows, null, 2));
    await client.end();
}

checkSpecificTxs();