mysqlp
A node mysql wrapper with promises for coffeescript
Install
npm install mysqlp
or
npm install jmsegrev/mysqlp
Usage
Configuration
mysqlp = require 'mysqlp' configuration = master: host: 'host_x' database: 'database_x' user: 'user_x' password: 'password_x' slave1: host: 'host_x' database: 'database_x' user: 'user_x' password: 'password_x' slave2: host: 'host_x' database: 'database_x' user: 'user_x' password: 'password_x' namex: host: 'host_x' database: 'database_x' user: 'user_x' password: 'password_x' mysqlp.config(configuration)All the connection configurations will be added to a mysql.poolCluster. The slave* connections will be fetched with the default cluster mysql.poolCluster selector 'RR' (Round-Robin). Any other connection configuration (e.g. master, namex, whateveryouwant ) will be used directly.
Queries
# The slave mysql.cluster will be used to connect# Slave will return the promise for the connection Round-Robin selectedmysqlp.connect('slave') .then (connection) -> # same as mysql connection.query connection.query('select * from table_x where column_x = ?', [1]) .spread (rows, fields) -> console.log rows # you can nest queries @query('select * from table_x where column_x = ?', [1]) .spread (rows, fields) -> console.log rows connection.end()Transactions
mysqlp.connect('master') .then (connection) -> connection.begin () -> @query('SELECT * FROM table_y WHERE column_y > ?', [42]) .spread (rows, fields) -> if rows.length > 0 @query('UPDATE table_z SET column_z = ?', ['anything']) .spread (rows, fields) -> if rows.affectedRows is 1 @commit() else @rollback() else @rollback() .finally -> connection.end()