const { Client } = require('pg');
(async () => {
  const admin = new Client({ host:'localhost', port:5433, user:'nati', password:'password', database:'postgres' });
  await admin.connect();
  const { rows } = await admin.query("SELECT 1 FROM pg_database WHERE datname='nati_wt_opsreport'");
  if (!rows.length) {
    await admin.query('CREATE DATABASE nati_wt_opsreport TEMPLATE edr_dev_sqltest');
    console.log('created nati_wt_opsreport from edr_dev_sqltest');
  } else console.log('already exists');
  await admin.end();
  const db = new Client({ host:'localhost', port:5433, user:'nati', password:'password', database:'nati_wt_opsreport' });
  await db.connect();
  for (const t of ['train_schedules','train_set_wagons','wagon_booking_allocations','wagon_allocation_container_items','wagon_allocation_bulk_loads','yard_distances','yards','cargo_types','train_checkpoint_events','bookings','container_types']) {
    const r = await db.query(`SELECT count(*)::int n FROM freight.${t}`);
    console.log(t.padEnd(36), r.rows[0].n);
  }
  await db.end();
})().catch(e => { console.error('FAIL', e.message); process.exit(1); });