generateSelectRelationshipsSQL method

FutureOr<SQL> generateSelectRelationshipsSQL(Transaction transaction, String entityName, String table, String field, List ids, String otherTableName,)

Implementation

FutureOr<SQL> generateSelectRelationshipsSQL(
    Transaction transaction,
    String entityName,
    String table,
    String field,
    List<dynamic> ids,
    String otherTableName) {
  var retTableScheme = getTableScheme(table);

  return retTableScheme.resolveMapped((tableScheme) {
    if (tableScheme == null) {
      var errorMsg = "Can't find `TableScheme` for table: $table";
      _log.severe(errorMsg);
      throw StateError(errorMsg);
    }

    var relationship = tableScheme.getTableRelationshipReference(
        sourceTable: table, sourceField: field, targetTable: otherTableName);

    if (relationship == null) {
      throw StateError(
          "Can't find TableRelationshipReference for tables: $table -> $otherTableName");
    }

    var q = dialect.elementQuote;

    var conditionSQL =
        StringBuffer('$q${relationship.sourceRelationshipField}$q IN (');

    var parameters = <String, dynamic>{};
    for (var i = 0; i < ids.length; ++i) {
      var p = 'p$i';
      var id = ids[i];
      parameters[p] = id;
      if (i > 0) conditionSQL.write(', ');
      conditionSQL.write('@$p');
    }

    conditionSQL.write(') ');

    var conditionSQLStr = conditionSQL.toString();

    var sql = StringBuffer();

    sql.write('SELECT $q');
    sql.write(relationship.sourceRelationshipField);
    sql.write('$q as ${q}source_id$q , $q');
    sql.write(relationship.targetRelationshipField);
    sql.write('$q as ${q}target_id$q FROM $q');
    sql.write(relationship.relationshipTable);
    sql.write('$q WHERE ( ');
    sql.write(conditionSQLStr);
    sql.write(' )');

    var condition = KeyConditionIN(
        [ConditionKeyField(relationship.sourceRelationshipField)], ids);

    return SQL(sql.toString(), ids, {'ids': ids}, parameters,
        condition: condition,
        sqlCondition: conditionSQLStr,
        returnColumnsAliases: {
          relationship.sourceRelationshipField: 'source_id',
          relationship.targetRelationshipField: 'target_id',
        },
        mainTable: relationship.relationshipTable,
        relationship: relationship);
  });
}