forked from github/dataease
Merge branch 'v1.8' into dev
This commit is contained in:
commit
b9bbbe1907
@ -99,11 +99,18 @@ public class EsProvider extends DatasourceProvider {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<TableField> getTableFileds(DatasourceRequest datasourceRequest) throws Exception {
|
public List<TableField> getTableFileds(DatasourceRequest datasourceRequest) throws Exception {
|
||||||
QueryProvider qp = ProviderFactory.getQueryProvider(datasourceRequest.getDatasource().getType());
|
datasourceRequest.setQuery("desc " + datasourceRequest.getTable());
|
||||||
datasourceRequest.setQuery(qp.convertTableToSql(datasourceRequest.getTable(), datasourceRequest.getDatasource()));
|
List<TableField> tableFields = new ArrayList<>();
|
||||||
return fetchResultField(datasourceRequest);
|
try {
|
||||||
|
String response = exexQuery(datasourceRequest, datasourceRequest.getQuery(), "?format=json");
|
||||||
|
tableFields = fetchResultField4Table(response);
|
||||||
|
} catch (Exception e) {
|
||||||
|
DataEaseException.throwException(e);
|
||||||
|
}
|
||||||
|
return tableFields;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private List<String[]> fetchResult(String response) throws Exception {
|
private List<String[]> fetchResult(String response) throws Exception {
|
||||||
EsReponse esReponse = new Gson().fromJson(response, EsReponse.class);
|
EsReponse esReponse = new Gson().fromJson(response, EsReponse.class);
|
||||||
return fetchResult(esReponse);
|
return fetchResult(esReponse);
|
||||||
@ -166,6 +173,26 @@ public class EsProvider extends DatasourceProvider {
|
|||||||
return fieldList;
|
return fieldList;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private List<TableField> fetchResultField4Table(String response) throws Exception {
|
||||||
|
List<TableField> fieldList = new ArrayList<>();
|
||||||
|
EsReponse esReponse = new Gson().fromJson(response, EsReponse.class);
|
||||||
|
if (esReponse.getError() != null) {
|
||||||
|
throw new Exception(esReponse.getError().getReason());
|
||||||
|
}
|
||||||
|
|
||||||
|
for (String[] row : esReponse.getRows()) {
|
||||||
|
if(!row[1].equalsIgnoreCase("STRUCT")){
|
||||||
|
TableField field = new TableField();
|
||||||
|
field.setFieldName(row[0]);
|
||||||
|
field.setRemarks(row[0]);
|
||||||
|
field.setFieldType(row[2]);
|
||||||
|
field.setFieldSize(EsQueryProvider.transFieldTypeSize(row[2]));
|
||||||
|
fieldList.add(field);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return fieldList;
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Map<String, List> fetchResultAndField(DatasourceRequest datasourceRequest) throws Exception {
|
public Map<String, List> fetchResultAndField(DatasourceRequest datasourceRequest) throws Exception {
|
||||||
Map<String, List> result = new HashMap<>();
|
Map<String, List> result = new HashMap<>();
|
||||||
|
@ -403,6 +403,9 @@ public class JdbcProvider extends DatasourceProvider {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private Connection getConnectionFromPool(DatasourceRequest datasourceRequest) throws Exception {
|
private Connection getConnectionFromPool(DatasourceRequest datasourceRequest) throws Exception {
|
||||||
|
if(datasourceRequest.getDatasource().getType().equalsIgnoreCase(DatasourceTypes.mongo.name())){
|
||||||
|
return getConnection(datasourceRequest);
|
||||||
|
}
|
||||||
DruidDataSource dataSource = jdbcConnection.get(datasourceRequest.getDatasource().getId());
|
DruidDataSource dataSource = jdbcConnection.get(datasourceRequest.getDatasource().getId());
|
||||||
if (dataSource == null) {
|
if (dataSource == null) {
|
||||||
handleDatasource(datasourceRequest, "add");
|
handleDatasource(datasourceRequest, "add");
|
||||||
|
@ -1629,7 +1629,7 @@ public class DataSetTableService {
|
|||||||
datasetTableField.setDeExtractType(transFieldType(filed.getFieldType()));
|
datasetTableField.setDeExtractType(transFieldType(filed.getFieldType()));
|
||||||
} else {
|
} else {
|
||||||
Integer fieldType = qp.transFieldType(filed.getFieldType());
|
Integer fieldType = qp.transFieldType(filed.getFieldType());
|
||||||
datasetTableField.setDeType(fieldType == 4 ? 2 : fieldType);
|
datasetTableField.setDeType(fieldType == 4 ? 2 : (fieldType == 6 ? 0 : fieldType));
|
||||||
datasetTableField.setDeExtractType(fieldType);
|
datasetTableField.setDeExtractType(fieldType);
|
||||||
}
|
}
|
||||||
datasetTableField.setSize(filed.getFieldSize());
|
datasetTableField.setSize(filed.getFieldSize());
|
||||||
@ -1637,7 +1637,7 @@ public class DataSetTableService {
|
|||||||
datasetTableField.setColumnIndex(i);
|
datasetTableField.setColumnIndex(i);
|
||||||
datasetTableField.setLastSyncTime(syncTime);
|
datasetTableField.setLastSyncTime(syncTime);
|
||||||
datasetTableField.setExtField(0);
|
datasetTableField.setExtField(0);
|
||||||
datasetTableField.setGroupType(datasetTableField.getDeType() < 2 ? "d" : "q");
|
datasetTableField.setGroupType((datasetTableField.getDeType() < 2 || datasetTableField.getDeType() == 6) ? "d" : "q");
|
||||||
}
|
}
|
||||||
dataSetTableFieldsService.save(datasetTableField);
|
dataSetTableFieldsService.save(datasetTableField);
|
||||||
}
|
}
|
||||||
|
@ -72,8 +72,8 @@
|
|||||||
</el-option>
|
</el-option>
|
||||||
</el-select>
|
</el-select>
|
||||||
<span style="margin-left: 8px;">
|
<span style="margin-left: 8px;">
|
||||||
<span v-if="scope.row.deType === 0">
|
<span v-if="scope.row.deType === 0 || scope.row.deType === 6">
|
||||||
<svg-icon v-if="scope.row.deType === 0" icon-class="field_text" class="field-icon-text" />
|
<svg-icon v-if="scope.row.deType === 0 || scope.row.deType === 6" icon-class="field_text" class="field-icon-text" />
|
||||||
<span class="field-class">{{ $t('dataset.text') }}</span>
|
<span class="field-class">{{ $t('dataset.text') }}</span>
|
||||||
</span>
|
</span>
|
||||||
<span v-if="scope.row.deType === 1">
|
<span v-if="scope.row.deType === 1">
|
||||||
@ -95,8 +95,8 @@
|
|||||||
<el-table-column property="deExtractType" :label="$t('dataset.origin_field_type')" width="100">
|
<el-table-column property="deExtractType" :label="$t('dataset.origin_field_type')" width="100">
|
||||||
<template slot-scope="scope">
|
<template slot-scope="scope">
|
||||||
<span v-if="scope.row.extField === 0">
|
<span v-if="scope.row.extField === 0">
|
||||||
<span v-if="scope.row.deExtractType === 0">
|
<span v-if="scope.row.deExtractType === 0 || scope.row.deExtractType === 6">
|
||||||
<svg-icon v-if="scope.row.deExtractType === 0" icon-class="field_text" class="field-icon-text" />
|
<svg-icon v-if="scope.row.deExtractType === 0 || scope.row.deExtractType === 6" icon-class="field_text" class="field-icon-text" />
|
||||||
<span class="field-class">{{ $t('dataset.text') }}</span>
|
<span class="field-class">{{ $t('dataset.text') }}</span>
|
||||||
</span>
|
</span>
|
||||||
<span v-if="scope.row.deExtractType === 1">
|
<span v-if="scope.row.deExtractType === 1">
|
||||||
|
@ -253,7 +253,7 @@
|
|||||||
</el-select>
|
</el-select>
|
||||||
</el-form-item>
|
</el-form-item>
|
||||||
|
|
||||||
<el-collapse v-if="form.configuration.dataSourceType=='jdbc' && form.type !== 'api'">
|
<el-collapse v-if="form.configuration.dataSourceType=='jdbc' && form.type !== 'api' && form.type !== 'mongo'">
|
||||||
<el-collapse-item :title="$t('datasource.priority')" name="1">
|
<el-collapse-item :title="$t('datasource.priority')" name="1">
|
||||||
<el-form-item :label="$t('datasource.initial_pool_size')" prop="configuration.initialPoolSize">
|
<el-form-item :label="$t('datasource.initial_pool_size')" prop="configuration.initialPoolSize">
|
||||||
<el-input v-model="form.configuration.initialPoolSize" autocomplete="off" type="number" min="0"
|
<el-input v-model="form.configuration.initialPoolSize" autocomplete="off" type="number" min="0"
|
||||||
|
Loading…
Reference in New Issue
Block a user