Add optional support for raw SQL queries

README.md

@@ -57,7 +57,6 @@ expects a single JSON object with properties corresponding to column names.
 * Optionally use authenticated user/password to connect to DB
 * Handle ORDER BY via orderby param
 * Handle PostGIS data
-* Optionally allow raw SQL
 
 ## License 
 

lib/cli.coffee

@@ -19,11 +19,13 @@ optimist.options 'user',
     default : process.env.USER
 optimist.options 'password',
     describe : 'PostgreSQL password'
+optimist.options 'raw',
+    describe : 'Enable raw SQL usage'
 optimist.options 'cors',
     describe : 'Enable CORS support'
 optimist.options 'help',
     describe : 'Show this message'
-argv = optimist.boolean('cors')
+argv = optimist.boolean('raw').boolean('cors')
     .demand(['port', 'dbhost', 'dbport', 'database', 'user'])
     .argv
 

lib/db.coffee

@@ -6,6 +6,12 @@ pg = require 'pg'
 lexer = require './lexer'
 
 module.exports = (log, connectionString, database) ->
+    ###
+    config.sql      - sql to query
+    config.res      - response to send query results to (or eventual error)
+    config.values   - parameter values
+    config.callback - callback to be called on successful query with a single argument containing the query result
+    ###
     query = (config) ->
         connectionStringDb = connectionString + "/" + (config.database || database)
 

lib/resources/database.coffee

@@ -1,4 +1,4 @@
-module.exports = (server) ->
+module.exports = (server, raw) ->
     log = server.log
     db = server.db
     app = server.app
@@ -9,3 +9,13 @@ module.exports = (server) ->
         res.send
             type: 'database'
             children: ['schemas']
+
+    if raw
+        app.post '/db/:databaseName', (req, res) ->
+            console.log 'RAW SQL POST: ' + req.body.sql
+            db.query
+                sql: req.body.sql
+                res: res
+                database: req.params.databaseName
+                callback: (result) ->
+                    res.send result.rows

lib/server.coffee

@@ -24,18 +24,23 @@ start = (argv) ->
         log.info "Enable Cross-origin Resource Sharing" 
         app.options '/*', (req,res,next) ->
             res.header 'Access-Control-Allow-Origin', '*'
-            res.header 'Access-Control-Allow-Headers', 'origin, x-requested-with'
+            res.header 'Access-Control-Allow-Headers', 'origin, x-requested-with, content-type'
             next()
 
         app.get '/*', (req,res,next) ->
             res.header 'Access-Control-Allow-Origin', '*'
-            res.header 'Access-Control-Allow-Headers', 'origin, x-requested-with'
+            res.header 'Access-Control-Allow-Headers', 'origin, x-requested-with, content-type'
+            next()
+
+        app.post '/*', (req,res,next) ->
+            res.header 'Access-Control-Allow-Origin', '*'
+            res.header 'Access-Control-Allow-Headers', 'origin, x-requested-with, content-type'
             next()
 
     log.info "Setting up resources"
     resources.root exports
     resources.db exports
-    resources.database exports
+    resources.database exports, argv.raw
     resources.schemas exports
     resources.schema exports
     resources.tables exports