pool-async-await.js 730 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. const { Pool } = require('pg');
  2. const pool = new Pool({
  3. user: 'postgres',
  4. host: 'localhost',
  5. database: 'testdb',
  6. password: '1234abcd',
  7. port: 5432,
  8. })
  9. pool.on('error', (err, client) => {
  10. console.error('Error:', err)
  11. })
  12. const query = `
  13. SELECT *
  14. FROM users
  15. `;
  16. (async () => {
  17. try {
  18. const client = await pool.connect();
  19. const res = await client.query(query);
  20. for (let row of res.rows) {
  21. console.log(row)
  22. }
  23. } catch (err) {
  24. console.error(err);
  25. }
  26. })();
  27. /**
  28. Expected output:
  29. {
  30. email: 'johndoe@gmail.com',
  31. firstname: 'john',
  32. lastname: 'doe',
  33. age: 21
  34. }
  35. {
  36. email: 'anna@gmail.com',
  37. firstname: 'anna',
  38. lastname: 'dias',
  39. age: 35
  40. }
  41. */