progres-transaction v0.0.0

Progres

progres is a Node.js module to wrap node-postgres in a nice, promise based interface.

The add-on modules progres-transaction and progres-convenience provides some non-essential functionality.

Basic example

var progres = require('progres');

progres.connect(connectionString, function (client) {

	return client.query('SELECT NOW() AS time').then(function (rows) {
	
		console.log('Time is ' + rows[0].time);
	});

}).done();

API

progres.connect(connectionString, job)

• connectionString - The postgres connection string.
• job - A callback where you do the actual work. It' single argument is a ProgresClient instance, and it must return a promise. It may not use the ProgresClient instance outside the chain of the returned promise, since the database connection is released automatically when the job's returned promise resolves.

Return value: The promise returned by your job callback.

ProgresClient

You are not supposed to create instances of ProgresClient yourself. It is passed to you in the argument to your job callback in progres.connect. Assuming it is named client:

client.query(SQL, parameters)

This is a promisified proxy to the client.query(SQL, parameters, callback) method of node-postgres.

• SQL - The query to execute.
• parameters - Optional parameters for prepared statements.

Return value: A promise, resolved with the resulting rows from the SQL statement.

progres-transaction

The progres-transaction module adds automatic transaction handling.

var progres = require('progres-transaction');

progres.transaction(connectionString, function (client) {

	// Queries executed here are automatically wrapped in a transaction.
	
}).done();

progres.transaction(connectionString, job)

This method works just like progres.connect(connectionString, job), but is wrapped in a transaction. If the promise returned by job resolves, the transaction is committed. If it is rejected, the transaction is rolled back.

progres-convenience

The progres-convenience module adds a few methods to ProgresClient for common tasks, using node-sql for SQL generation.

var progres = require('progres-convenience');
var sql = require('sql');

var usersTable = sql.define({
	name: 'users',
	columns: ['id', 'name', 'email']
});

var user = {
	name: 'geon',
	email: 'victor@topmost.se'
};

progres.connect(connectionString, function (client) {

	return client.insert(usersTable, user);

}).done();

client.queryGenerated(queryObject)

This works just like client.query(SQL), but takes a node-sql query object in place of the SQL.

• queryObject - The node-sql query object to execute.

Return value: A promise, resolved with the resulting rows from the SQL statement.

client.insert(tableDefinition, objectOrObjects)

Inserts the objectOrObjects in the table specified by tableDefinition.

• tableDefinition - A node-sql table definition.
• objectOrObjects - An object, or an array of objects to insert into the table defined by tableDefinition.

Return value: A promise, resolved with the inserted row or rows.

client.select(tableDefinition, conditions)

Selects all rows in the table defined by tableDefinition, matching the conditions.

• tableDefinition - A node-sql table definition.
• conditions - Optional. A node-sql condition object.

Return value: A promise, resolved with the matching rows.

client.selectOne(tableDefinition, conditions)

Same as client.select(tableDefinition, [conditions]), but only the first row is returned. Useful if you know there is at most one matching row.

• tableDefinition - A node-sql table definition.
• conditions - Optional. A node-sql condition object.

Return value: A promise, resolved with the first matching row.

client.update(tableDefinition, conditions, object)

Updates all rows matched by the conditions with the values in object.

• tableDefinition - A node-sql table definition.
• conditions - A node-sql condition object.
• object - A hash of column names and the values to update them with.

Return value: A promise, resolved with the updated rows.

client.delete(tableDefinition, conditions)

Deletes the rows meeting the conditions from the table specified by tableDefinition.

• tableDefinition - A node-sql table definition.
• conditions - A node-sql condition object.

Return value: A promise.

Combining Transactions And Convenience

They are designed to work well together. Just require both progres-transaction and progres-convenience, and you are set. Internally, they both monkey-patch progres to extend it, so they all return the same module object.

All variations below are equivalent:

var progres = require('progres-transaction');
require('progres-convenience');

require('progres-transaction');
var progres = require('progres-convenience');

var progres = require('progres');
require('progres-transaction');
require('progres-convenience');