style(数据源): 增加数据源连接报错日志

This commit is contained in:
liuboF2c
2026-01-27 17:05:19 +08:00
committed by xuwei-fit2cloud
parent 9d2e6e00f6
commit 1e273c4658

View File

@@ -100,6 +100,7 @@ public class CalciteProvider extends Provider {
schemas.add(resultSet.getString(1));
}
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException(e.getMessage());
}
if (datasourceRequest.getDatasource().getType().equalsIgnoreCase(DatasourceConfiguration.DatasourceType.pg.name())) {
@@ -154,6 +155,7 @@ public class CalciteProvider extends Provider {
}
}
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException(e.getMessage());
}
return tables;
@@ -1625,6 +1627,7 @@ public class CalciteProvider extends Provider {
startSshSession(configuration, null, datasourceDTO.getId());
}
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException(e.getMessage());
}
}
@@ -1676,7 +1679,10 @@ public class CalciteProvider extends Provider {
BasicDataSource basicDataSource = (BasicDataSource) jdbcSchema.getDataSource();
basicDataSource.setMaxWaitMillis(5 * 1000);
return basicDataSource.getConnection();
} catch (DEException e) {
throw e;
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException(Translator.get("i18n_invalid_connection") + e.getMessage());
}
return null;