From 17ec90a0acbaa077dffa4bc55b08a5d337038231 Mon Sep 17 00:00:00 2001 From: jianneng-fit2cloud Date: Wed, 10 Dec 2025 12:04:04 +0800 Subject: [PATCH] =?UTF-8?q?feat(X-Pack):=20=E6=95=B0=E6=8D=AE=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E6=94=AF=E6=8C=81=E7=9B=AE=E6=A0=87=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=BA=90=E6=8F=92=E4=BB=B6=EF=BC=8C=E4=BB=A5=E5=8F=8A=E4=BC=98?= =?UTF-8?q?=E5=8C=96=E6=BA=90=E6=95=B0=E6=8D=AE=E6=BA=90=E9=83=A8=E5=88=86?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/api/sync/syncDatasource.ts | 9 - core/core-frontend/src/api/sync/syncTask.ts | 6 + de-xpack | 2 +- .../sync/datatype/StandardDataType.java | 202 ++++++++++++++---- .../sync/provider/SinkProvider.java | 18 +- .../sync/provider/SourceProvider.java | 10 + .../sync/provider/SyncProvider.java | 78 ++++++- 7 files changed, 258 insertions(+), 67 deletions(-) diff --git a/core/core-frontend/src/api/sync/syncDatasource.ts b/core/core-frontend/src/api/sync/syncDatasource.ts index 9dedb6fcef..19334606fd 100644 --- a/core/core-frontend/src/api/sync/syncDatasource.ts +++ b/core/core-frontend/src/api/sync/syncDatasource.ts @@ -53,12 +53,3 @@ export const validateByIdApi = (id: string) => { export const loadSyncPlugin = () => { return request.get({ url: '/xpackComponent/syncPlugins' }) } - -export const loadPluginApi = (key: string) => { - return request.get({ url: `/xpackComponent/contentPlugin/${key}` }) -} - -export const loadPluginStaticInfo = (moduleName: string) => { - const url = `/xpackComponent/pluginStaticInfo/${moduleName}` - return request.get({ url }) -} diff --git a/core/core-frontend/src/api/sync/syncTask.ts b/core/core-frontend/src/api/sync/syncTask.ts index 1c2a71f723..494a6ef09b 100644 --- a/core/core-frontend/src/api/sync/syncTask.ts +++ b/core/core-frontend/src/api/sync/syncTask.ts @@ -42,6 +42,10 @@ export interface ITableField { } export interface ITargetProperty { + /** + * 容错率 + */ + faultToleranceRate: number /** * 启用分区on */ @@ -96,6 +100,8 @@ export interface ITargetProperty { * 分区字段 */ partitionColumn: string + + [key: string]: any } export interface ITarget { diff --git a/de-xpack b/de-xpack index d924fd12f7..8e19dd0d8e 160000 --- a/de-xpack +++ b/de-xpack @@ -1 +1 @@ -Subproject commit d924fd12f781000c7776012da79afb6b66c7f793 +Subproject commit 8e19dd0d8e291158e75d0876dfc2f751ba964f90 diff --git a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/datatype/StandardDataType.java b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/datatype/StandardDataType.java index 9fc1eb065d..7291683ef2 100644 --- a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/datatype/StandardDataType.java +++ b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/datatype/StandardDataType.java @@ -1,6 +1,6 @@ package io.dataease.extensions.sync.datatype; -import org.apache.commons.lang3.StringUtils; +import lombok.Getter; import java.util.Arrays; @@ -12,50 +12,170 @@ import java.util.Arrays; **/ public enum StandardDataType { // 数值类型 - TINYINT, SMALLINT, INTEGER, BIGINT, MEDIUMINT, INT, - TINYINT_UNSIGNED, SMALLINT_UNSIGNED, INTEGER_UNSIGNED, - BIGINT_UNSIGNED, MEDIUMINT_UNSIGNED, INT_UNSIGNED, - FLOAT, DOUBLE, DECIMAL, NUMERIC, REAL, DOUBLE_PRECISION, - DECIMAL_UNSIGNED, NUMERIC_UNSIGNED, DECFLOAT, NUMBER, - BINARY_FLOAT, BINARY_DOUBLE, BYTE, SHORT, LONG_INT, - UNSIGNED_LONG, HALF_FLOAT, SCALED_FLOAT, - INT_IDENTITY, BIGINT_IDENTITY, SMALLINT_IDENTITY, TINYINT_IDENTITY, DECIMAL_IDENTITY, NUMERIC_IDENTITY, - // 字符类型 - CHAR, VARCHAR, STRING, TEXT, CLOB, TINYTEXT, MEDIUMTEXT, - LONGTEXT, TINYSTRING, MEDIUMSTRING, LONGSTRING, CHARACTER, - VARCHAR2, NCHAR, LONG, NCLOB, NVARCHAR2, NVARCHAR, NTEXT, - // 二进制类型 - BINARY, VARBINARY, BLOB, BYTEA, BIT, TINYBINARY, LONGBINARY, - TINYBLOB, MEDIUMBLOB, LONGBLOB, LONGVARCHAR, RAW, LONG_RAW, - // 日期时间类型 - DATE, TIME, DATETIME, TIMESTAMP, TIMESTAMPTZ, YEAR, DATETIME2, - SMALLDATETIME, DATETIMEOFFSET, - // 布尔类型 - BOOLEAN, - // 枚举类型 - ENUM, - // JSON/XML - JSON, JSONB, XML, - // 地理空间类型 - GEOMETRY, POINT, LINESTRING, POLYGON, GEO_POINT, GEO_SHAPE, - // 网络地址类型 - INET, CIDR, MACADDR, IP, - // UUID - UUID, - // 金额 - MONEY, SMALLMONEY, - // 其他 - INTERVAL, SET, ARRAY, OBJECT, ROWID, UROWID, KEYWORD, NESTED, - // 未知类型 - UNKNOWN; + TINYINT("TINYINT", "8位整数", "8位有符号整数，范围-128~127", Category.NUMBER), + SMALLINT("SMALLINT", "16位整数", "16位有符号整数", Category.NUMBER), + INTEGER("INTEGER", "32位整数", "32位有符号整数", Category.NUMBER), + BIGINT("BIGINT", "64位整数", "64位有符号整数", Category.NUMBER), + MEDIUMINT("MEDIUMINT", "24位整数", "24位有符号整数，MySQL特有", Category.NUMBER), + INT("INT", "32位整数", "32位有符号整数", Category.NUMBER), + TINYINT_UNSIGNED("TINYINT_UNSIGNED", "无符号8位整数", "无符号8位整数", Category.NUMBER), + SMALLINT_UNSIGNED("SMALLINT_UNSIGNED", "无符号16位整数", "无符号16位整数", Category.NUMBER), + INTEGER_UNSIGNED("INTEGER_UNSIGNED", "无符号32位整数", "无符号32位整数", Category.NUMBER), + BIGINT_UNSIGNED("BIGINT_UNSIGNED", "无符号64位整数", "无符号64位整数", Category.NUMBER), + MEDIUMINT_UNSIGNED("MEDIUMINT_UNSIGNED", "无符号24位整数", "无符号24位整数", Category.NUMBER), + INT_UNSIGNED("INT_UNSIGNED", "无符号32位整数", "无符号32位整数", Category.NUMBER), + FLOAT("FLOAT", "单精度浮点数", "单精度浮点数", Category.NUMBER), + DOUBLE("DOUBLE", "双精度浮点数", "双精度浮点数", Category.NUMBER), + DECIMAL("DECIMAL", "高精度定点数", "高精度定点数，常用于货币", Category.NUMBER), + NUMERIC("NUMERIC", "高精度定点数", "高精度定点数", Category.NUMBER), + REAL("REAL", "近似浮点数", "近似浮点数", Category.NUMBER), + DOUBLE_PRECISION("DOUBLE_PRECISION", "双精度浮点数", "双精度浮点数", Category.NUMBER), + DECIMAL_UNSIGNED("DECIMAL_UNSIGNED", "无符号高精度定点数", "无符号高精度定点数", Category.NUMBER), + NUMERIC_UNSIGNED("NUMERIC_UNSIGNED", "无符号高精度定点数", "无符号高精度定点数", Category.NUMBER), + DECFLOAT("DECFLOAT", "十进制浮点数", "十进制浮点数", Category.NUMBER), + NUMBER("NUMBER", "通用数字类型", "通用数字类型（如Oracle）", Category.NUMBER), + BINARY_FLOAT("BINARY_FLOAT", "二进制浮点数", "二进制浮点数（Oracle）", Category.NUMBER), + BINARY_DOUBLE("BINARY_DOUBLE", "二进制双精度浮点数", "二进制双精度浮点数（Oracle）", Category.NUMBER), + BYTE("BYTE", "字节", "单字节整数", Category.NUMBER), + SHORT("SHORT", "短整型", "短整型", Category.NUMBER), + LONG_INT("LONG_INT", "长整型", "长整型", Category.NUMBER), + UNSIGNED_LONG("UNSIGNED_LONG", "无符号长整型", "无符号长整型", Category.NUMBER), + HALF_FLOAT("HALF_FLOAT", "半精度浮点数", "半精度浮点数", Category.NUMBER), + SCALED_FLOAT("SCALED_FLOAT", "可缩放浮点数", "可缩放浮点数（如Elasticsearch）", Category.NUMBER), + INT_IDENTITY("INT_IDENTITY", "自增32位整数", "自增主键类型", Category.NUMBER), + BIGINT_IDENTITY("BIGINT_IDENTITY", "自增64位整数", "自增主键类型", Category.NUMBER), + SMALLINT_IDENTITY("SMALLINT_IDENTITY", "自增16位整数", "自增主键类型", Category.NUMBER), + TINYINT_IDENTITY("TINYINT_IDENTITY", "自增8位整数", "自增主键类型", Category.NUMBER), + DECIMAL_IDENTITY("DECIMAL_IDENTITY", "自增高精度定点数", "自增主键类型", Category.NUMBER), + NUMERIC_IDENTITY("NUMERIC_IDENTITY", "自增高精度定点数", "自增主键类型", Category.NUMBER), + INTEGER_IDENTITY("INTEGER_IDENTITY", "自增32位整数", "自增主键类型", Category.NUMBER), + + // 字符类型 + CHAR("CHAR", "定长字符串", "定长字符串", Category.STRING), + VARCHAR("VARCHAR", "变长字符串", "变长字符串", Category.STRING), + STRING("STRING", "字符串", "通用字符串类型", Category.STRING), + TEXT("TEXT", "大文本", "大容量文本数据", Category.STRING), + CLOB("CLOB", "字符大对象", "字符大对象", Category.STRING), + TINYTEXT("TINYTEXT", "小文本", "小容量文本数据", Category.STRING), + MEDIUMTEXT("MEDIUMTEXT", "中等文本", "中等容量文本数据", Category.STRING), + LONGTEXT("LONGTEXT", "超大文本", "超大容量文本数据", Category.STRING), + TINYSTRING("TINYSTRING", "小字符串", "小容量字符串", Category.STRING), + MEDIUMSTRING("MEDIUMSTRING", "中等字符串", "中等容量字符串", Category.STRING), + LONGSTRING("LONGSTRING", "超大字符串", "超大容量字符串", Category.STRING), + CHARACTER("CHARACTER", "字符", "单字符或定长字符串", Category.STRING), + VARCHAR2("VARCHAR2", "变长字符串", "Oracle变长字符串", Category.STRING), + NCHAR("NCHAR", "定长Unicode字符串", "定长Unicode字符串", Category.STRING), + LONG("LONG", "长字符串", "Oracle长字符串", Category.STRING), + NCLOB("NCLOB", "Unicode字符大对象", "Unicode字符大对象", Category.STRING), + NVARCHAR2("NVARCHAR2", "变长Unicode字符串", "Oracle变长Unicode字符串", Category.STRING), + NVARCHAR("NVARCHAR", "变长Unicode字符串", "变长Unicode字符串", Category.STRING), + NTEXT("NTEXT", "Unicode大文本", "Unicode大文本", Category.STRING), + + // 二进制类型 + BINARY("BINARY", "定长二进制", "定长二进制数据", Category.BINARY), + VARBINARY("VARBINARY", "变长二进制", "变长二进制数据", Category.BINARY), + BLOB("BLOB", "二进制大对象", "二进制大对象", Category.BINARY), + BYTEA("BYTEA", "二进制数组", "PostgreSQL二进制数组", Category.BINARY), + BIT("BIT", "位类型", "位类型", Category.BINARY), + TINYBINARY("TINYBINARY", "小二进制", "小容量二进制", Category.BINARY), + LONGBINARY("LONGBINARY", "超大二进制", "超大容量二进制", Category.BINARY), + TINYBLOB("TINYBLOB", "小二进制大对象", "小容量二进制大对象", Category.BINARY), + MEDIUMBLOB("MEDIUMBLOB", "中等二进制大对象", "中等容量二进制大对象", Category.BINARY), + LONGBLOB("LONGBLOB", "超大二进制大对象", "超大容量二进制大对象", Category.BINARY), + LONGVARCHAR("LONGVARCHAR", "长变长字符串", "长变长字符串", Category.BINARY), + RAW("RAW", "原始二进制", "Oracle原始二进制", Category.BINARY), + LONG_RAW("LONG_RAW", "长原始二进制", "Oracle长原始二进制", Category.BINARY), + + // 日期时间类型 + DATE("DATE", "日期", "仅包含年月日的日期类型", Category.DATE), + TIME("TIME", "时间", "仅包含时分秒的时间类型", Category.DATE), + DATETIME("DATETIME", "日期时间", "包含日期和时间", Category.DATE), + TIMESTAMP("TIMESTAMP", "时间戳", "时间戳，通常精确到秒或毫秒", Category.DATE), + TIMESTAMPTZ("TIMESTAMPTZ", "带时区时间戳", "带时区的时间戳", Category.DATE), + YEAR("YEAR", "年份", "年份类型", Category.DATE), + DATETIME2("DATETIME2", "高精度日期时间", "高精度日期时间（SQL Server）", Category.DATE), + SMALLDATETIME("SMALLDATETIME", "低精度日期时间", "低精度日期时间（SQL Server）", Category.DATE), + DATETIMEOFFSET("DATETIMEOFFSET", "带时区偏移的日期时间", "带时区偏移的日期时间（SQL Server）", Category.DATE), + + // 布尔类型 + BOOLEAN("BOOLEAN", "布尔", "布尔类型，真或假", Category.BOOLEAN), + + // 枚举类型 + ENUM("ENUM", "枚举", "枚举类型，有限集合", Category.ENUM), + + // JSON/XML + JSON("JSON", "JSON对象", "JSON格式数据", Category.OBJECT), + JSONB("JSONB", "二进制JSON", "二进制JSON格式数据（PostgreSQL）", Category.OBJECT), + XML("XML", "XML对象", "XML格式数据", Category.OBJECT), + + // 地理空间类型 + GEOMETRY("GEOMETRY", "地理空间", "通用地理空间类型", Category.GEO), + POINT("POINT", "点", "地理空间点", Category.GEO), + LINESTRING("LINESTRING", "线", "地理空间线", Category.GEO), + POLYGON("POLYGON", "多边形", "地理空间多边形", Category.GEO), + GEO_POINT("GEO_POINT", "地理点", "地理点（如Elasticsearch）", Category.GEO), + GEO_SHAPE("GEO_SHAPE", "地理形状", "地理形状（如Elasticsearch）", Category.GEO), + + // 网络地址类型 + INET("INET", "IP地址", "IPv4或IPv6地址", Category.NETWORK), + CIDR("CIDR", "网络地址块", "网络地址块", Category.NETWORK), + MACADDR("MACADDR", "MAC地址", "物理网卡地址", Category.NETWORK), + IP("IP", "IP地址", "IP地址", Category.NETWORK), + + // UUID + UUID("UUID", "唯一标识符", "通用唯一标识符", Category.UUID), + + // 金额 + MONEY("MONEY", "货币金额", "货币金额类型", Category.MONEY), + SMALLMONEY("SMALLMONEY", "小额货币", "小额货币类型", Category.MONEY), + + // 其他 + INTERVAL("INTERVAL", "时间间隔", "时间间隔类型", Category.OTHER), + SET("SET", "集合", "集合类型", Category.OTHER), + ARRAY("ARRAY", "数组", "数组类型", Category.OTHER), + OBJECT("OBJECT", "对象", "对象类型", Category.OTHER), + ROWID("ROWID", "行唯一标识", "行唯一标识（Oracle）", Category.OTHER), + UROWID("UROWID", "通用行唯一标识", "通用行唯一标识（Oracle）", Category.OTHER), + KEYWORD("KEYWORD", "关键字", "关键字（如Elasticsearch）", Category.OTHER), + NESTED("NESTED", "嵌套对象", "嵌套对象（如Elasticsearch）", Category.OTHER), + + // 未知类型 + UNKNOWN("UNKNOWN", "未知", "未知类型", Category.UNKNOWN); + + @Getter + private final String baseName; + @Getter + private final String displayName; + @Getter + private final String description; + @Getter + private final Category category; + + StandardDataType(String baseName, String displayName, String description, Category category) { + this.baseName = baseName; + this.displayName = displayName; + this.description = description; + this.category = category; + } - /** - * 忽略大小写查找 - */ public static StandardDataType customValueOf(String type) { return Arrays.stream(StandardDataType.values()) - .filter(item -> StringUtils.equalsIgnoreCase(item.name(), type.replace(" ", "_"))) + .filter(item -> org.apache.commons.lang3.StringUtils.equalsIgnoreCase(item.name(), type.replace(" ", "_"))) .findFirst() .orElse(StandardDataType.UNKNOWN); } + + public enum Category { + NUMBER("数值型"), STRING("字符串型"), BINARY("二进制型"), DATE("日期时间型"), + BOOLEAN("布尔型"), ENUM("枚举型"), OBJECT("对象/结构体"), GEO("地理空间型"), + NETWORK("网络地址型"), UUID("唯一标识符"), MONEY("金额型"), + OTHER("其他"), UNKNOWN("未知"); + @Getter + private final String description; + + Category(String description) { + this.description = description; + } + } } + diff --git a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SinkProvider.java b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SinkProvider.java index a0943f5927..db992f6e4b 100644 --- a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SinkProvider.java +++ b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SinkProvider.java @@ -106,14 +106,6 @@ public interface SinkProvider { */ boolean validateCreateTableSql(DatasourceRequest datasourceRequest, String createTableSql, String tableName); - /** - * 获取获取数据源节点数 - * - * @param datasourceRequest datasource 配置 - * @return 节点数 - */ - String getNodes(DatasourceRequest datasourceRequest); - /** * 获取支持的数据类型 * @@ -147,4 +139,14 @@ public interface SinkProvider { */ String generatorSinkConfig(TaskInfoVO taskInfoVO); + /** + * 默认主键字段 + * + * @param datasourceRequest datasource 配置 + * @return 默认主键字段 + */ + default TableFieldDTO defaultKeyField(DatasourceRequest datasourceRequest) { + return null; + } + } diff --git a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SourceProvider.java b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SourceProvider.java index 651b0c889c..f8c0d24ec9 100644 --- a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SourceProvider.java +++ b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SourceProvider.java @@ -1,5 +1,6 @@ package io.dataease.extensions.sync.provider; +import io.dataease.exception.DEException; import io.dataease.extensions.sync.datatype.StandardDataType; import io.dataease.extensions.sync.model.TableDTO; import io.dataease.extensions.sync.model.TableFieldDTO; @@ -26,6 +27,15 @@ public interface SourceProvider { */ List getTables(DatasourceRequest datasourceRequest); + /** + * 获取表字段信息 + * + * @param datasourceRequest 数据源请求 + * @return 表字段信息列表 + * @throws DEException 异常 + */ + List fetchTableField(DatasourceRequest datasourceRequest) throws DEException; + /** * 通过SQL获取字段信息 * fieldSource 可不用赋值 diff --git a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SyncProvider.java b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SyncProvider.java index bd95de6fa5..e5e6d50f63 100644 --- a/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SyncProvider.java +++ b/sdk/extensions/extensions-sync/src/main/java/io/dataease/extensions/sync/provider/SyncProvider.java @@ -3,11 +3,12 @@ package io.dataease.extensions.sync.provider; import com.jcraft.jsch.JSch; import com.jcraft.jsch.Session; import io.dataease.exception.DEException; -import io.dataease.extensions.sync.model.TableFieldDTO; import io.dataease.extensions.sync.model.datasource.ConnectionObj; import io.dataease.extensions.sync.model.datasource.DatasourceRequest; +import io.dataease.extensions.sync.utils.ProviderUtil; import io.dataease.extensions.sync.vo.DatasourceConfiguration; import lombok.Getter; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -15,10 +16,14 @@ import java.io.IOException; import java.net.Socket; import java.nio.charset.StandardCharsets; import java.sql.Connection; +import java.sql.SQLException; +import java.sql.SQLTimeoutException; import java.sql.Statement; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.regex.Matcher; +import java.util.regex.Pattern; /** * 数据源提供者抽象类，定义了与数据源交互的基本操作和SSH会话管理 @@ -81,21 +86,78 @@ public abstract class SyncProvider { /** * 配置额外参数 - * 如Doris需要配置版本以及be节点等 + * 默认不做任何操作 + * 如: Doris需要配置版本以及be节点等 * * @param datasource 数据源请求 * @throws DEException 异常 */ - public abstract void configurationAdditionalParameters(DatasourceRequest datasource) throws DEException; + public void configurationAdditionalParameters(DatasourceRequest datasource) throws DEException { + // 默认不做任何操作 + } /** - * 获取表字段信息 + * 执行SQL语句 * - * @param datasourceRequest 数据源请求 - * @return 表字段信息列表 - * @throws DEException 异常 + * @param configuration 数据源配置 + * @param queryStr SQL语句 + * @return 执行结果 */ - public abstract List fetchTableField(DatasourceRequest datasourceRequest) throws DEException; + public boolean executeSql(DatasourceConfiguration configuration, String queryStr) { + int queryTimeout = Math.max(configuration.getQueryTimeout(), 30); + // 对于DDL操作，使用更长的超时时间 + if (isDdlOperation(queryStr)) { + queryTimeout = Math.max(queryTimeout, 120); + } + long startTime = System.currentTimeMillis(); + String operationType = getOperationType(queryStr); + try (Connection con = getConnection(configuration).getConnection()) { + con.setNetworkTimeout(Runnable::run, queryTimeout * 1000); + Statement statement = ProviderUtil.getStatement(con, queryTimeout); + // 执行SQL + int result = statement.executeUpdate(queryStr); + return result >= 0; + + } catch (SQLTimeoutException e) { + long executeTime = System.currentTimeMillis() - startTime; + String errorMsg = String.format("%s operation timed out, execution time: %dms, timeout setting: %ds", + operationType, executeTime, queryTimeout); + DEException.throwException(errorMsg); + } catch (SQLException e) { + long executeTime = System.currentTimeMillis() - startTime; + String errorCode = e.getSQLState(); + String errorMsg = String.format("%s operation failed, execution time: %dms, error code: %s, error message: %s", + operationType, executeTime, errorCode, e.getMessage()); + DEException.throwException(errorMsg); + } catch (Exception e) { + long executeTime = System.currentTimeMillis() - startTime; + String errorMsg = String.format("%s operation exception, execution time: %dms, exception message: %s", + operationType, executeTime, e.getMessage()); + DEException.throwException(errorMsg); + } + return false; + } + + /** + * 判断是否为DDL操作 + */ + private boolean isDdlOperation(String sql) { + Pattern ddlPrefix = Pattern.compile("^\\s*(CREATE|ALTER|DROP|TRUNCATE)\\b", Pattern.CASE_INSENSITIVE); + return sql != null && ddlPrefix.matcher(sql).find(); + } + + /** + * 获取操作类型 + */ + private String getOperationType(String sql) { + if (StringUtils.isBlank(sql)) { + return "UNKNOWN"; + } + Matcher m = Pattern + .compile("^\\s*(CREATE|ALTER|DROP|INSERT|UPDATE|DELETE)\\b", Pattern.CASE_INSENSITIVE) + .matcher(sql); + return m.find() ? m.group(1).toUpperCase() : "OTHER"; + } /** * 获取带有查询超时设置的SQL语句对象