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:28:07 UTC
lucene-solr:master: SOLR-9246: If the JDBCStream sees an unknown
column type it will now throw a detailed exception
Repository: lucene-solr
Updated Branches:
refs/heads/master 7a8be1827 -> 1ae0d8d6e
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/1ae0d8d6
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/1ae0d8d6
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/1ae0d8d6
Branch: refs/heads/master
Commit: 1ae0d8d6e1394a941b65c940cb449662d7cab5d2
Parents: 7a8be18
Author: Dennis Gove <dp...@gmail.com>
Authored: Wed Jun 29 14:27:56 2016 -0400
Committer: Dennis Gove <dp...@gmail.com>
Committed: Wed Jun 29 14:27:56 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/1ae0d8d6/solr/CHANGES.txt
----------------------------------------------------------------------
diff --git a/solr/CHANGES.txt b/solr/CHANGES.txt
index e7b8dd1..7fdba2c 100644
--- a/solr/CHANGES.txt
+++ b/solr/CHANGES.txt
@@ -96,6 +96,8 @@ Bug Fixes
* SOLR-8777: Duplicate Solr process can cripple a running process. (Jessica Cheng Mallet, Scott Blum, shalin)
+* 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/1ae0d8d6/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/1ae0d8d6/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>();