|
@@ -359,15 +359,21 @@ def get_api(request, snippet):
|
|
|
from notebook.connectors.dataeng import DataEngApi
|
|
from notebook.connectors.dataeng import DataEngApi
|
|
|
return DataEngApi(user=request.user, request=request, cluster_name=cluster_name)
|
|
return DataEngApi(user=request.user, request=request, cluster_name=cluster_name)
|
|
|
elif interface == 'jdbc':
|
|
elif interface == 'jdbc':
|
|
|
- if not interpreter['options'] or interpreter['options'].get('url', '').find('teradata') < 0:
|
|
|
|
|
- from notebook.connectors.jdbc import JdbcApi
|
|
|
|
|
- return JdbcApi(request.user, interpreter=interpreter)
|
|
|
|
|
- else:
|
|
|
|
|
|
|
+ if interpreter['options'] and interpreter['options'].get('url', '').find('teradata') >= 0:
|
|
|
from notebook.connectors.jdbc_teradata import JdbcApiTeradata
|
|
from notebook.connectors.jdbc_teradata import JdbcApiTeradata
|
|
|
return JdbcApiTeradata(request.user, interpreter=interpreter)
|
|
return JdbcApiTeradata(request.user, interpreter=interpreter)
|
|
|
|
|
+ elif interpreter['options'] and interpreter['options'].get('url', '').find('presto') >= 0:
|
|
|
|
|
+ from notebook.connectors.jdbc_presto import JdbcApiPresto
|
|
|
|
|
+ return JdbcApiPresto(request.user, interpreter=interpreter)
|
|
|
|
|
+ else:
|
|
|
|
|
+ from notebook.connectors.jdbc import JdbcApi
|
|
|
|
|
+ return JdbcApi(request.user, interpreter=interpreter)
|
|
|
elif interface == 'teradata':
|
|
elif interface == 'teradata':
|
|
|
from notebook.connectors.jdbc import JdbcApiTeradata
|
|
from notebook.connectors.jdbc import JdbcApiTeradata
|
|
|
return JdbcApiTeradata(request.user, interpreter=interpreter)
|
|
return JdbcApiTeradata(request.user, interpreter=interpreter)
|
|
|
|
|
+ elif interface == 'presto':
|
|
|
|
|
+ from notebook.connectors.jdbc_presto import JdbcApiPresto
|
|
|
|
|
+ return JdbcApiPresto(request.user, interpreter=interpreter)
|
|
|
elif interface == 'sqlalchemy':
|
|
elif interface == 'sqlalchemy':
|
|
|
from notebook.connectors.sqlalchemyapi import SqlAlchemyApi
|
|
from notebook.connectors.sqlalchemyapi import SqlAlchemyApi
|
|
|
return SqlAlchemyApi(request.user, interpreter=interpreter)
|
|
return SqlAlchemyApi(request.user, interpreter=interpreter)
|