postgresql-cg

PostgreSQL Connector for Node.js

A Node.js module for connecting to PostgreSQL databases using the pg library.

Installation

Install the module using npm:

npm install pg

npm install postgresql-cg

const PostgreSQLConnector = require('postgresql-cg');

// Replace with your actual database connection configuration
const dbConfig = {
  user: 'your_username',
  host: 'your_host',
  database: 'your_database',
  password: 'your_password',
  port: 5432,
};

async function main() {
  const connector = new PostgreSQLConnector(dbConfig);

  try {
    // select query
    const selectQuery = 'SELECT * FROM your_table';
    const selectResult = await connector.executeQuery('select', selectQuery);
    console.log('Select result:', selectResult);
  } catch (error) {
    console.error('Error executing select query:', error);
  }

  try {
    // insert query
    const insertQuery = "INSERT INTO your_table (id, username, email) VALUES (id, 'name', '[e-mail]')";
    const insertResult = await connector.executeQuery('insert', insertQuery);
    console.log('Insert result:', insertResult);
  } catch (error) {
    console.error('Error executing insert query:', error);
  }

  try {
    // update query
    const updateQuery = "UPDATE your_table SET email = '[e-mail]' WHERE id = 111";
    const updateResult = await connector.executeQuery('update', updateQuery);
    console.log('Update result:', updateResult);
  } catch (error) {
    console.error('Error executing update query:', error);
  }

  try {
    // delete query
    const deleteQuery = 'DELETE FROM your_table WHERE id = 2';
    const deleteResult = await connector.executeQuery('delete', deleteQuery);
    console.log('Delete result:', deleteResult);
  } catch (error) {
    console.error('Error executing delete query:', error);
  }

  // Close the connection
  await connector.close();
}

main();