You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by dp...@apache.org on 2016/06/29 18:44:43 UTC
lucene-solr:branch_6x: SOLR-9246: If the JDBCStream sees an unknown
column type it will now throw a detailed exception
Repository: lucene-solr
Updated Branches:
refs/heads/branch_6x 455e041c6 -> d1a9daec8
SOLR-9246: If the JDBCStream sees an unknown column type it will now throw a detailed exception
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/d1a9daec
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/d1a9daec
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/d1a9daec
Branch: refs/heads/branch_6x
Commit: d1a9daec8787a3f6869bdcff282dee8b3936cf24
Parents: 455e041
Author: Dennis Gove <dp...@gmail.com>
Authored: Wed Jun 29 14:44:25 2016 -0400
Committer: Dennis Gove <dp...@gmail.com>
Committed: Wed Jun 29 14:44:25 2016 -0400
----------------------------------------------------------------------
solr/CHANGES.txt | 2 ++
.../solr/client/solrj/io/stream/JDBCStream.java | 4 ++++
.../solr/client/solrj/io/stream/JDBCStreamTest.java | 16 ++++++++++++++++
3 files changed, 22 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/d1a9daec/solr/CHANGES.txt
----------------------------------------------------------------------
diff --git a/solr/CHANGES.txt b/solr/CHANGES.txt
index 9b54ff8..6ccff2a 100644
--- a/solr/CHANGES.txt
+++ b/solr/CHANGES.txt
@@ -67,6 +67,8 @@ Bug Fixes
* SOLR-8657: Fix SolrRequestInfo error logs if QuerySenderListener is being used (Pascal Chollet,
Tom�s Fern�ndez L�bbe)
+* SOLR-9246: If the JDBCStream sees an unknown column type it will now throw a detailed exception. (Dennis Gove)
+
Optimizations
----------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/d1a9daec/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
index d1a301e..f57beac 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
@@ -225,6 +225,7 @@ public class JDBCStream extends TupleStream implements Expressible {
final int columnNumber = columnIdx + 1; // cause it starts at 1
final String columnName = metadata.getColumnName(columnNumber);
String className = metadata.getColumnClassName(columnNumber);
+ String typeName = metadata.getColumnTypeName(columnNumber);
if(directSupportedTypes.contains(className)){
valueSelectors[columnIdx] = new ResultSetValueSelector() {
@@ -274,6 +275,9 @@ public class JDBCStream extends TupleStream implements Expressible {
}
};
}
+ else{
+ throw new SQLException(String.format(Locale.ROOT, "Unable to determine the valueSelector for column '%s' (col #%d) of java class '%s' and type '%s'", columnName, columnNumber, className, typeName));
+ }
}
return valueSelectors;
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/d1a9daec/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/JDBCStreamTest.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/JDBCStreamTest.java b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/JDBCStreamTest.java
index 0315cfe..980d0e7 100644
--- a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/JDBCStreamTest.java
+++ b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/JDBCStreamTest.java
@@ -84,6 +84,7 @@ public class JDBCStreamTest extends SolrCloudTestCase {
statement.executeUpdate("create table COUNTRIES(CODE varchar(3) not null primary key, COUNTRY_NAME varchar(50), DELETED char(1) default 'N')");
statement.executeUpdate("create table PEOPLE(ID int not null primary key, NAME varchar(50), COUNTRY_CODE char(2), DELETED char(1) default 'N')");
statement.executeUpdate("create table PEOPLE_SPORTS(ID int not null primary key, PERSON_ID int, SPORT_NAME varchar(50), DELETED char(1) default 'N')");
+ statement.executeUpdate("create table UNSUPPORTED_COLUMNS(ID int not null primary key, UNSP binary)");
}
@@ -109,6 +110,7 @@ public class JDBCStreamTest extends SolrCloudTestCase {
statement.executeUpdate("delete from COUNTRIES WHERE 1=1");
statement.executeUpdate("delete from PEOPLE WHERE 1=1");
statement.executeUpdate("delete from PEOPLE_SPORTS WHERE 1=1");
+ statement.executeUpdate("delete from UNSUPPORTED_COLUMNS WHERE 1=1");
}
}
@@ -497,6 +499,20 @@ public class JDBCStreamTest extends SolrCloudTestCase {
}
+ @Test(expected=IOException.class)
+ public void testUnsupportedColumns() throws Exception {
+
+ // No need to load table with any data
+
+ TupleStream stream;
+
+ // Simple 1
+ stream = new JDBCStream("jdbc:hsqldb:mem:.", "select ID,UNSP from UNSUPPORTED_COLUMNS",
+ new FieldComparator("CODE", ComparatorOrder.ASCENDING));
+ getTuples(stream);
+
+ }
+
protected List<Tuple> getTuples(TupleStream tupleStream) throws IOException {
tupleStream.open();
List<Tuple> tuples = new ArrayList<Tuple>();