diff options
| author | Jacques Nadeau <jacques@apache.org> | 2015-11-01 16:14:21 -0800 |
|---|---|---|
| committer | Jacques Nadeau <jacques@apache.org> | 2015-11-01 18:54:22 -0800 |
| commit | 2f894afc86a899d15974171c597de5ff415df3be (patch) | |
| tree | e1eb31f71d7ca1b9926a338d35ae090cb44dc634 /contrib/storage-jdbc/src | |
| parent | 22e5316317cf5b8caed7a869e40a012f18652254 (diff) | |
DRILL-3956: Add support for MySQL text type
Diffstat (limited to 'contrib/storage-jdbc/src')
| -rwxr-xr-x | contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcRecordReader.java | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcRecordReader.java b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcRecordReader.java index 2fa647f55..436f06576 100755 --- a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcRecordReader.java +++ b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcRecordReader.java @@ -97,6 +97,7 @@ class JdbcRecordReader extends AbstractRecordReader { .put(java.sql.Types.CHAR, MinorType.VARCHAR) .put(java.sql.Types.VARCHAR, MinorType.VARCHAR) .put(java.sql.Types.LONGVARCHAR, MinorType.VARCHAR) + .put(java.sql.Types.CLOB, MinorType.VARCHAR) .put(java.sql.Types.NCHAR, MinorType.VARCHAR) .put(java.sql.Types.NVARCHAR, MinorType.VARCHAR) @@ -104,6 +105,7 @@ class JdbcRecordReader extends AbstractRecordReader { .put(java.sql.Types.VARBINARY, MinorType.VARBINARY) .put(java.sql.Types.LONGVARBINARY, MinorType.VARBINARY) + .put(java.sql.Types.BLOB, MinorType.VARBINARY) .put(java.sql.Types.NUMERIC, MinorType.FLOAT8) .put(java.sql.Types.DECIMAL, MinorType.FLOAT8) |