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 selected
mysqlp.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()