private void processNonRecursiveRow()

in rdb/src/main/java/org/apache/tuscany/das/rdb/graphbuilder/impl/ResultSetRow.java [115:148]


    private void processNonRecursiveRow() throws SQLException {
        // parse primary keys only
        // the rest will be parsed as needed
        int count = indexesForPKs.length;
        for (int j = 0; j < count; j++) {
        	int i = indexesForPKs[j];
        	Object data = getObject(currentResultSet, i);
        	if (data == null) {
        		// primary key is null, check other columns
        		String tablePropertyName = tablePropertyNames[i];
        		// if table data already exists then this has already been done
        		if (!tableMap.containsKey(tablePropertyName)) {
        			TableData table = getRawData(tablePropertyName);
        			processRowForTable(tablePropertyName);
        			// add table data only if not empty
        			if (!table.isTableEmpty()) {
        	            table.addData(columnPropertyNames[i], true, data);
        				allTableData.add(table);
        			}
        		}
        	} else {
        		// add table data
				TableData table = getRawData(tablePropertyNames[i]);
				if (!allTableData.contains(table)) allTableData.add(table);
	            if (this.logger.isDebugEnabled()) {
	                this.logger.debug("Adding column: " + columnPropertyNames[i] + "\tValue: " 
	                        + data + "\tTable: "
	                        + tablePropertyNames[i]);
	            }
	            table.addData(columnPropertyNames[i], true, data);
        	}
		}
        checkResultSetMissesPK();
        }