提交 4b5c76e5 authored 作者: taojinlong's avatar taojinlong

Merge branch 'v1.9' into dev

...@@ -13,6 +13,7 @@ import io.dataease.dto.datasource.TableDesc; ...@@ -13,6 +13,7 @@ import io.dataease.dto.datasource.TableDesc;
import io.dataease.dto.datasource.TableField; import io.dataease.dto.datasource.TableField;
import io.dataease.exception.DataEaseException; import io.dataease.exception.DataEaseException;
import io.dataease.i18n.Translator; import io.dataease.i18n.Translator;
import io.dataease.plugins.common.constants.EsSqlLConstants;
import io.dataease.provider.query.es.EsQueryProvider; import io.dataease.provider.query.es.EsQueryProvider;
import org.apache.commons.codec.binary.Base64; import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
...@@ -97,7 +98,7 @@ public class EsProvider extends DatasourceProvider { ...@@ -97,7 +98,7 @@ public class EsProvider extends DatasourceProvider {
@Override @Override
public List<TableField> getTableFileds(DatasourceRequest datasourceRequest) throws Exception { public List<TableField> getTableFileds(DatasourceRequest datasourceRequest) throws Exception {
datasourceRequest.setQuery("desc " + datasourceRequest.getTable()); datasourceRequest.setQuery("desc " + String.format(EsSqlLConstants.KEYWORD_TABLE, datasourceRequest.getTable()));
List<TableField> tableFields = new ArrayList<>(); List<TableField> tableFields = new ArrayList<>();
try { try {
String response = exexQuery(datasourceRequest, datasourceRequest.getQuery(), "?format=json"); String response = exexQuery(datasourceRequest, datasourceRequest.getQuery(), "?format=json");
...@@ -292,6 +293,7 @@ public class EsProvider extends DatasourceProvider { ...@@ -292,6 +293,7 @@ public class EsProvider extends DatasourceProvider {
Request request = new Request(); Request request = new Request();
request.setQuery(sql); request.setQuery(sql);
request.setFetch_size(datasourceRequest.getFetchSize()); request.setFetch_size(datasourceRequest.getFetchSize());
System.out.println(new Gson().toJson(request));
String url = esConfiguration.getUrl().endsWith("/") ? esConfiguration.getUrl() + uri : esConfiguration.getUrl() + "/" + uri; String url = esConfiguration.getUrl().endsWith("/") ? esConfiguration.getUrl() + uri : esConfiguration.getUrl() + "/" + uri;
String response = HttpClientUtil.post(url, new Gson().toJson(request), httpClientConfig); String response = HttpClientUtil.post(url, new Gson().toJson(request), httpClientConfig);
return response; return response;
......
...@@ -252,6 +252,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -252,6 +252,7 @@ public class JdbcProvider extends DatasourceProvider {
} catch (SQLException e) { } catch (SQLException e) {
DataEaseException.throwException(e); DataEaseException.throwException(e);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
DataEaseException.throwException(Translator.get("i18n_datasource_connect_error") + e.getMessage()); DataEaseException.throwException(Translator.get("i18n_datasource_connect_error") + e.getMessage());
} }
return new ArrayList<>(); return new ArrayList<>();
...@@ -285,7 +286,7 @@ public class JdbcProvider extends DatasourceProvider { ...@@ -285,7 +286,7 @@ public class JdbcProvider extends DatasourceProvider {
String l = StringUtils.isNotEmpty(metaData.getColumnLabel(j + 1)) ? metaData.getColumnLabel(j + 1) : f; String l = StringUtils.isNotEmpty(metaData.getColumnLabel(j + 1)) ? metaData.getColumnLabel(j + 1) : f;
String t = metaData.getColumnTypeName(j + 1); String t = metaData.getColumnTypeName(j + 1);
if (datasourceRequest.getDatasource().getType().equalsIgnoreCase(DatasourceTypes.hive.name()) && l.contains(".")) { if (datasourceRequest.getDatasource().getType().equalsIgnoreCase(DatasourceTypes.hive.name()) && l.contains(".")) {
l = l.split(".")[1]; l = l.split("\\.")[1];
} }
TableField field = new TableField(); TableField field = new TableField();
field.setFieldName(l); field.setFieldName(l);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论