diff --git a/pydruid/db/sqlalchemy.py b/pydruid/db/sqlalchemy.py index c6d05569..182303de 100644 --- a/pydruid/db/sqlalchemy.py +++ b/pydruid/db/sqlalchemy.py @@ -3,7 +3,6 @@ from sqlalchemy.sql import compiler import pydruid.db -from pydruid.db import exceptions RESERVED_SCHEMAS = ["INFORMATION_SCHEMA"] @@ -63,25 +62,18 @@ def visit_CHAR(self, type_, **kwargs): visit_TEXT = visit_CHAR def visit_DATETIME(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type DATETIME is not supported") + return "LONG" def visit_TIME(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type TIME is not supported") - - def visit_BINARY(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type BINARY is not supported") - - def visit_VARBINARY(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type VARBINARY is not supported") + return "LONG" def visit_BLOB(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type BLOB is not supported") - - def visit_CLOB(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type CBLOB is not supported") + return "COMPLEX" - def visit_NCLOB(self, type_, **kwargs): - raise exceptions.NotSupportedError("Type NCBLOB is not supported") + visit_CLOB = visit_BLOB + visit_NCLOB = visit_BLOB + visit_VARBINARY = visit_BLOB + visit_BINARY = visit_BLOB class DruidDialect(default.DefaultDialect):