From e396063dd1ce2a20c41f38795af93b8c4ee3f8ce Mon Sep 17 00:00:00 2001 From: junjun Date: Mon, 22 Jul 2024 14:05:00 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E6=95=B0=E6=8D=AE=E6=BA=90?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datasource/provider/Provider.java | 49 ++++++++++++++++++- 1 file changed, 47 insertions(+), 2 deletions(-) diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java b/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java index 352716a04b..f7f01c04f3 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java @@ -33,25 +33,70 @@ public abstract class Provider { public static Logger logger = LoggerFactory.getLogger(Provider.class); + /** + * 获取schema接口 + * + * @param datasourceRequest + * @return + */ public abstract List getSchema(DatasourceRequest datasourceRequest); + /** + * 获取表接口 + * + * @param datasourceRequest + * @return + */ public abstract List getTables(DatasourceRequest datasourceRequest); + /** + * 创建数据库连接 + * + * @param coreDatasource + * @return + * @throws Exception + */ public abstract ConnectionObj getConnection(DatasourceDTO coreDatasource) throws Exception; + /** + * 检测数据源状态是否有效 + * + * @param datasourceRequest + * @return + * @throws Exception + */ public abstract String checkStatus(DatasourceRequest datasourceRequest) throws Exception; + /** + * 获取数据 + * + * @param datasourceRequest + * @return + * @throws DEException + */ public abstract Map fetchResultField(DatasourceRequest datasourceRequest) throws DEException; + /** + * 获取表字段 + * + * @param datasourceRequest + * @return + * @throws DEException + */ public abstract List fetchTableField(DatasourceRequest datasourceRequest) throws DEException; + /** + * 隐藏密码 + * + * @param datasourceDTO + */ + public abstract void hidePW(DatasourceDTO datasourceDTO); + @Getter private static final Map lPorts = new HashMap<>(); @Getter private static final Map sessions = new HashMap<>(); - public abstract void hidePW(DatasourceDTO datasourceDTO); - public Statement getStatement(Connection connection, int queryTimeout) { if (connection == null) { DEException.throwException("Failed to get connection!");