From 2bcb6063195ecdec924ca86614cd709780d3491a Mon Sep 17 00:00:00 2001 From: root <13910913995@163.com> Date: Sun, 22 Jun 2025 11:44:38 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E4=BA=86=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sdk/extensions/extensions-datasource/pom.xml | 4 +- .../datasource/dto/DatasetTableDTO.java | 1 + .../datasource/dto/DatasetTableFieldDTO.java | 4 +- .../datasource/dto/DatasourceDTO.java | 4 -- .../datasource/dto/DatasourceRequest.java | 1 + .../datasource/dto/ExecuteResult.java | 13 ++++++ .../extensions/datasource/dto/TableField.java | 2 + .../datasource/dto/TableFieldWithValue.java | 12 ++++- .../plugin/DataEaseDatasourcePlugin.java | 6 +-- .../datasource/provider/Provider.java | 4 +- .../datasource/vo/Configuration.java | 4 +- .../vo/DatasourceConfiguration.java | 46 +++++++++++-------- 12 files changed, 63 insertions(+), 38 deletions(-) create mode 100644 sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/ExecuteResult.java diff --git a/sdk/extensions/extensions-datasource/pom.xml b/sdk/extensions/extensions-datasource/pom.xml index 7ffde6b..8a4ffa8 100644 --- a/sdk/extensions/extensions-datasource/pom.xml +++ b/sdk/extensions/extensions-datasource/pom.xml @@ -6,7 +6,7 @@ io.gisbi extensions - 1.0.0 + 2.0.0 extensions-datasource @@ -37,7 +37,7 @@ io.gisbi common - 1.0.0 + 2.0.0 compile diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableDTO.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableDTO.java index 21f8dd1..7ad1e00 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableDTO.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableDTO.java @@ -62,4 +62,5 @@ public class DatasetTableDTO implements Serializable { private Long lastUpdateTime = 0L; private String status; + private Boolean isCross; } diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableFieldDTO.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableFieldDTO.java index 5d00e4d..43a1769 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableFieldDTO.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasetTableFieldDTO.java @@ -65,7 +65,7 @@ public class DatasetTableFieldDTO implements Serializable { /** * de字段名用作唯一标识 */ - private String dataeaseName; + private String gisbiName; /** * 维度/指标标识 d:维度，q:指标 @@ -82,7 +82,7 @@ public class DatasetTableFieldDTO implements Serializable { private Integer scale; /** - * dataease字段类型：0-文本，1-时间，2-整型数值，3-浮点数值，4-布尔，5-地理位置，6-二进制, 7-URL + * gisbi字段类型：0-文本，1-时间，2-整型数值，3-浮点数值，4-布尔，5-地理位置，6-二进制, 7-URL */ private Integer deType; diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceDTO.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceDTO.java index 4273959..11f68cd 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceDTO.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceDTO.java @@ -23,10 +23,6 @@ public class DatasourceDTO implements Serializable { * 数据源名称 */ private String name; - /** - * 应用ID - */ - private String appId; /** * 描述 diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceRequest.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceRequest.java index 16fedd3..0a4e46c 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceRequest.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/DatasourceRequest.java @@ -27,6 +27,7 @@ public class DatasourceRequest implements Serializable { private Map dsList; private List tableFieldWithValues; private String token; + private Boolean isCross; public DatasourceRequest() { } diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/ExecuteResult.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/ExecuteResult.java new file mode 100644 index 0000000..01b7347 --- /dev/null +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/ExecuteResult.java @@ -0,0 +1,13 @@ +package io.gisbi.extensions.datasource.dto; + +import lombok.Data; + +import java.util.List; + +@Data +public class ExecuteResult { + + private int count; + + private List generatedKeys; +} diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableField.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableField.java index f3cd571..fb9ed87 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableField.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableField.java @@ -23,9 +23,11 @@ public class TableField implements Serializable { private int extField; private String jsonPath; private boolean primary; + private boolean autoIncrement; List value; private int inCount; private String term = "eq"; + private Integer typeNumber; } diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableFieldWithValue.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableFieldWithValue.java index 57c6361..2882dc7 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableFieldWithValue.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/dto/TableFieldWithValue.java @@ -3,10 +3,12 @@ package io.gisbi.extensions.datasource.dto; import lombok.Getter; import lombok.Setter; import lombok.experimental.Accessors; +import lombok.extern.slf4j.Slf4j; import java.io.Serial; import java.io.Serializable; +@Slf4j @Getter @Setter @Accessors(chain = true) @@ -18,6 +20,8 @@ public class TableFieldWithValue implements Serializable { private String filedName; private String typeName; private Integer type; + private String columnTypeName; + private boolean autoIncrement; private String isDateTime; private String dateFormat; @@ -27,8 +31,14 @@ public class TableFieldWithValue implements Serializable { public static TableFieldWithValue copy(TableFieldWithValue tableFieldWithValue) { return new TableFieldWithValue() .setValue(tableFieldWithValue.getValue()) + .setAutoIncrement(tableFieldWithValue.isAutoIncrement()) .setFiledName(tableFieldWithValue.getFiledName()) .setTypeName(tableFieldWithValue.getTypeName()) - .setType(tableFieldWithValue.getType()); + .setType(tableFieldWithValue.getType()) + .setColumnTypeName(tableFieldWithValue.getColumnTypeName()) + .setIsDateTime(tableFieldWithValue.getIsDateTime()) + .setDateFormat(tableFieldWithValue.getDateFormat()) + .setTerm(tableFieldWithValue.getTerm()) + .setDeExtractType(tableFieldWithValue.getDeExtractType()); } } diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/plugin/DataEaseDatasourcePlugin.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/plugin/DataEaseDatasourcePlugin.java index cb421e1..c84eb38 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/plugin/DataEaseDatasourcePlugin.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/plugin/DataEaseDatasourcePlugin.java @@ -2,14 +2,10 @@ package io.gisbi.extensions.datasource.plugin; import io.gisbi.exception.DEException; import io.gisbi.extensions.datasource.dto.DatasourceRequest; -import io.gisbi.extensions.datasource.factory.ProviderFactory; import io.gisbi.extensions.datasource.provider.Provider; -import io.gisbi.extensions.datasource.vo.XpackPluginsDatasourceVO; import org.apache.commons.lang3.StringUtils; import java.io.File; -import java.io.FileOutputStream; -import java.io.InputStream; import java.net.URI; import java.nio.file.Paths; import java.security.ProtectionDomain; @@ -23,7 +19,7 @@ import java.util.jar.JarFile; * @Author Junjun */ public abstract class DataEaseDatasourcePlugin extends Provider { - private final String DEFAULT_FILE_PATH = "/opt/gisbi1.0/drivers/plugin"; + private final String DEFAULT_FILE_PATH = "/opt/gisbi2.0/drivers/plugin"; @Override diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/provider/Provider.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/provider/Provider.java index d6ae8f7..65e3a0b 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/provider/Provider.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/provider/Provider.java @@ -97,8 +97,8 @@ public abstract class Provider { } - public int executeUpdate(DatasourceRequest datasourceRequest) { - return 0; + public ExecuteResult executeUpdate(DatasourceRequest datasourceRequest, String autoIncrementPkName) { + return new ExecuteResult(); } diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/Configuration.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/Configuration.java index ccf9163..2a08e23 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/Configuration.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/Configuration.java @@ -13,7 +13,7 @@ public class Configuration { private String keywordSuffix = ""; private String aliasPrefix = ""; private String aliasSuffix = ""; - private String jdbc; + protected String jdbc; private String host; private String jdbcUrl; private String urlType; @@ -31,7 +31,7 @@ public class Configuration { private int initialPoolSize = 5; private int minPoolSize = 5; private int maxPoolSize = 20; - private int queryTimeout = 10; + private int queryTimeout = 30; private boolean useSSH = false; private String sshHost; private Integer sshPort; diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/DatasourceConfiguration.java b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/DatasourceConfiguration.java index cdc55ca..3485812 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/DatasourceConfiguration.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/gisbi/extensions/datasource/vo/DatasourceConfiguration.java @@ -11,38 +11,40 @@ public class DatasourceConfiguration extends Configuration { static public enum DatasourceType { - folder("folder", "folder", "folder", null, null), - API("API", "API", "API", "`", "`"), - Excel("Excel", "Excel", "LOCALFILE", "`", "`"), - mysql("mysql", "Mysql", "OLTP", "`", "`"), - impala("impala", "Apache Impala", "OLAP", "`", "`"), - mariadb("mariadb", "Mariadb", "OLTP", "`", "`"), - StarRocks("StarRocks", "StarRocks", "OLAP", "`", "`"), - es("es", "Elasticsearch", "OLAP", "\"", "\""), - doris("doris", "Apache Doris", "OLAP", "`", "`"), - TiDB("TiDB", "TiDB", "OLTP", "`", "`"), - oracle("oracle", "ORACLE", "OLTP", "\"", "\""), - pg("pg", "PostgreSQL", "OLTP", "\"", "\""), - redshift("redshift", "AWS Redshift", "OLTP", "\"", "\""), - db2("db2", "Db2", "OLTP", "", ""), - ck("ck", "Clickhouse", "OLAP", "`", "`"), - h2("h2", "H2", "OLAP", "\"", "\""), - sqlServer("sqlServer", "Sqlserver", "DL", "[", "]"), - mongo("mongo", "MongoDB", "DL", "`", "`"); + folder("folder", "folder", "folder", null, null, 25), + API("API", "API", "API", "`", "`", 15), + Excel("Excel", "Excel", "LOCALFILE", "`", "`", 16), + ExcelRemote("ExcelRemote", "ExcelRemote", "LOCALFILE", "`", "`", 29), + mysql("mysql", "Mysql", "OLTP", "`", "`", 27), + impala("impala", "Apache Impala", "OLAP", "`", "`", 5), + mariadb("mariadb", "Mariadb", "OLTP", "`", "`", 6), + StarRocks("StarRocks", "StarRocks", "OLAP", "`", "`", 7), + es("es", "Elasticsearch", "OLAP", "\"", "\"", 14), + doris("doris", "Apache Doris", "OLAP", "`", "`", 26), + TiDB("TiDB", "TiDB", "OLTP", "`", "`", 3), + oracle("oracle", "ORACLE", "OLTP", "\"", "\"", 1), + pg("pg", "PostgreSQL", "OLTP", "\"", "\"", 9), + redshift("redshift", "AWS Redshift", "OLTP", "\"", "\"", 13), + db2("db2", "Db2", "OLTP", "", "", 12), + ck("ck", "Clickhouse", "OLAP", "`", "`", 11), + h2("h2", "H2", "OLAP", "\"", "\"", 30), + sqlServer("sqlServer", "Sqlserver", "DL", "[", "]", 2), + mongo("mongo", "MongoDB", "DL", "`", "`", 10); private String type; private String name; - + private Integer flag; private String catalog; private String prefix; private String suffix; - DatasourceType(String type, String name, String catalog, String prefix, String suffix) { + DatasourceType(String type, String name, String catalog, String prefix, String suffix, Integer flag) { this.type = type; this.name = name; this.catalog = catalog; this.prefix = prefix; this.suffix = suffix; + this.flag = flag; } public String getType() { @@ -64,5 +66,9 @@ public class DatasourceConfiguration extends Configuration { public String getSuffix() { return suffix; } + + public Integer getFlag() { + return flag; + } } }