image:https://travis-ci.org/larvit/larvitdb-pg.svg?branch=master[] image:https://coveralls.io/repos/github/larvit/larvitdb-pg/badge.svg?branch=master[]

= Database wrapper for pg (PostgreSQL)

Database wrapper for the pg npm package. Use this to add:

• Logging
• Compatible API to larvitdbmigration for database migrations
• Great glory

== Installation

npm i larvitdb-pg

== Usage

=== Initialization

[source,javascript]

import { Db } from 'larvitdb-pg';

// All parameters are optional

const db = new Db({ log: log, // Logging object. Will default to a simple console logger if not provided host: 'database.server.com', // Hostname of the server to connect to, can also be a socket, like this: '/cloudsql/myproject:zone:mydb' port: 3211, // Port, ignored if host is a socket user: 'dbuser', // Database account username password: 'secretpassword', // Database account password database: 'mydb', // Database name within the database server });

// OR

const db = new Db({ log: log, connectionString: 'postgresql://dbuser:[email protected]:3211/mydb', });

=== Querying

==== Simple query

A direct query to any connection in the pool

[source,javascript]

const dbRes = await db.query('SELECT 1 + 1 AS solution'); console.log('solution is: ' + dbRes.rows[0].solution); // 2 console.log('All fields: ' + dbRes.fields); // ['solution']

==== Simple query to specific connection

For example if you want to lock tables and run multiple queries on the samme connection.

[source,javascript]

const dbCon = await db.getConnection(); const sql = 'SELECT * FROM users WHERE username LIKE ' + dbCon.escape(dataToBeEscaped); const dbRes = await dbCon.query(sql); dbCon.release(); // Always release your connection when the query is done

==== Escape data

Either you use a database connection as in the example above, or you do like this:

[source,javascript]

const firstName = 'Bosse'; const lastName = 'Nilsson'; const dbRes = await db.query('SELECT * FROM users WHERE firstname = $1 AND lastname = $2', [firstName, lastName]);

=== Check if database connection is ready

To see when the database connection is ready to recieve commands. Will automatically connect if that is not done already.

[source,javascript]

await db.ready(); console.log('ready');

However, a query can be ran before ready(), it will wait until the database connection is ready.

== Custom functions

Remove all tables from current database

This function will clean the current database from all tables, in the public schema, by removing and then recreating it.

[source,javascript]

await db.resetSchema('public');

== Version history

=== v1.0.0

• Changed behaviour of getConnection and added getPool
• Added logging for individual connection queries

=== v0.5.1

• Added option to not log errors on queries

=== v0.5

• Added resetSchema() method, that effectively removes all tables (and of course their data)

=== v0.4

• Added null as dbfield accepted type
• Added more logging
• All dependencies up to date

=== v0.2

• Added support for getting a single connection from a pool

=== v0.1

• Initial release