cypherquery.js

if (typeof window === 'object') {
  var _ = window._;
  var helpers = window.Neo4jMapper.helpers;
} else {
  var _ = require('underscore');
  var helpers = require('./helpers');
}

var CypherQuery = function CypherQuery(query, parameters) {
  this.statements = [];
  if (typeof query === 'string')
    this.query = query;
  else if (typeof query === 'object')
    this.statements = query;
  if (parameters)
    this.parameters = parameters;
  this.cypher = _.extend(CypherQuery.prototype.cypher);
}

CypherQuery.prototype.statementsToString = function(options) {
  var s = '';
  var chopLength = 15;
  var defaultOptions = {
    niceFormat: true
  };
  if (this.statements) {
    if (typeof options !== 'object')
      options = {};
    else
      _.defaults(options, defaultOptions);
    for (var i=0; i < this.statements.length; i++) {
      var queryFragment = this.statements[i];
      if (typeof queryFragment === 'string') {

        s += queryFragment;
        continue;
      }
      var attribute = Object.keys(this.statements[i])[0];
      var forQuery = this.statements[i][attribute];

      attribute = attribute.replace(/([A-Z]{1})\_([A-Z]{1})/g, '$1 $2');
      if (options.niceFormat) {

        attribute = attribute + Array(chopLength - attribute.length).join(' ');
      }
      if (forQuery !== null) {
        if (typeof forQuery === 'string') {

          forQuery = forQuery.trim().replace(new RegExp('^'+attribute+'\\s+', 'i'), '');

          forQuery = forQuery.replace(/\;$/, '');
        } else {
          forQuery = String(forQuery);
        }
        s += '\n'+attribute+' '+forQuery+' ';
      }
    }
    s = s.trim();
  }
  return s + ';';
}

CypherQuery.prototype.query = '';         // the cypher query string
CypherQuery.prototype.parameters = null;
CypherQuery.prototype.statements = null;
CypherQuery.prototype.cypher = {};
CypherQuery.prototype.useParameters = true;

CypherQuery.prototype.hasParameters = function() {
  return ((this.parameters) && (typeof this.parameters === 'object') && (Object.keys(this.parameters).length > 0));
}

CypherQuery.prototype.toCypher = function() {
  var s = '';
  if (this.query)
    s = this.query;
  else if (this.statements.length > 0)
    s = this.statementsToString();
  return s;
}

CypherQuery.prototype.toString = function() {
  var s = this.toCypher();
  if ((s)&&(this.hasParameters())) {

    for (var key in this.parameters) {
      var value = this.parameters[key];

      s = s.replace(new RegExp('(\\s+){'+key+'}([\\s;]+)'), "$1'"+helpers.valueToStringForCypherQuery(value)+"'$2");
    };
  }
  return s;
}

CypherQuery.prototype.addParameters = function(parameters) {
  if (typeof parameters !== 'object')
    throw Error('parameter(s) as argument must be an object, e.g. { key: "value" }')
  if (this.useParameters === null)
    this.useParameters = true;
  if (!this.hasParameters())
    this.parameters = {};
  for (var attr in parameters) {
    this.parameters[attr] = parameters[attr];
  }
  return this;
}

if (typeof window === 'object') {
  window.Neo4jMapper.CypherQuery = CypherQuery;
} else {
  module.exports = exports = CypherQuery;
}