juma-r2rml/r2rml_generator.js

'use strict';

var R2RML = new Blockly.Generator('R2RML');
/**
 * List of illegal variable names.
 * This is not intended to be a security feature.  Blockly is 100% client-side,
 * so bypassing this list is trivial.  This is intended to prevent users from
 * accidentally clobbering a built-in object or function.
 * @private
 */
R2RML.addReservedWords('');
// R2RML.EXAMPLE = "###\n";

/**
 * Initialise the database of variable names.
 * @param {!Blockly.Workspace} workspace Workspace to generate code from.
 */
R2RML.init = function(workspace) {
};

/**
 * Prepend the generated code with the variable definitions.
 * @param {string} code Generated code.
 * @return {string} Completed code.
 */
R2RML.finish = function(code) {
  return code;
};

/**
 * Naked values are top-level blocks with outputs that aren't plugged into
 * anything.  A trailing semicolon is needed to make this legal.
 * @param {string} line Line of generated code.
 * @return {string} Legal line of code.
 */
R2RML.scrubNakedValue = function(line) {
  return line + ';\n';
};

/**
 * Encode a string as a properly escaped R2RML string, complete with
 * quotes.
 * @param {string} string Text to encode.
 * @return {string} R2RML string.
 * @private
 */
R2RML.quote_ = function(string) {
  // TODO: This is a quick hack.  Replace with goog.string.quote
  string = string.replace(/\\/g, '\\\\')
                 .replace(/\n/g, '\\\n')
                 .replace(/'/g, '\\\'');
  return '\'' + string + '\'';
};

/**
 * Common tasks for generating R2RML from blocks.
 * Handles comments for the specified block and any connected value blocks.
 * Calls any statements following this block.
 * @param {!Blockly.Block} block The current block.
 * @param {string} code The R2RML code created for this block.
 * @return {string} R2RML code with comments and subsequent blocks added.
 * @private
 */
R2RML.scrub_ = function(block, code) {
  var commentCode = '';
  // Only collect comments for blocks that aren't inline.
  if (!block.outputConnection || !block.outputConnection.targetConnection) {
    // Collect comment for this block.
    var comment = block.getCommentText();
    if (comment) {
      commentCode += R2RML.prefixLines(comment, '// ') + '\n';
    }
    // Collect comments for all value arguments.
    // Don't collect comments for nested statements.
    for (var x = 0; x < block.inputList.length; x++) {
      if (block.inputList[x].type == Blockly.INPUT_VALUE) {
        var childBlock = block.inputList[x].connection.targetBlock();
        if (childBlock) {
          var childComment = R2RML.allNestedComments(childBlock);
          if (childComment) {
            commentCode += R2RML.prefixLines(childComment, '// ');
          }
        }
      }
    }
  }
  var nextBlock = block.nextConnection && block.nextConnection.targetBlock();
  var nextCode = R2RML.blockToCode(nextBlock);
  return commentCode + code + nextCode;
};

function isDisconnected(block) {
  return block.getParent() == undefined;
}

R2RML.mapping = function(block) {
  if (!block) {
    return '';
  }
  var mapping = '# Mapping created using R2RML editor. \n  @prefix rr: <http://www.w3.org/ns/r2rml#> . \n'; 
  mapping +=  R2RML.statementToCode(block, 'mapping');
  mapping +=  "\n" + R2RML.statementToCode(block, 'triplesmap');
  return mapping;
};

R2RML.prefix = function(block) {
  if (isDisconnected(block)) {
    return '';
  }
  
  var prefix = block.getFieldValue('PREFIX');
  var uri = block.getFieldValue('URI');
  return "@prefix "+ prefix +": <" + uri + "> .\n";
};

R2RML.base = function(block) {
  if (isDisconnected(block)) {
    return '';
  }
  
  var uri = block.getFieldValue('URI');
  return "@base <" + uri + "> .\n";
};

R2RML.predefinedprefix = function(block) {
  if (isDisconnected(block)) {
    return '';
  }
  
  var prefix = block.getFieldValue('PREFIX');
  return "@prefix "+ prefix +" .\n";
};

R2RML.triplemap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  // countTripleMap++;
  var triplemap = block.getFieldValue('TRIPLEMAPNAME'); //"TripleMap" + countTripleMap;
  return "<#" + triplemap + ">\n" + "rr:logicalTable [ " + R2RML.statementToCode(block, 'logicaltable') + "];"  
              + "\n " + R2RML.statementToCode(block, 'subjectmap')
              + "\n " + R2RML.statementToCode(block, 'predicateobjectmap')  + " . \n\n"; 
};

