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', 'example@example.com')";
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 = 'example@gmail.com' 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();