pg.js

//var Client = require('pg-native');
//var Q = require("q");
//
//var settings = require('./../settings.js').pg;
//
//// PostGIS Connection String
//var conString = "postgres://" +
//    settings.user + ":" +
//    settings.password + "@" +
//    settings.server + ":" +
//    settings.port + "/" +
//    settings.database;
//
//var pg = new Client();
//
///**
// * Main query function to execute an SQL query; callback form.
// *
// * @type {Function}
// */
//module.exports.queryCallback = function(sql, cb, opts) {
//    pg.connect(conString, function(err, client, done) {
//        if(err) {
//            console.error('error fetching client from pool', err);
//        }
//        client.query(sqlStr, sqlParams, function(queryerr, result) {
//            done();
//            if(queryerr) {
//                console.error('ERROR RUNNING QUERY:', sqlStr, queryerr);
//            }
//            cb((err || queryerr), (result && result.rows ? result.rows : result));
//        });
//    });
//};
//
///**
// * Main query function to execute an SQL query; deferred form.
// *
// * @type {Function}
// */
//module.exports.queryDeferred = function(sqlStr, opts){
//
//    var options = opts || {};
//    var sqlParams = options.sqlParams || null;
//
//    var deferred = Q.defer();
//
//    pg.connect(conString, function(err) {
//
//        if(err) {
//            console.error('error fetching client from pool', err);
//            deferred.reject(err);
//        }
//
//        pg.query(sqlStr.text, sqlStr.values, function(queryerr, result) {
//
//
//            //done();
//            if(queryerr) {
//                console.error('ERROR RUNNING QUERY:', sqlStr, queryerr);
//                deferred.reject(queryerr);
//            } else {
//                deferred.resolve(result ? result : []);
//            }
//        });
//
//    });
//
//    return deferred.promise;
//};
//
//var sanitize = module.exports.sanitize = function (val) {
//    // we want a null to still be null, not a string
//    if (typeof val === 'string' && val !== 'null') {
//        // $nh9$ is using $$ with an arbitrary tag. $$ in pg is a safe way to quote something,
//        // because all escape characters are ignored inside of it.
//        var esc = settings.escapeStr;
//        return "$" + esc + "$" + val + "$" + esc + "$";
//    }
//    return val;
//};
//
//var featureCollectionSQL = module.exports.featureCollectionSQL = function(table, propertyColumns, opts){
//
//    var options = opts || {};
//    var whereClause = options.whereClause || '';
//
//    var sql = "SELECT row_to_json(fc) AS response "
//        + "FROM ( SELECT 'FeatureCollection' As type, array_to_json(array_agg(f)) As features "
//        + "FROM (SELECT 'Feature' As type "
//        + ", row_to_json((SELECT l FROM (select {{columns}}) As l "
//        + ")) As properties "
//        + "FROM " + table + " As t {{where}}) As f )  As fc;"
//
//    return sql.replace('{{columns}}', propertyColumns).replace('{{where}}', whereClause);
//};