This is an automated email from the ASF dual-hosted git repository.
fjy pushed a commit to branch 0.12.3
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/0.12.3 by this push:
new 130a601 SQL: Fix selecting BOOLEAN type in JDBC. (#5401) (#6238)
130a601 is described below
commit 130a6011b36e3ba1811369350e7929607e33d5ad
Author: Gian Merlino <[email protected]>
AuthorDate: Sun Aug 26 18:45:38 2018 -0700
SQL: Fix selecting BOOLEAN type in JDBC. (#5401) (#6238)
---
.../main/java/io/druid/sql/calcite/rel/QueryMaker.java | 2 ++
.../io/druid/sql/avatica/DruidAvaticaHandlerTest.java | 17 ++++++++++++++++-
2 files changed, 18 insertions(+), 1 deletion(-)
diff --git a/sql/src/main/java/io/druid/sql/calcite/rel/QueryMaker.java
b/sql/src/main/java/io/druid/sql/calcite/rel/QueryMaker.java
index ed006a8..3c063f8 100644
--- a/sql/src/main/java/io/druid/sql/calcite/rel/QueryMaker.java
+++ b/sql/src/main/java/io/druid/sql/calcite/rel/QueryMaker.java
@@ -385,6 +385,8 @@ public class QueryMaker
return ColumnMetaData.Rep.of(Float.class);
} else if (sqlType == SqlTypeName.DOUBLE || sqlType ==
SqlTypeName.DECIMAL) {
return ColumnMetaData.Rep.of(Double.class);
+ } else if (sqlType == SqlTypeName.BOOLEAN) {
+ return ColumnMetaData.Rep.of(Boolean.class);
} else if (sqlType == SqlTypeName.OTHER) {
return ColumnMetaData.Rep.of(Object.class);
} else {
diff --git
a/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java
b/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java
index a978188..b13035b 100644
--- a/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java
+++ b/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java
@@ -41,12 +41,12 @@ import io.druid.java.util.common.Pair;
import io.druid.java.util.common.StringUtils;
import io.druid.math.expr.ExprMacroTable;
import io.druid.server.DruidNode;
-import io.druid.server.security.NoopEscalator;
import io.druid.server.security.AuthConfig;
import io.druid.server.security.AuthTestUtils;
import io.druid.server.security.AuthenticatorMapper;
import io.druid.server.security.AuthorizerMapper;
import io.druid.server.security.Escalator;
+import io.druid.server.security.NoopEscalator;
import io.druid.sql.calcite.planner.Calcites;
import io.druid.sql.calcite.planner.DruidOperatorTable;
import io.druid.sql.calcite.planner.PlannerConfig;
@@ -288,6 +288,21 @@ public class DruidAvaticaHandlerTest extends
CalciteTestBase
}
@Test
+ public void testSelectBoolean() throws Exception
+ {
+ final ResultSet resultSet = client.createStatement().executeQuery(
+ "SELECT dim2, dim2 IS NULL AS isnull FROM druid.foo LIMIT 1"
+ );
+
+ Assert.assertEquals(
+ ImmutableList.of(
+ ImmutableMap.of("dim2", "a", "isnull", false)
+ ),
+ getRows(resultSet)
+ );
+ }
+
+ @Test
public void testExplainSelectCount() throws Exception
{
final ResultSet resultSet = client.createStatement().executeQuery(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
