bug fixed for hbase support

This commit is contained in:
温少
2012-05-22 07:45:23 +08:00
parent ec2debdfd7
commit 2d60fef9ed
2 changed files with 6 additions and 2 deletions
@@ -184,8 +184,12 @@ public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
}
}
} else {
List<Filter> filters = new ArrayList<Filter>();
filters.add(parentFilter);
filters.add(filter);
FilterList.Operator filterOp = and ? FilterList.Operator.MUST_PASS_ALL : FilterList.Operator.MUST_PASS_ONE;
return new FilterList(filterOp, parentFilter, filter);
return new FilterList(filterOp, filters);
}
}
@@ -15,7 +15,7 @@ public class HBaseDriverTest_getIndex_or extends TestCase {
HDriver driver = new HDriver();
Connection conn = driver.connect("jdbc:druid-hbase:10.20.153.63", new Properties());
PreparedStatement stmt = conn.prepareStatement("SELECT id, name, gender, salary FROM test_user where id = 3 or id = ?");
PreparedStatement stmt = conn.prepareStatement("SELECT id, name, gender, salary FROM test_user where id = 3 or id = ? or name = 'user-4'");
stmt.setInt(1, 6);
ResultSet rs = stmt.executeQuery();