R2RML.tablesqlquery = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  var isTable = block.getFieldValue('TABLESQLQUERY') == 'table';
  var separator = (isTable ? '\"' : '\"\"\"');
  var table = (isTable ? 'rr:tableName ' : 'rr:sqlQuery ');
  return "\n" + table + separator + block.sql + separator + ";\n";
};

R2RML.subjectmap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:subjectMap [ \n  " + termmap(block) + R2RML.statementToCode(block, 'termmap') + "]; \n";
};

R2RML.class = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:class " + block.getFieldValue('CLASS') + ";\n";
};

R2RML.predicateobjectmap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:predicateObjectMap [ \n" + R2RML.statementToCode(block, 'ppredicateobjectmap') + 
                                  "\n " + R2RML.statementToCode(block, 'opredicateobjectmap') +
                                  "\n " + R2RML.statementToCode(block, 'graphmap') + "]; \n";
};

R2RML.objectmap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:objectMap [ \n  " + termmap(block) +  R2RML.statementToCode(block, 'termmap')  + "]; \n";
};

R2RML.predicatemap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:predicateMap [ \n  " + termmap(block) + R2RML.statementToCode(block, 'termmap')  + "]; \n";
};

R2RML.object = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:object " + block.getFieldValue('OBJECT') + ";\n";
};

R2RML.predicate = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:predicate " + block.getFieldValue('PREDICATE') + ";\n";
};

R2RML.inverseexpression = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:inverseExpression \"" + block.getFieldValue('INVERSEEXPRESSION') + "\";\n";
};

R2RML.datatype = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:datatype " + block.getFieldValue('DATATYPE') + ";\n";
};

R2RML.objectdatatype = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:datatype " + block.getFieldValue('DATATYPE') + ";\n";
};


R2RML.language = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:language \"" + block.getFieldValue('LANGUAGE') + "\";\n";
};

R2RML.objectlanguage = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:language \"" + block.getFieldValue('LANGUAGE') + "\";\n";
};

R2RML.joincondition = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:joinCondition [ \n   rr:child \"" + block.getFieldValue('CHILD') + "\";\n   rr:parent \"" + block.getFieldValue('PARENT') + "\";\n];\n";
};

R2RML.parenttriplesmap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  var triplesmap = block.getFieldValue('PARENTTRIPLEMAP');
  return "rr:objectMap [\n  rr:parentTriplesMap <#" + triplesmap + ">;\n" + R2RML.statementToCode(block, 'joincondition') + "];"; 
};

function termtype(block) {
  if (isDisconnected(block)) {
    return '';
  }

  var code = "rr:termType ";
  var termtype = block.getFieldValue('TERMTYPE');
  if(termtype == 'termtypeiri'){
    code += 'rr:IRI; \n';
  } else if(termtype == 'termtypeblanknode'){
    code += 'rr:BlankNode; \n';
  } else {
    code += 'rr:Literal; \n';
    if(block.type == 'objecttermtype'){
      code += R2RML.statementToCode(block, 'termtypevalue');
    }
  }
  return code;
}

R2RML.subjectgraphtermap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:graphMap [\n\t" + termmap(block) + "];\n";
};

R2RML.predicategraphtermap = function(block) {
  if (isDisconnected(block)) {
    return '';
  }

  return "rr:graphMap [\n\t" + termmap(block) + "];\n";
};

function termmap(block) {
  if (isDisconnected(block)) {
    return '';
  }

  var code = "";
  var termmap = block.getFieldValue('TERMMAP');
  if(termmap == 'CONSTANT'){
    code += 'rr:constant';
    code += ' ' + block.getFieldValue('TERMMAPVALUE') + ";\n";
  } else if(termmap == 'TEMPLATE'){
    code += 'rr:template';
    code += " \"" + block.getFieldValue('TERMMAPVALUE') + "\";\n";
  } else if (termmap == 'COLUMN'){
    code += 'rr:column';
    code += " \"" + block.getFieldValue('TERMMAPVALUE') + "\";\n";
  } 

  if(block.type == 'predicatemap'){
    code += '  rr:termType rr:IRI;\n';
  }

  return code;
}

R2RML.subjecttermtype = function(block) {
  return termtype(block);
};

R2RML.subjecttermmap = function(block) {
  return termmap(block);
};

R2RML.predicatetermtype = function(block) {
  return termtype(block);
};

R2RML.predicatetermmap = function(block) {
  return termmap(block);
};

R2RML.objecttermtype = function(block) {
  return termtype(block);
};

R2RML.objecttermmap = function(block) {
  return termmap(block);
};