diff --git a/src/main/java/com/loafle/overflow/crawler/result/OFResultSet.java b/src/main/java/com/loafle/overflow/crawler/result/OFResultSet.java index ad66770..4ceadba 100644 --- a/src/main/java/com/loafle/overflow/crawler/result/OFResultSet.java +++ b/src/main/java/com/loafle/overflow/crawler/result/OFResultSet.java @@ -1,6 +1,7 @@ package com.loafle.overflow.crawler.result; import com.loafle.overflow.crawler.config.Item; +import com.loafle.overflow.crawler.config.MappingInfo; import java.util.ArrayList; import java.util.HashMap; @@ -42,6 +43,9 @@ public abstract class OFResultSet { // methods static public OFResultSet newInstance(Item item) { + if (item.getMappingInfo() == null) { + item.setMappingInfo(new MappingInfo()); + } String type = (String) item.getMappingInfo().getParseDirection(); if (type != null && type.equals("row")) { return new OFResultSetRow(item); diff --git a/src/main/java/com/loafle/overflow/crawler/result/OFResultSetRow.java b/src/main/java/com/loafle/overflow/crawler/result/OFResultSetRow.java index 5757aaa..b5371e2 100644 --- a/src/main/java/com/loafle/overflow/crawler/result/OFResultSetRow.java +++ b/src/main/java/com/loafle/overflow/crawler/result/OFResultSetRow.java @@ -77,7 +77,7 @@ public class OFResultSetRow extends OFResultSet{ for (String keyColumn: keyColumns) { String row = data.get(this.meta.get(keyColumn)); for (int i =0 ; i < keys.size() ; ++i) { - if (row.equals(keys.get(i))) { + if (row.equals(keys.get(i).getKey())) { findIndex = i; find = true; break;