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();
}