You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ng...@apache.org on 2023/05/10 13:42:10 UTC
[hive] branch master updated: HIVE-27316: Map certain unmapped SQL datatypes to hive datatypes in connectors (#4300)
This is an automated email from the ASF dual-hosted git repository.
ngangam pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new 5aa3208db76 HIVE-27316: Map certain unmapped SQL datatypes to hive datatypes in connectors (#4300)
5aa3208db76 is described below
commit 5aa3208db76758082e026ec91a384d3e0a783577
Author: Venu Reddy <35...@users.noreply.github.com>
AuthorDate: Wed May 10 19:12:02 2023 +0530
HIVE-27316: Map certain unmapped SQL datatypes to hive datatypes in connectors (#4300)
---
.../dataconnector/jdbc/AbstractJDBCConnectorProvider.java | 3 +++
.../dataconnector/jdbc/PostgreSQLConnectorProvider.java | 13 +++++++++++++
2 files changed, 16 insertions(+)
diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/AbstractJDBCConnectorProvider.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/AbstractJDBCConnectorProvider.java
index aa322266fc3..5a46fc96312 100644
--- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/AbstractJDBCConnectorProvider.java
+++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/AbstractJDBCConnectorProvider.java
@@ -346,6 +346,8 @@ public abstract class AbstractJDBCConnectorProvider extends AbstractDataConnecto
case "longblob":
case "bytea":
case "binary":
+ case "varbinary":
+ case "binary varying":
return ColumnType.BINARY_TYPE_NAME;
case "tinyint":
return ColumnType.TINYINT_TYPE_NAME;
@@ -380,6 +382,7 @@ public abstract class AbstractJDBCConnectorProvider extends AbstractDataConnecto
case "timestampz":
case "timez":
return ColumnType.TIMESTAMPTZ_TYPE_NAME;
+ case "bool":
case "boolean":
return ColumnType.BOOLEAN_TYPE_NAME;
default:
diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/PostgreSQLConnectorProvider.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/PostgreSQLConnectorProvider.java
index 047932e111a..cafb0c0173e 100644
--- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/PostgreSQLConnectorProvider.java
+++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/dataconnector/jdbc/PostgreSQLConnectorProvider.java
@@ -69,11 +69,24 @@ public class PostgreSQLConnectorProvider extends AbstractJDBCConnectorProvider {
switch (dbDataType.toLowerCase())
{
case "bpchar":
+ case "character":
mappedType = ColumnType.CHAR_TYPE_NAME + wrapSize(size);
break;
+ case "int2":
+ mappedType = ColumnType.SMALLINT_TYPE_NAME;
+ break;
+ case "int4":
+ mappedType = ColumnType.INT_TYPE_NAME;
+ break;
case "int8":
mappedType = ColumnType.BIGINT_TYPE_NAME;
break;
+ case "float4":
+ mappedType = ColumnType.FLOAT_TYPE_NAME;
+ break;
+ case "float8":
+ mappedType = ColumnType.DOUBLE_TYPE_NAME;
+ break;
default:
mappedType = ColumnType.VOID_TYPE_NAME;
break;