executions = runtimeService.createExecutionQuery().processInstanceId(processInstanceId).list();
if (CollUtil.isNotEmpty(executions)) {
log.warn("[moveTaskToEnd][执行跳转到 EndEvent 后, 流程实例未结束，强制执行 deleteProcessInstance 方法]");
@@ -1331,7 +1331,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return;
}
- // 自动去重，通过自动审批的方式 TODO @芋艿 驳回的情况得考虑一下；@lesan：驳回后，又自动审批么？
+ // 自动去重，通过自动审批的方式 TODO @ZT 驳回的情况得考虑一下；@lesan：驳回后，又自动审批么？
BpmProcessDefinitionInfoDO processDefinitionInfo = bpmProcessDefinitionService.getProcessDefinitionInfo(task.getProcessDefinitionId());
if (processDefinitionInfo == null) {
log.error("[processTaskAssigned][taskId({}) 没有找到流程定义({})]", task.getId(), task.getProcessDefinitionId());
@@ -1374,7 +1374,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
}
FlowElement userTaskElement = BpmnModelUtils.getFlowElementById(bpmnModel, task.getTaskDefinitionKey());
// 判断是否为退回或者驳回：如果是退回或者驳回不走这个策略
- // TODO 芋艿：【优化】未来有没更好的判断方式？！另外，还要考虑清理机制。就是说，下次处理了之后，就移除这个标识
+ // TODO ZT：【优化】未来有没更好的判断方式？！另外，还要考虑清理机制。就是说，下次处理了之后，就移除这个标识
Boolean returnTaskFlag = runtimeService.getVariable(processInstance.getProcessInstanceId(),
String.format(PROCESS_INSTANCE_VARIABLE_RETURN_FLAG, task.getTaskDefinitionKey()), Boolean.class);
Boolean skipStartUserNodeFlag = Convert.toBool(runtimeService.getVariable(processInstance.getProcessInstanceId(),
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/listener/BpmUserTaskListener.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/listener/BpmUserTaskListener.java
index 2102560..ec0f164 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/listener/BpmUserTaskListener.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/listener/BpmUserTaskListener.java
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component;
import static com.zt.plat.module.bpm.framework.flowable.core.util.BpmnModelUtils.parseListenerConfig;
-// TODO @芋艿：可能会想换个包地址
+// TODO @ZT：可能会想换个包地址
/**
* BPM 用户任务通用监听器
*
@@ -42,7 +42,7 @@ public class BpmUserTaskListener implements TaskListener {
BpmSimpleModelNodeVO.ListenerHandler listenerHandler = parseListenerConfig(listenerConfig);
// 2. 发起请求
- // TODO @芋艿：哪些默认参数，后续再调研下；感觉可以搞个 task 字段，把整个 delegateTask 放进去；
+ // TODO @ZT：哪些默认参数，后续再调研下；感觉可以搞个 task 字段，把整个 delegateTask 放进去；
listenerHandler.getBody().add(new BpmSimpleModelNodeVO.HttpRequestParam().setKey("processInstanceId")
.setType(BpmHttpRequestParamTypeEnum.FIXED_VALUE.getType()).setValue(delegateTask.getProcessInstanceId()));
listenerHandler.getBody().add(new BpmSimpleModelNodeVO.HttpRequestParam().setKey("assignee")
@@ -54,6 +54,6 @@ public class BpmUserTaskListener implements TaskListener {
BpmHttpRequestUtils.executeBpmHttpRequest(processInstance,
listenerHandler.getPath(), listenerHandler.getHeader(), listenerHandler.getBody(), false, null);
- // 3. 是否需要后续操作？TODO 芋艿：待定！
+ // 3. 是否需要后续操作？TODO ZT：待定！
}
}
\ No newline at end of file
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/BpmTrigger.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/BpmTrigger.java
index 02fb2d5..8aee717 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/BpmTrigger.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/BpmTrigger.java
@@ -2,7 +2,7 @@ package com.zt.plat.module.bpm.service.task.trigger;
import com.zt.plat.module.bpm.enums.definition.BpmTriggerTypeEnum;
-// TODO @芋艿：可能会想换个包地址
+// TODO @ZT：可能会想换个包地址
/**
* BPM 触发器接口
*
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormDeleteTrigger.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormDeleteTrigger.java
index 60d3073..46ed559 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormDeleteTrigger.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormDeleteTrigger.java
@@ -1,7 +1,6 @@
package com.zt.plat.module.bpm.service.task.trigger.form;
import cn.hutool.core.collection.CollUtil;
-import com.fasterxml.jackson.core.type.TypeReference;
import com.zt.plat.framework.common.util.json.JsonUtils;
import com.zt.plat.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelNodeVO;
import com.zt.plat.module.bpm.enums.definition.BpmTriggerTypeEnum;
@@ -9,6 +8,7 @@ import com.zt.plat.module.bpm.framework.flowable.core.util.BpmnModelUtils;
import com.zt.plat.module.bpm.framework.flowable.core.util.SimpleModelUtils;
import com.zt.plat.module.bpm.service.task.BpmProcessInstanceService;
import com.zt.plat.module.bpm.service.task.trigger.BpmTrigger;
+import com.fasterxml.jackson.core.type.TypeReference;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormUpdateTrigger.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormUpdateTrigger.java
index 79a48d9..c8427b2 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormUpdateTrigger.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/form/BpmFormUpdateTrigger.java
@@ -1,7 +1,6 @@
package com.zt.plat.module.bpm.service.task.trigger.form;
import cn.hutool.core.collection.CollUtil;
-import com.fasterxml.jackson.core.type.TypeReference;
import com.zt.plat.framework.common.util.json.JsonUtils;
import com.zt.plat.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelNodeVO.TriggerSetting.FormTriggerSetting;
import com.zt.plat.module.bpm.enums.definition.BpmTriggerTypeEnum;
@@ -9,6 +8,7 @@ import com.zt.plat.module.bpm.framework.flowable.core.util.BpmnModelUtils;
import com.zt.plat.module.bpm.framework.flowable.core.util.SimpleModelUtils;
import com.zt.plat.module.bpm.service.task.BpmProcessInstanceService;
import com.zt.plat.module.bpm.service.task.trigger.BpmTrigger;
+import com.fasterxml.jackson.core.type.TypeReference;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmHttpCallbackTrigger.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmHttpCallbackTrigger.java
index 76292d8..3fe0606 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmHttpCallbackTrigger.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmHttpCallbackTrigger.java
@@ -10,6 +10,7 @@ import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.flowable.engine.runtime.ProcessInstance;
import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
/**
* BPM HTTP 回调触发器
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmSyncHttpRequestTrigger.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmSyncHttpRequestTrigger.java
index f612660..617bf7a 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmSyncHttpRequestTrigger.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/task/trigger/http/BpmSyncHttpRequestTrigger.java
@@ -9,6 +9,7 @@ import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.flowable.engine.runtime.ProcessInstance;
import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
/**
* BPM 发送同步 HTTP 请求触发器
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/database/core/DmDatabase.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/database/core/DmDatabase.java
index e7dc5bf..9e2c50f 100644
--- a/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/database/core/DmDatabase.java
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/database/core/DmDatabase.java
@@ -5,6 +5,25 @@
package liquibase.database.core;
+import java.lang.reflect.Method;
+import java.sql.CallableStatement;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+import java.util.Properties;
+import java.util.ResourceBundle;
+import java.util.Set;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
import liquibase.CatalogAndSchema;
import liquibase.GlobalConfiguration;
import liquibase.Scope;
@@ -23,17 +42,15 @@ import liquibase.statement.UniqueConstraint;
import liquibase.statement.core.RawCallStatement;
import liquibase.statement.core.RawParameterizedSqlStatement;
import liquibase.structure.DatabaseObject;
-import liquibase.structure.core.*;
+import liquibase.structure.core.Catalog;
+import liquibase.structure.core.Column;
+import liquibase.structure.core.Index;
+import liquibase.structure.core.PrimaryKey;
+import liquibase.structure.core.Schema;
import liquibase.util.JdbcUtil;
import liquibase.util.StringUtil;
import org.apache.commons.lang3.StringUtils;
-import java.lang.reflect.Method;
-import java.sql.*;
-import java.util.*;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
public class DmDatabase extends AbstractJdbcDatabase {
private static final String PROXY_USER_REGEX = ".*(?:thin|oci)\\:(.+)/@.*";
public static final Pattern PROXY_USER_PATTERN = Pattern.compile(".*(?:thin|oci)\\:(.+)/@.*");
@@ -98,6 +115,7 @@ public class DmDatabase extends AbstractJdbcDatabase {
public void setConnection(DatabaseConnection conn) {
this.reservedWords.addAll(Arrays.asList("GROUP", "USER", "SESSION", "PASSWORD", "RESOURCE", "START", "SIZE", "UID", "DESC", "ORDER"));
Connection sqlConn = null;
+ boolean dmDatabase = false;
if (!(conn instanceof OfflineConnection)) {
try {
if (conn instanceof JdbcConnection) {
@@ -124,26 +142,42 @@ public class DmDatabase extends AbstractJdbcDatabase {
Scope.getCurrentScope().getLog(this.getClass()).info("Could not set remarks reporting on OracleDatabase: " + e.getMessage());
}
- CallableStatement statement = null;
-
try {
- statement = sqlConn.prepareCall("{call DBMS_UTILITY.DB_VERSION(?,?)}");
- statement.registerOutParameter(1, 12);
- statement.registerOutParameter(2, 12);
- statement.execute();
- String compatibleVersion = statement.getString(2);
- if (compatibleVersion != null) {
- Matcher majorVersionMatcher = VERSION_PATTERN.matcher(compatibleVersion);
- if (majorVersionMatcher.matches()) {
- this.databaseMajorVersion = Integer.valueOf(majorVersionMatcher.group(1));
- this.databaseMinorVersion = Integer.valueOf(majorVersionMatcher.group(2));
+ DatabaseMetaData metaData = sqlConn.getMetaData();
+ if (metaData != null) {
+ String productName = metaData.getDatabaseProductName();
+ dmDatabase = productName != null && PRODUCT_NAME.equalsIgnoreCase(productName);
+ if (dmDatabase) {
+ this.databaseMajorVersion = metaData.getDatabaseMajorVersion();
+ this.databaseMinorVersion = metaData.getDatabaseMinorVersion();
}
}
} catch (SQLException e) {
- String message = "Cannot read from DBMS_UTILITY.DB_VERSION: " + e.getMessage();
- Scope.getCurrentScope().getLog(this.getClass()).info("Could not set check compatibility mode on OracleDatabase, assuming not running in any sort of compatibility mode: " + message);
- } finally {
- JdbcUtil.closeStatement(statement);
+ Scope.getCurrentScope().getLog(this.getClass()).info("Unable to inspect database metadata for DM version detection: " + e.getMessage());
+ }
+
+ if (!dmDatabase) {
+ CallableStatement statement = null;
+
+ try {
+ statement = sqlConn.prepareCall("{call DBMS_UTILITY.DB_VERSION(?,?)}");
+ statement.registerOutParameter(1, 12);
+ statement.registerOutParameter(2, 12);
+ statement.execute();
+ String compatibleVersion = statement.getString(2);
+ if (compatibleVersion != null) {
+ Matcher majorVersionMatcher = VERSION_PATTERN.matcher(compatibleVersion);
+ if (majorVersionMatcher.matches()) {
+ this.databaseMajorVersion = Integer.valueOf(majorVersionMatcher.group(1));
+ this.databaseMinorVersion = Integer.valueOf(majorVersionMatcher.group(2));
+ }
+ }
+ } catch (SQLException e) {
+ String message = "Cannot read from DBMS_UTILITY.DB_VERSION: " + e.getMessage();
+ Scope.getCurrentScope().getLog(this.getClass()).info("Could not set check compatibility mode on OracleDatabase, assuming not running in any sort of compatibility mode: " + message);
+ } finally {
+ JdbcUtil.closeStatement(statement);
+ }
}
if (GlobalConfiguration.DDL_LOCK_TIMEOUT.getCurrentValue() != null) {
@@ -250,7 +284,15 @@ public class DmDatabase extends AbstractJdbcDatabase {
}
public boolean isCorrectDatabaseImplementation(DatabaseConnection conn) throws DatabaseException {
- return "oracle".equalsIgnoreCase(conn.getDatabaseProductName());
+ String databaseProductName = conn == null ? null : conn.getDatabaseProductName();
+ if (databaseProductName == null) {
+ return false;
+ }
+ if (PRODUCT_NAME.equalsIgnoreCase(databaseProductName)) {
+ return true;
+ }
+ // Flowable 历史上将 DM 映射为 Oracle 元数据，因此这里同样接受 Oracle 以保持兼容
+ return "oracle".equalsIgnoreCase(databaseProductName);
}
public String getDefaultDriver(String url) {
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/datatype/core/DmBooleanType.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/datatype/core/DmBooleanType.java
new file mode 100644
index 0000000..7f66250
--- /dev/null
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/datatype/core/DmBooleanType.java
@@ -0,0 +1,32 @@
+package liquibase.datatype.core;
+
+import liquibase.database.Database;
+import liquibase.database.core.DmDatabase;
+import liquibase.datatype.DataTypeInfo;
+import liquibase.datatype.DatabaseDataType;
+
+@DataTypeInfo(
+ name = "boolean",
+ aliases = {"java.sql.Types.BOOLEAN", "java.lang.Boolean", "bit", "bool"},
+ minParameters = 0,
+ maxParameters = 0,
+ priority = 2
+)
+public class DmBooleanType extends BooleanType {
+
+ @Override
+ public boolean supports(Database database) {
+ if (database instanceof DmDatabase) {
+ return true;
+ }
+ return super.supports(database);
+ }
+
+ @Override
+ public DatabaseDataType toDatabaseDataType(Database database) {
+ if (database instanceof DmDatabase) {
+ return new DatabaseDataType("NUMBER", 1);
+ }
+ return super.toDatabaseDataType(database);
+ }
+}
diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/snapshot/JdbcDatabaseSnapshot.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/snapshot/JdbcDatabaseSnapshot.java
new file mode 100644
index 0000000..1e0a40e
--- /dev/null
+++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/liquibase/snapshot/JdbcDatabaseSnapshot.java
@@ -0,0 +1,1957 @@
+package liquibase.snapshot;
+
+import liquibase.CatalogAndSchema;
+import liquibase.Scope;
+import liquibase.database.AbstractJdbcDatabase;
+import liquibase.database.Database;
+import liquibase.database.DatabaseConnection;
+import liquibase.database.LiquibaseTableNamesFactory;
+import liquibase.database.core.*;
+import liquibase.database.jvm.JdbcConnection;
+import liquibase.exception.DatabaseException;
+import liquibase.executor.jvm.ColumnMapRowMapper;
+import liquibase.executor.jvm.RowMapperNotNullConstraintsResultSetExtractor;
+import liquibase.structure.DatabaseObject;
+import liquibase.structure.core.Catalog;
+import liquibase.structure.core.Schema;
+import liquibase.structure.core.Table;
+import liquibase.structure.core.View;
+import liquibase.util.JdbcUtil;
+import liquibase.util.StringUtil;
+
+import java.sql.*;
+import java.util.*;
+
+public class JdbcDatabaseSnapshot extends DatabaseSnapshot {
+
+ private boolean warnedAboutDbaRecycleBin;
+ private static final boolean ignoreWarnAboutDbaRecycleBin = Boolean.getBoolean("liquibase.ignoreRecycleBinWarning");
+
+ private CachingDatabaseMetaData cachingDatabaseMetaData;
+
+ private Map cachedExpressionMap = null;
+
+ private Set userDefinedTypes;
+
+ public JdbcDatabaseSnapshot(DatabaseObject[] examples, Database database, SnapshotControl snapshotControl) throws DatabaseException, InvalidExampleException {
+ super(examples, database, snapshotControl);
+ }
+
+ public JdbcDatabaseSnapshot(DatabaseObject[] examples, Database database) throws DatabaseException, InvalidExampleException {
+ super(examples, database);
+ }
+
+ public CachingDatabaseMetaData getMetaDataFromCache() throws SQLException {
+ if (cachingDatabaseMetaData == null) {
+ DatabaseMetaData databaseMetaData = null;
+ if (getDatabase().getConnection() != null) {
+ databaseMetaData = ((JdbcConnection) getDatabase().getConnection()).getUnderlyingConnection().getMetaData();
+ }
+
+ cachingDatabaseMetaData = new CachingDatabaseMetaData(this.getDatabase(), databaseMetaData);
+ }
+ return cachingDatabaseMetaData;
+ }
+
+ public class CachingDatabaseMetaData {
+ private static final String SQL_FILTER_MATCH_ALL = "%";
+ private final DatabaseMetaData databaseMetaData;
+ private final Database database;
+
+ public CachingDatabaseMetaData(Database database, DatabaseMetaData metaData) {
+ this.databaseMetaData = metaData;
+ this.database = database;
+ }
+
+ public java.sql.DatabaseMetaData getDatabaseMetaData() {
+ return databaseMetaData;
+ }
+
+ public List getForeignKeys(final String catalogName, final String schemaName, final String tableName,
+ final String fkName) throws DatabaseException {
+ ForeignKeysResultSetCache foreignKeysResultSetCache = new ForeignKeysResultSetCache(database, catalogName, schemaName, tableName, fkName);
+ ResultSetCache importedKeys = getResultSetCache("getImportedKeys");
+ importedKeys.setBulkTracking(!(database instanceof MSSQLDatabase));
+
+ return importedKeys.get(foreignKeysResultSetCache);
+ }
+
+ public List getIndexInfo(final String catalogName, final String schemaName, final String tableName, final String indexName) throws DatabaseException, SQLException {
+
+ return getResultSetCache("getIndexInfo").get(new ResultSetCache.UnionResultSetExtractor(database) {
+
+ public boolean isBulkFetchMode;
+
+ @Override
+ public ResultSetCache.RowData rowKeyParameters(CachedRow row) {
+ return new ResultSetCache.RowData(row.getString("TABLE_CAT"), row.getString("TABLE_SCHEM"), database, row.getString("TABLE_NAME"), row.getString("INDEX_NAME"));
+ }
+
+ @Override
+ public ResultSetCache.RowData wantedKeyParameters() {
+ return new ResultSetCache.RowData(catalogName, schemaName, database, tableName, indexName);
+ }
+
+ @Override
+ public boolean bulkContainsSchema(String schemaKey) {
+ return getAllCatalogsStringScratchData() != null && database instanceof OracleDatabase;
+ }
+
+ @Override
+ public String getSchemaKey(CachedRow row) {
+ return row.getString("TABLE_SCHEM");
+ }
+
+ @Override
+ public List fastFetch() throws SQLException, DatabaseException {
+ List returnList = new ArrayList<>();
+
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+ if (database instanceof OracleDatabase) {
+ warnAboutDbaRecycleBin();
+
+ //oracle getIndexInfo is buggy and slow. See Issue 1824548 and http://forums.oracle.com/forums/thread.jspa?messageID=578383
+ String sql =
+ "SELECT " +
+ "c.INDEX_NAME, " +
+ "3 AS TYPE, " +
+ "c.TABLE_OWNER AS TABLE_SCHEM, " +
+ "c.TABLE_NAME, " +
+ "c.COLUMN_NAME, " +
+ "c.COLUMN_POSITION AS ORDINAL_POSITION, " +
+ "NULL AS FILTER_CONDITION, " +
+ "c.INDEX_OWNER, " +
+ "CASE I.UNIQUENESS WHEN 'UNIQUE' THEN 0 ELSE 1 END AS NON_UNIQUE, " +
+ "CASE c.DESCEND WHEN 'Y' THEN 'D' WHEN 'DESC' THEN 'D' WHEN 'N' THEN 'A' WHEN 'ASC' THEN 'A' END AS ASC_OR_DESC, " +
+ "CASE WHEN tablespace_name = (SELECT default_tablespace FROM user_users) " +
+ "THEN NULL ELSE tablespace_name END AS tablespace_name " +
+ "FROM ALL_IND_COLUMNS c " +
+ "JOIN ALL_INDEXES i ON i.owner=c.index_owner AND i.index_name = c.index_name and i.table_owner = c.table_owner " +
+ "LEFT OUTER JOIN " + (((OracleDatabase) database).canAccessDbaRecycleBin() ? "dba_recyclebin" : "user_recyclebin") + " d ON d.object_name=c.table_name ";
+ if (!isBulkFetchMode || getAllCatalogsStringScratchData() == null) {
+ sql += "WHERE c.TABLE_OWNER = '" + database.correctObjectName(catalogAndSchema.getCatalogName(), Schema.class) + "' ";
+ } else {
+ sql += "WHERE c.TABLE_OWNER IN ('" + database.correctObjectName(catalogAndSchema.getCatalogName(), Schema.class) + "', " + getAllCatalogsStringScratchData() + ")";
+ }
+ sql += "AND i.OWNER = c.TABLE_OWNER " +
+ "AND d.object_name IS NULL ";
+
+
+ if (!isBulkFetchMode && (tableName != null)) {
+ sql += " AND c.TABLE_NAME='" + tableName + "'";
+ }
+
+ if (!isBulkFetchMode && (indexName != null)) {
+ sql += " AND c.INDEX_NAME='" + indexName + "'";
+ }
+
+ sql += " ORDER BY c.INDEX_NAME, ORDINAL_POSITION";
+
+ returnList.addAll(setIndexExpressions(executeAndExtract(sql, database)));
+ } else if (database instanceof MSSQLDatabase) {
+ String tableCat = "original_db_name()";
+
+ if (9 <= database.getDatabaseMajorVersion()) {
+ tableCat = "db_name()";
+ }
+ //fetch additional index info
+ String sql = "SELECT " +
+ tableCat + " as TABLE_CAT, " +
+ "object_schema_name(i.object_id) as TABLE_SCHEM, " +
+ "object_name(i.object_id) as TABLE_NAME, " +
+ "CASE is_unique WHEN 1 then 0 else 1 end as NON_UNIQUE, " +
+ "object_name(i.object_id) as INDEX_QUALIFIER, " +
+ "i.name as INDEX_NAME, " +
+ "case i.type when 1 then 1 ELSE 3 end as TYPE, " +
+ "key_ordinal as ORDINAL_POSITION, " +
+ "COL_NAME(c.object_id,c.column_id) AS COLUMN_NAME, " +
+ "case is_descending_key when 0 then 'A' else 'D' end as ASC_OR_DESC, " +
+ "null as CARDINALITY, " +
+ "null as PAGES, " +
+ "i.filter_definition as FILTER_CONDITION, " +
+ "o.type AS INTERNAL_OBJECT_TYPE, " +
+ "i.*, " +
+ "c.*, " +
+ "s.* " +
+ "FROM sys.indexes i " +
+ "join sys.index_columns c on i.object_id=c.object_id and i.index_id=c.index_id " +
+ "join sys.stats s on i.object_id=s.object_id and i.name=s.name " +
+ "join sys.objects o on i.object_id=o.object_id " +
+ "WHERE object_schema_name(i.object_id)='" + database.correctObjectName(catalogAndSchema.getSchemaName(), Schema.class) + "'";
+
+ if (!isBulkFetchMode && (tableName != null)) {
+ sql += " AND object_name(i.object_id)='" + database.escapeStringForDatabase(tableName) + "'";
+ }
+
+ if (!isBulkFetchMode && (indexName != null)) {
+ sql += " AND i.name='" + database.escapeStringForDatabase(indexName) + "'";
+ }
+
+ sql += "ORDER BY i.object_id, i.index_id, c.key_ordinal";
+
+ returnList.addAll(executeAndExtract(sql, database));
+
+ } else if (database instanceof Db2zDatabase) {
+ List parameters = new ArrayList<>(3);
+ String sql = "SELECT i.CREATOR AS TABLE_SCHEM, " +
+ "i.TBNAME AS TABLE_NAME, " +
+ "i.NAME AS INDEX_NAME, " +
+ "3 AS TYPE, " +
+ "k.COLNAME AS COLUMN_NAME, " +
+ "k.COLSEQ AS ORDINAL_POSITION, " +
+ "CASE UNIQUERULE WHEN 'D' then 1 else 0 end as NON_UNIQUE, " +
+ "k.ORDERING AS ORDER, " +
+ "i.CREATOR AS INDEX_QUALIFIER " +
+ "FROM SYSIBM.SYSKEYS k " +
+ "JOIN SYSIBM.SYSINDEXES i " +
+ "ON k.IXNAME = i.NAME " +
+ "AND k.IXCREATOR = i.CREATOR " +
+ "WHERE i.CREATOR = ?";
+ parameters.add(database.correctObjectName(catalogAndSchema.getSchemaName(), Schema.class));
+ if (!isBulkFetchMode && tableName != null) {
+ sql += " AND i.TBNAME = ?";
+ parameters.add(database.escapeStringForDatabase(tableName));
+ }
+
+ if (!isBulkFetchMode && indexName != null) {
+ sql += " AND i.NAME = ?";
+ parameters.add(database.escapeStringForDatabase(indexName));
+ }
+
+ sql += "ORDER BY i.NAME, k.COLSEQ";
+
+ returnList.addAll(executeAndExtract(database, sql, parameters.toArray()));
+ } else if (!(database instanceof MariaDBDatabase) && database instanceof MySQLDatabase) {
+
+ //mysql 8.0.13 introduced support for indexes on `lower(first_name)` which comes back in an "expression" column
+ String filterConditionValue = "NULL";
+ if (database.getDatabaseMajorVersion() > 8 || (database.getDatabaseMajorVersion() == 8 && ((MySQLDatabase) database).getDatabasePatchVersion() >= 13)) {
+ filterConditionValue = "EXPRESSION";
+ }
+
+ StringBuilder sql = new StringBuilder("SELECT TABLE_CATALOG AS TABLE_CAT, TABLE_SCHEMA AS TABLE_SCHEM,");
+ sql.append(" TABLE_NAME, NON_UNIQUE, NULL AS INDEX_QUALIFIER, INDEX_NAME,");
+ sql.append(DatabaseMetaData.tableIndexOther);
+ sql.append(" AS TYPE, SEQ_IN_INDEX AS ORDINAL_POSITION, COLUMN_NAME,");
+ sql.append("COLLATION AS ASC_OR_DESC, CARDINALITY, 0 AS PAGES, " + filterConditionValue + " AS FILTER_CONDITION FROM INFORMATION_SCHEMA.STATISTICS WHERE");
+ sql.append(" TABLE_SCHEMA = '").append(database.correctObjectName(catalogAndSchema.getCatalogName(), Catalog.class)).append("'");
+
+ if (!isBulkFetchMode && tableName != null) {
+ sql.append(" AND TABLE_NAME = '").append(database.escapeStringForDatabase(tableName)).append("'");
+ }
+
+ if (!isBulkFetchMode && indexName != null) {
+ sql.append(" AND INDEX_NAME='").append(database.escapeStringForDatabase(indexName)).append("'");
+ }
+
+ sql.append("ORDER BY NON_UNIQUE, INDEX_NAME, SEQ_IN_INDEX");
+
+ returnList.addAll(executeAndExtract(sql.toString(), database));
+ } else {
+ /*
+ * If we do not know in which table to look for the index, things get a little bit ugly.
+ * First, we get a collection of all tables within the catalogAndSchema, then iterate through
+ * them until we (hopefully) find the index we are looking for.
+ */
+ List tables = new ArrayList<>();
+ if (tableName == null) {
+ // Build a list of all candidate tables in the catalog/schema that might contain the index
+ for (CachedRow row : getTables(((AbstractJdbcDatabase) database).getJdbcCatalogName(catalogAndSchema), ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema), null)) {
+ tables.add(row.getString("TABLE_NAME"));
+ }
+ } else {
+ tables.add(tableName);
+ }
+
+ // Iterate through all the candidate tables and try to find the index.
+ for (String tableName1 : tables) {
+ ResultSet rs = databaseMetaData.getIndexInfo(
+ ((AbstractJdbcDatabase) database).getJdbcCatalogName(catalogAndSchema),
+ ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema),
+ tableName1,
+ false,
+ true);
+ List rows = extract(rs, (database instanceof InformixDatabase));
+ returnList.addAll(rows);
+ }
+ }
+
+ return returnList;
+ }
+
+ private List setIndexExpressions(List c) throws DatabaseException, SQLException {
+ Map expressionMap = getCachedExpressionMap();
+ c.forEach(row -> {
+ row.set("FILTER_CONDITION", null);
+ String key = row.getString("INDEX_OWNER") + "::" + row.getString("INDEX_NAME") + "::" +
+ row.getInt("ORDINAL_POSITION");
+ CachedRow fromMap = expressionMap.get(key);
+ if (fromMap != null) {
+ row.set("FILTER_CONDITION", fromMap.get("COLUMN_EXPRESSION"));
+ }
+ });
+ return c;
+ }
+
+ private Map getCachedExpressionMap() throws DatabaseException, SQLException {
+ if (cachedExpressionMap != null) {
+ return cachedExpressionMap;
+ }
+ String expSql = "SELECT e.column_expression, e.index_owner, e.index_name, e.column_position FROM all_ind_expressions e";
+ List ec = executeAndExtract(expSql, database);
+ cachedExpressionMap = new HashMap<>();
+ ec.forEach(row -> {
+ String key = row.getString("INDEX_OWNER") + "::" + row.getString("INDEX_NAME") + "::" +
+ row.getInt("COLUMN_POSITION");
+ cachedExpressionMap.put(key, row);
+ });
+ return cachedExpressionMap;
+ }
+
+ @Override
+ public List bulkFetch() throws SQLException, DatabaseException {
+ this.isBulkFetchMode = true;
+ return fastFetch();
+ }
+
+ @Override
+ protected boolean shouldBulkSelect(String schemaKey, ResultSetCache resultSetCache) {
+ if (database instanceof OracleDatabase || database instanceof MSSQLDatabase) {
+ return JdbcDatabaseSnapshot.this.getAllCatalogsStringScratchData() != null || (tableName == null && indexName == null) || super.shouldBulkSelect(schemaKey, resultSetCache);
+ }
+ return false;
+ }
+ });
+ }
+
+
+ protected void warnAboutDbaRecycleBin() {
+ if (!ignoreWarnAboutDbaRecycleBin && !warnedAboutDbaRecycleBin && !(((OracleDatabase) database).canAccessDbaRecycleBin())) {
+ Scope.getCurrentScope().getLog(getClass()).warning(((OracleDatabase) database).getDbaRecycleBinWarning());
+ warnedAboutDbaRecycleBin = true;
+ }
+ }
+
+ /**
+ * Return the columns for the given catalog, schema, table, and column.
+ */
+ public List getColumns(final String catalogName, final String schemaName, final String tableName, final String columnName) throws SQLException, DatabaseException {
+
+ if ((database instanceof MSSQLDatabase) && (userDefinedTypes == null)) {
+ userDefinedTypes = new HashSet<>();
+ DatabaseConnection databaseConnection = database.getConnection();
+ if (databaseConnection instanceof JdbcConnection) {
+ Statement stmt = null;
+ ResultSet resultSet = null;
+ try {
+ stmt = ((JdbcConnection) databaseConnection).getUnderlyingConnection().createStatement();
+ resultSet = stmt.executeQuery("select name from " + (catalogName == null ? "" : "[" + catalogName + "].") + "sys.types where is_user_defined=1");
+ while (resultSet.next()) {
+ userDefinedTypes.add(resultSet.getString("name").toLowerCase());
+ }
+ } finally {
+ JdbcUtil.close(resultSet, stmt);
+ }
+ }
+ }
+ GetColumnResultSetCache getColumnResultSetCache = new GetColumnResultSetCache(database, catalogName,
+ schemaName, tableName, columnName);
+ return getResultSetCache("getColumns").get(getColumnResultSetCache);
+ }
+
+ /**
+ * Return the NotNullConstraints for the given catalog, schema, table, and column.
+ */
+ public List getNotNullConst(final String catalogName, final String schemaName,
+ final String tableName) throws DatabaseException {
+ if (!(database instanceof OracleDatabase)) {
+ return Collections.emptyList();
+ }
+ GetNotNullConstraintsResultSetCache getNotNullConstraintsResultSetCache = new GetNotNullConstraintsResultSetCache(database, catalogName,
+ schemaName, tableName);
+ return getResultSetCache("getNotNullConst").get(getNotNullConstraintsResultSetCache);
+ }
+
+ private class GetColumnResultSetCache extends ResultSetCache.SingleResultSetExtractor {
+ final String catalogName;
+ final String schemaName;
+ final String tableName;
+ final String columnName;
+
+ private GetColumnResultSetCache(Database database, String catalogName, String schemaName, String tableName, String columnName) {
+ super(database);
+ this.catalogName = catalogName;
+ this.schemaName = schemaName;
+ this.tableName = tableName;
+ this.columnName = columnName;
+ }
+
+ @Override
+ public ResultSetCache.RowData rowKeyParameters(CachedRow row) {
+ return new ResultSetCache.RowData(row.getString("TABLE_CAT"), row.getString("TABLE_SCHEM"), database, row.getString("TABLE_NAME"), row.getString("COLUMN_NAME"));
+ }
+
+ @Override
+ public ResultSetCache.RowData wantedKeyParameters() {
+ return new ResultSetCache.RowData(catalogName, schemaName, database, tableName, columnName);
+ }
+
+ @Override
+ public boolean bulkContainsSchema(String schemaKey) {
+ String catalogs = getAllCatalogsStringScratchData();
+ return catalogs != null && schemaKey != null
+ && catalogs.contains("'" + schemaKey.toUpperCase() + "'")
+ && database instanceof OracleDatabase;
+ }
+
+ @Override
+ public String getSchemaKey(CachedRow row) {
+ return row.getString("TABLE_SCHEM");
+ }
+
+ @Override
+ protected boolean shouldBulkSelect(String schemaKey, ResultSetCache resultSetCache) {
+ LiquibaseTableNamesFactory liquibaseTableNamesFactory = Scope.getCurrentScope().getSingleton(LiquibaseTableNamesFactory.class);
+ List liquibaseTableNames = liquibaseTableNamesFactory.getLiquibaseTableNames(database);
+ return liquibaseTableNames.stream().noneMatch(tableName::equalsIgnoreCase);
+ }
+
+ @Override
+ public List fastFetchQuery() throws SQLException, DatabaseException {
+ if (database instanceof OracleDatabase) {
+ return oracleQuery(false);
+ } else if (database instanceof MSSQLDatabase) {
+ return mssqlQuery(false);
+ }
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ try {
+ List returnList =
+ extract(
+ databaseMetaData.getColumns(
+ ((AbstractJdbcDatabase) database).getJdbcCatalogName(catalogAndSchema),
+ escapeForLike(((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema), database),
+ escapeForLike(tableName, database),
+ SQL_FILTER_MATCH_ALL)
+ );
+ //
+ // IF MARIADB OR SQL ANYWHERE
+ // Query to get actual data types and then map each column to its CachedRow
+ //
+ determineActualDataTypes(returnList, tableName);
+ return returnList;
+ } catch (SQLException e) {
+ if (shouldReturnEmptyColumns(e)) { //view with table already dropped. Act like it has no columns.
+ return new ArrayList<>();
+ } else {
+ throw e;
+ }
+ }
+ }
+
+ @Override
+ public List bulkFetchQuery() throws SQLException, DatabaseException {
+ if (database instanceof OracleDatabase) {
+ return oracleQuery(true);
+ } else if (database instanceof MSSQLDatabase) {
+ return mssqlQuery(true);
+ }
+
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ try {
+ List returnList =
+ extract(databaseMetaData.getColumns(((AbstractJdbcDatabase) database)
+ .getJdbcCatalogName(catalogAndSchema),
+ escapeForLike(((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema), database),
+ SQL_FILTER_MATCH_ALL, SQL_FILTER_MATCH_ALL));
+ //
+ // IF MARIADB OR SQL ANYWHERE
+ // Query to get actual data types and then map each column to its CachedRow
+ //
+ determineActualDataTypes(returnList, null);
+ return returnList;
+ } catch (SQLException e) {
+ if (shouldReturnEmptyColumns(e)) {
+ return new ArrayList<>();
+ } else {
+ throw e;
+ }
+ }
+ }
+
+ //
+ // For MariaDB, query for the data type column so that we can correctly
+ // set the DATETIME(6) type if specified
+ //
+ // For SQL Anywhere, query for the scale column so we can correctly
+ // set the size unit
+ //
+ private void determineActualDataTypes(List returnList, String tableName) throws SQLException {
+ //
+ // If not MariaDB / SQL Anywhere then just return
+ //
+ if (!(database instanceof MariaDBDatabase || database instanceof SybaseASADatabase)) {
+ return;
+ }
+
+ if (database instanceof SybaseASADatabase) {
+ //
+ // Query for actual data type for column. The actual SYSTABCOL.scale column value is
+ // not reported by the DatabaseMetadata.getColumns() query for CHAR-limited (in contrast
+ // to BYTE-limited) columns, and it is needed to capture the kind if limitation.
+ // The actual SYSTABCOL.column_type is not reported by the DatabaseMetadata.getColumns()
+ // query as the IS_GENERATEDCOLUMN columns is missing in the result set, and it is needed to
+ // capture the kind of column (regular or computed).
+ //
+ // See https://help.sap.com/docs/SAP_SQL_Anywhere/93079d4ba8e44920ae63ffb4def91f5b/3beaa3956c5f1014883cb0c3e3559cc9.html.
+ //
+ String selectStatement =
+ "SELECT table_name, column_name, scale, column_type FROM SYSTABCOL KEY JOIN SYSTAB KEY JOIN SYSUSER " +
+ "WHERE user_name = ? AND ? IS NULL OR table_name = ?";
+ Connection underlyingConnection = ((JdbcConnection) database.getConnection()).getUnderlyingConnection();
+ try (PreparedStatement stmt = underlyingConnection.prepareStatement(selectStatement)) {
+ stmt.setString(1, schemaName);
+ stmt.setString(2, tableName);
+ stmt.setString(3, tableName);
+ try (ResultSet columnSelectRS = stmt.executeQuery()) {
+ while (columnSelectRS.next()) {
+ String selectedTableName = columnSelectRS.getString("table_name");
+ String selectedColumnName = columnSelectRS.getString("column_name");
+ int selectedScale = columnSelectRS.getInt("scale");
+ String selectedColumnType = columnSelectRS.getString("column_type");
+ for (CachedRow row : returnList) {
+ String rowTableName = row.getString("TABLE_NAME");
+ String rowColumnName = row.getString("COLUMN_NAME");
+ if (rowTableName.equalsIgnoreCase(selectedTableName) &&
+ rowColumnName.equalsIgnoreCase(selectedColumnName)) {
+ int rowDataType = row.getInt("DATA_TYPE");
+ if (rowDataType == Types.VARCHAR || rowDataType == Types.CHAR) {
+ row.set("scale", selectedScale);
+ }
+ row.set("IS_GENERATEDCOLUMN", "C".equals(selectedColumnType) ? "YES" : "NO");
+ break;
+ }
+ }
+ }
+ }
+ } catch (SQLException sqle) {
+ throw new RuntimeException(sqle);
+ //
+ // Do not stop
+ //
+ }
+ return;
+ }
+
+ //
+ // Query for actual data type for column. The actual DATA_TYPE column string is
+ // not returned by the DatabaseMetadata.getColumns() query, and it is needed
+ // to capture DATETIME() data types.
+ //
+ StringBuilder selectStatement = new StringBuilder(
+ "SELECT TABLE_SCHEMA, TABLE_NAME, COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = ?");
+ if(tableName != null) {
+ selectStatement.append(" AND TABLE_NAME = ?");
+ }
+ Connection underlyingConnection = ((JdbcConnection) database.getConnection()).getUnderlyingConnection();
+ PreparedStatement statement = underlyingConnection.prepareStatement(selectStatement.toString());
+ statement.setString(1, schemaName);
+ if (tableName != null) {
+ statement.setString(2, tableName);
+ }
+ try {
+ ResultSet columnSelectRS = statement.executeQuery(selectStatement.toString());
+ //
+ // Iterate the result set from the query and match the rows
+ // to the rows that were returned by getColumns() in order
+ // to assign the actual DATA_TYPE string to the appropriate row.
+ //
+ while (columnSelectRS.next()) {
+ String selectedTableName = columnSelectRS.getString("TABLE_NAME");
+ String selectedColumnName = columnSelectRS.getString("COLUMN_NAME");
+ String actualDataType = columnSelectRS.getString("DATA_TYPE");
+ for (CachedRow row : returnList) {
+ String rowTableName = row.getString("TABLE_NAME");
+ String rowColumnName = row.getString("COLUMN_NAME");
+ String rowTypeName = row.getString("TYPE_NAME");
+ int rowDataType = row.getInt("DATA_TYPE");
+ if (rowTableName.equalsIgnoreCase(selectedTableName) &&
+ rowColumnName.equalsIgnoreCase(selectedColumnName) &&
+ rowTypeName.equalsIgnoreCase("datetime") &&
+ rowDataType == Types.OTHER &&
+ !rowTypeName.equalsIgnoreCase(actualDataType)) {
+ row.set("TYPE_NAME", actualDataType);
+ row.set("DATA_TYPE", Types.TIMESTAMP);
+ break;
+ }
+ }
+ }
+ } catch (SQLException sqle) {
+ //
+ // Do not stop
+ //
+ }
+ finally {
+ JdbcUtil.closeStatement(statement);
+ }
+ }
+
+ protected boolean shouldReturnEmptyColumns(SQLException e) {
+ return e.getMessage().contains("references invalid table"); //view with table already dropped. Act like it has no columns.
+ }
+
+ protected List oracleQuery(boolean bulk) throws DatabaseException, SQLException {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+ boolean collectIdentityData = database.getDatabaseMajorVersion() >= OracleDatabase.ORACLE_12C_MAJOR_VERSION;
+
+ String sql = "select NULL AS TABLE_CAT, OWNER AS TABLE_SCHEM, 'NO' as IS_AUTOINCREMENT, cc.COMMENTS AS REMARKS," +
+ "OWNER, TABLE_NAME, COLUMN_NAME, DATA_TYPE AS DATA_TYPE_NAME, DATA_TYPE_MOD, DATA_TYPE_OWNER, " +
+ // note: oracle reports DATA_LENGTH=4*CHAR_LENGTH when using VARCHAR( CHAR ), thus BYTEs
+ "DECODE (c.data_type, 'CHAR', 1, 'VARCHAR2', 12, 'NUMBER', 3, 'LONG', -1, 'DATE', " + "93" + ", 'RAW', -3, 'LONG RAW', -4, 'BLOB', 2004, 'CLOB', 2005, 'BFILE', -13, 'FLOAT', 6, 'TIMESTAMP(6)', 93, 'TIMESTAMP(6) WITH TIME ZONE', -101, 'TIMESTAMP(6) WITH LOCAL TIME ZONE', -102, 'INTERVAL YEAR(2) TO MONTH', -103, 'INTERVAL DAY(2) TO SECOND(6)', -104, 'BINARY_FLOAT', 100, 'BINARY_DOUBLE', 101, 'XMLTYPE', 2009, 1111) AS data_type, " +
+ "DECODE( CHAR_USED, 'C',CHAR_LENGTH, DATA_LENGTH ) as DATA_LENGTH, " +
+ "DATA_PRECISION, DATA_SCALE, NULLABLE, COLUMN_ID as ORDINAL_POSITION, DEFAULT_LENGTH, " +
+ "DATA_DEFAULT, " +
+ "NUM_BUCKETS, CHARACTER_SET_NAME, " +
+ "CHAR_COL_DECL_LENGTH, CHAR_LENGTH, " +
+ "CHAR_USED, VIRTUAL_COLUMN ";
+ if (collectIdentityData) {
+ sql += ", DEFAULT_ON_NULL, IDENTITY_COLUMN, ic.GENERATION_TYPE ";
+ }
+ sql += "FROM ALL_TAB_COLS c " +
+ "JOIN ALL_COL_COMMENTS cc USING ( OWNER, TABLE_NAME, COLUMN_NAME ) ";
+ if (collectIdentityData) {
+ sql += "LEFT JOIN ALL_TAB_IDENTITY_COLS ic USING (OWNER, TABLE_NAME, COLUMN_NAME ) ";
+ }
+ if (!bulk || getAllCatalogsStringScratchData() == null) {
+ sql += "WHERE OWNER='" + jdbcSchemaName + "' AND hidden_column='NO'";
+ } else {
+ sql += "WHERE OWNER IN ('" + jdbcSchemaName + "', " + getAllCatalogsStringScratchData() + ") AND hidden_column='NO'";
+ }
+
+ if (!bulk) {
+ if (tableName != null) {
+ sql += " AND TABLE_NAME='" + database.escapeStringForDatabase(tableName) + "'";
+ }
+ if (columnName != null) {
+ sql += " AND COLUMN_NAME='" + database.escapeStringForDatabase(columnName) + "'";
+ }
+ }
+ sql += " AND " + ((OracleDatabase) database).getSystemTableWhereClause("TABLE_NAME");
+ sql += " ORDER BY OWNER, TABLE_NAME, c.COLUMN_ID";
+
+ return this.executeAndExtract(sql, database);
+ }
+
+
+ protected List mssqlQuery(boolean bulk) throws DatabaseException, SQLException {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ String databaseName = StringUtil.trimToNull(database.correctObjectName(catalogAndSchema.getCatalogName(), Catalog.class));
+ String dbIdParam;
+ String databasePrefix;
+ if (databaseName == null) {
+ databasePrefix = "";
+ dbIdParam = "";
+ } else {
+ dbIdParam = ", db_id('" + databaseName + "')";
+ databasePrefix = "[" + databaseName + "].";
+ }
+
+ String sql = "select " +
+ "db_name(" + (databaseName == null ? "" : "db_id('" + databaseName + "')") + ") AS TABLE_CAT, " +
+ "object_schema_name(c.object_id" + dbIdParam + ") AS TABLE_SCHEM, " +
+ "object_name(c.object_id" + dbIdParam + ") AS TABLE_NAME, " +
+ "c.name AS COLUMN_NAME, " +
+ "is_filestream AS IS_FILESTREAM, " +
+ "is_rowguidcol AS IS_ROWGUIDCOL, " +
+ "CASE WHEN c.is_identity = 'true' THEN 'YES' ELSE 'NO' END as IS_AUTOINCREMENT, " +
+ "{REMARKS_COLUMN_PLACEHOLDER}" +
+ "t.name AS TYPE_NAME, " +
+ "dc.name as COLUMN_DEF_NAME, " +
+ "dc.definition as COLUMN_DEF, " +
+ // data type mapping from https://msdn.microsoft.com/en-us/library/ms378878(v=sql.110).aspx
+ "CASE t.name " +
+ "WHEN 'bigint' THEN " + java.sql.Types.BIGINT + " " +
+ "WHEN 'binary' THEN " + java.sql.Types.BINARY + " " +
+ "WHEN 'bit' THEN " + java.sql.Types.BIT + " " +
+ "WHEN 'char' THEN " + java.sql.Types.CHAR + " " +
+ "WHEN 'date' THEN " + java.sql.Types.DATE + " " +
+ "WHEN 'datetime' THEN " + java.sql.Types.TIMESTAMP + " " +
+ "WHEN 'datetime2' THEN " + java.sql.Types.TIMESTAMP + " " +
+ "WHEN 'datetimeoffset' THEN -155 " +
+ "WHEN 'decimal' THEN " + java.sql.Types.DECIMAL + " " +
+ "WHEN 'float' THEN " + java.sql.Types.DOUBLE + " " +
+ "WHEN 'image' THEN " + java.sql.Types.LONGVARBINARY + " " +
+ "WHEN 'int' THEN " + java.sql.Types.INTEGER + " " +
+ "WHEN 'money' THEN " + java.sql.Types.DECIMAL + " " +
+ "WHEN 'nchar' THEN " + java.sql.Types.NCHAR + " " +
+ "WHEN 'ntext' THEN " + java.sql.Types.LONGNVARCHAR + " " +
+ "WHEN 'numeric' THEN " + java.sql.Types.NUMERIC + " " +
+ "WHEN 'nvarchar' THEN " + java.sql.Types.NVARCHAR + " " +
+ "WHEN 'real' THEN " + Types.REAL + " " +
+ "WHEN 'smalldatetime' THEN " + java.sql.Types.TIMESTAMP + " " +
+ "WHEN 'smallint' THEN " + java.sql.Types.SMALLINT + " " +
+ "WHEN 'smallmoney' THEN " + java.sql.Types.DECIMAL + " " +
+ "WHEN 'text' THEN " + java.sql.Types.LONGVARCHAR + " " +
+ "WHEN 'time' THEN " + java.sql.Types.TIME + " " +
+ "WHEN 'timestamp' THEN " + java.sql.Types.BINARY + " " +
+ "WHEN 'tinyint' THEN " + java.sql.Types.TINYINT + " " +
+ "WHEN 'udt' THEN " + java.sql.Types.VARBINARY + " " +
+ "WHEN 'uniqueidentifier' THEN " + java.sql.Types.CHAR + " " +
+ "WHEN 'varbinary' THEN " + java.sql.Types.VARBINARY + " " +
+ "WHEN 'varbinary(max)' THEN " + java.sql.Types.VARBINARY + " " +
+ "WHEN 'varchar' THEN " + java.sql.Types.VARCHAR + " " +
+ "WHEN 'varchar(max)' THEN " + java.sql.Types.VARCHAR + " " +
+ "WHEN 'xml' THEN " + java.sql.Types.LONGVARCHAR + " " +
+ "WHEN 'LONGNVARCHAR' THEN " + java.sql.Types.SQLXML + " " +
+ "ELSE " + Types.OTHER + " END AS DATA_TYPE, " +
+ "CASE WHEN c.is_nullable = 'true' THEN 1 ELSE 0 END AS NULLABLE, " +
+ "10 as NUM_PREC_RADIX, " +
+ "c.column_id as ORDINAL_POSITION, " +
+ "c.scale as DECIMAL_DIGITS, " +
+ "c.max_length as COLUMN_SIZE, " +
+ "c.precision as DATA_PRECISION, " +
+ "c.is_computed as IS_COMPUTED " +
+ "FROM " + databasePrefix + "sys.columns c " +
+ "inner join " + databasePrefix + "sys.types t on c.user_type_id=t.user_type_id " +
+ "{REMARKS_JOIN_PLACEHOLDER}" +
+ "left outer join " + databasePrefix + "sys.default_constraints dc on dc.parent_column_id = c.column_id AND dc.parent_object_id=c.object_id AND type_desc='DEFAULT_CONSTRAINT' " +
+ "WHERE object_schema_name(c.object_id" + dbIdParam + ")='" + ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema) + "'";
+
+
+ if (!bulk) {
+ if (tableName != null) {
+ sql += " and object_name(c.object_id" + dbIdParam + ")='" + database.escapeStringForDatabase(tableName) + "'";
+ }
+ if (columnName != null) {
+ sql += " and c.name='" + database.escapeStringForDatabase(columnName) + "'";
+ }
+ }
+ sql += "order by object_schema_name(c.object_id" + dbIdParam + "), object_name(c.object_id" + dbIdParam + "), c.column_id";
+
+
+ // sys.extended_properties is added to Azure on V12: https://feedback.azure.com/forums/217321-sql-database/suggestions/6549815-add-sys-extended-properties-for-meta-data-support
+ if ((!((MSSQLDatabase) database).isAzureDb()) // Either NOT AzureDB (=SQL Server 2008 or higher)
+ || (database.getDatabaseMajorVersion() >= 12)) { // or at least AzureDB v12
+ // SQL Server 2005 or later
+ // https://technet.microsoft.com/en-us/library/ms177541.aspx
+ sql = sql.replace("{REMARKS_COLUMN_PLACEHOLDER}", "CAST([ep].[value] AS [nvarchar](MAX)) AS [REMARKS], ");
+ sql = sql.replace("{REMARKS_JOIN_PLACEHOLDER}", "left outer join " + databasePrefix + "[sys].[extended_properties] AS [ep] ON [ep].[class] = 1 " +
+ "AND [ep].[major_id] = c.object_id " +
+ "AND [ep].[minor_id] = column_id " +
+ "AND [ep].[name] = 'MS_Description' ");
+ } else {
+ sql = sql.replace("{REMARKS_COLUMN_PLACEHOLDER}", "");
+ sql = sql.replace("{REMARKS_JOIN_PLACEHOLDER}", "");
+ }
+
+ List rows = this.executeAndExtract(sql, database);
+
+ for (CachedRow row : rows) {
+ String typeName = row.getString("TYPE_NAME");
+ if ("nvarchar".equals(typeName) || "nchar".equals(typeName)) {
+ Integer size = row.getInt("COLUMN_SIZE");
+ if (size > 0) {
+ row.set("COLUMN_SIZE", size / 2);
+ }
+ } else if ((row.getInt("DATA_PRECISION") != null) && (row.getInt("DATA_PRECISION") > 0)) {
+ row.set("COLUMN_SIZE", row.getInt("DATA_PRECISION"));
+ }
+ }
+
+ return rows;
+ }
+
+ @Override
+ protected List extract(ResultSet resultSet, boolean informixIndexTrimHint) throws SQLException {
+ List rows = super.extract(resultSet, informixIndexTrimHint);
+ if ((database instanceof MSSQLDatabase) && !userDefinedTypes.isEmpty()) { //UDT types in MSSQL don't take parameters
+ for (CachedRow row : rows) {
+ String dataType = (String) row.get("TYPE_NAME");
+ if (userDefinedTypes.contains(dataType.toLowerCase())) {
+ row.set("COLUMN_SIZE", null);
+ row.set("DECIMAL_DIGITS ", null);
+ }
+ }
+ }
+ return rows;
+ }
+ }
+
+ private class ForeignKeysResultSetCache extends ResultSetCache.UnionResultSetExtractor {
+ final String catalogName;
+ final String schemaName;
+ final String tableName;
+ final String fkName;
+
+ private ForeignKeysResultSetCache(Database database, String catalogName, String schemaName, String tableName, String fkName) {
+ super(database);
+ this.catalogName = catalogName;
+ this.schemaName = schemaName;
+ this.tableName = tableName;
+ this.fkName = fkName;
+ }
+
+ @Override
+ public ResultSetCache.RowData rowKeyParameters(CachedRow row) {
+ return new ResultSetCache.RowData(row.getString("FKTABLE_CAT"), row.getString("FKTABLE_SCHEM"), database, row.getString("FKTABLE_NAME"), row.getString("FK_NAME"));
+ }
+
+ @Override
+ public ResultSetCache.RowData wantedKeyParameters() {
+ return new ResultSetCache.RowData(catalogName, schemaName, database, tableName, fkName);
+ }
+
+ @Override
+ public boolean bulkContainsSchema(String schemaKey) {
+ return database instanceof OracleDatabase;
+ }
+
+ @Override
+ public String getSchemaKey(CachedRow row) {
+ return row.getString("FKTABLE_SCHEM");
+ }
+
+ @Override
+ public List fastFetch() throws SQLException, DatabaseException {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ String jdbcCatalogName = ((AbstractJdbcDatabase) database).getJdbcCatalogName(catalogAndSchema);
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+
+ if (database instanceof DB2Database) {
+ if (database.getDatabaseProductName().startsWith("DB2 UDB for AS/400")) {
+ return executeAndExtract(getDB2ForAs400Sql(jdbcSchemaName, tableName), database);
+ }
+ return querytDB2Luw(jdbcSchemaName, tableName);
+ } else if (database instanceof Db2zDatabase) {
+ return queryDb2Zos(catalogAndSchema, tableName);
+ } else {
+ List tables = new ArrayList<>();
+ if (tableName == null) {
+ for (CachedRow row : getTables(jdbcCatalogName, jdbcSchemaName, null)) {
+ tables.add(row.getString("TABLE_NAME"));
+ }
+ } else {
+ tables.add(tableName);
+ }
+
+ List returnList = new ArrayList<>();
+ for (String foundTable : tables) {
+ if (database instanceof OracleDatabase) {
+ throw new RuntimeException("Should have bulk selected");
+ } else {
+ returnList.addAll(extract(databaseMetaData.getImportedKeys(jdbcCatalogName, jdbcSchemaName, foundTable)));
+ }
+ }
+
+ return returnList;
+ }
+ }
+
+ @Override
+ public List bulkFetch() throws SQLException, DatabaseException {
+ if (database instanceof OracleDatabase) {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+ String sql = getOracleSql(jdbcSchemaName);
+ return executeAndExtract(sql, database);
+ } else if (database instanceof DB2Database) {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+ if (database.getDatabaseProductName().startsWith("DB2 UDB for AS/400")) {
+ return executeAndExtract(getDB2ForAs400Sql(jdbcSchemaName, null), database);
+ }
+ return querytDB2Luw(jdbcSchemaName, null);
+ } else if (database instanceof Db2zDatabase) {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+ return queryDb2Zos(catalogAndSchema, null);
+ } else if (database instanceof MSSQLDatabase) {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+ String sql = getMSSQLSql(jdbcSchemaName, tableName);
+ return executeAndExtract(sql, database);
+ } else {
+ throw new RuntimeException("Cannot bulk select");
+ }
+ }
+
+ protected String getOracleSql(String jdbcSchemaName) {
+ String sql = "SELECT /*+rule*/" +
+ " NULL AS pktable_cat, " +
+ " p.owner as pktable_schem, " +
+ " p.table_name as pktable_name, " +
+ " pc.column_name as pkcolumn_name, " +
+ " NULL as fktable_cat, " +
+ " f.owner as fktable_schem, " +
+ " f.table_name as fktable_name, " +
+ " fc.column_name as fkcolumn_name, " +
+ " fc.position as key_seq, " +
+ " NULL as update_rule, " +
+ " decode (f.delete_rule, 'CASCADE', 0, 'SET NULL', 2, 1) as delete_rule, " +
+ " f.constraint_name as fk_name, " +
+ " p.constraint_name as pk_name, " +
+ " decode(f.deferrable, 'DEFERRABLE', 5, 'NOT DEFERRABLE', 7, 'DEFERRED', 6) deferrability, " +
+ " f.validated as fk_validate " +
+ "FROM " +
+ "all_cons_columns pc " +
+ "INNER JOIN all_constraints p " +
+ "ON pc.owner = p.owner " +
+ "AND pc.constraint_name = p.constraint_name " +
+ "INNER JOIN all_constraints f " +
+ "ON pc.owner = f.r_owner " +
+ "AND pc.constraint_name = f.r_constraint_name " +
+ "INNER JOIN all_cons_columns fc " +
+ "ON fc.owner = f.owner " +
+ "AND fc.constraint_name = f.constraint_name " +
+ "AND fc.position = pc.position ";
+ if (getAllCatalogsStringScratchData() == null) {
+ sql += "WHERE f.owner = '" + jdbcSchemaName + "' ";
+ } else {
+ sql += "WHERE f.owner IN ('" + jdbcSchemaName + "', " + getAllCatalogsStringScratchData() + ") ";
+ }
+ sql += "AND p.constraint_type in ('P', 'U') " +
+ "AND f.constraint_type = 'R' " +
+ "AND p.table_name NOT LIKE 'BIN$%' " +
+ "ORDER BY fktable_schem, fktable_name, key_seq";
+ return sql;
+ }
+
+ protected String getMSSQLSql(String jdbcSchemaName, String tableName) {
+ //comes from select object_definition(object_id('sp_fkeys'))
+ return "select " +
+ "convert(sysname,db_name()) AS PKTABLE_CAT, " +
+ "convert(sysname,schema_name(o1.schema_id)) AS PKTABLE_SCHEM, " +
+ "convert(sysname,o1.name) AS PKTABLE_NAME, " +
+ "convert(sysname,c1.name) AS PKCOLUMN_NAME, " +
+ "convert(sysname,db_name()) AS FKTABLE_CAT, " +
+ "convert(sysname,schema_name(o2.schema_id)) AS FKTABLE_SCHEM, " +
+ "convert(sysname,o2.name) AS FKTABLE_NAME, " +
+ "convert(sysname,c2.name) AS FKCOLUMN_NAME, " +
+ "isnull(convert(smallint,k.constraint_column_id), convert(smallint,0)) AS KEY_SEQ, " +
+ "convert(smallint, case ObjectProperty(f.object_id, 'CnstIsUpdateCascade') when 1 then 0 else 1 end) AS UPDATE_RULE, " +
+ "convert(smallint, case ObjectProperty(f.object_id, 'CnstIsDeleteCascade') when 1 then 0 else 1 end) AS DELETE_RULE, " +
+ "convert(sysname,object_name(f.object_id)) AS FK_NAME, " +
+ "convert(sysname,i.name) AS PK_NAME, " +
+ "convert(smallint, 7) AS DEFERRABILITY " +
+ "from " +
+ "sys.objects o1, " +
+ "sys.objects o2, " +
+ "sys.columns c1, " +
+ "sys.columns c2, " +
+ "sys.foreign_keys f inner join " +
+ "sys.foreign_key_columns k on (k.constraint_object_id = f.object_id) inner join " +
+ "sys.indexes i on (f.referenced_object_id = i.object_id and f.key_index_id = i.index_id) " +
+ "where " +
+ "o1.object_id = f.referenced_object_id and " +
+ "o2.object_id = f.parent_object_id and " +
+ "c1.object_id = f.referenced_object_id and " +
+ "c2.object_id = f.parent_object_id and " +
+ "c1.column_id = k.referenced_column_id and " +
+ "c2.column_id = k.parent_column_id and " +
+ "((object_schema_name(o1.object_id)='" + jdbcSchemaName + "'" +
+ " and convert(sysname,schema_name(o2.schema_id))='" + jdbcSchemaName + "' and " +
+ "convert(sysname,o2.name)='" + tableName + "' ) or ( convert(sysname,schema_name" +
+ "(o2.schema_id))='" + jdbcSchemaName + "' and convert(sysname,o2.name)='" + tableName +
+ "' )) order by 5, 6, 7, 9, 8";
+ }
+
+ private List querytDB2Luw(String jdbcSchemaName, String tableName) throws DatabaseException, SQLException {
+ List parameters = new ArrayList<>(2);
+ StringBuilder sql = new StringBuilder ("SELECT " +
+ " pk_col.tabschema AS pktable_cat, " +
+ " pk_col.tabname as pktable_name, " +
+ " pk_col.colname as pkcolumn_name, " +
+ " fk_col.tabschema as fktable_cat, " +
+ " fk_col.tabname as fktable_name, " +
+ " fk_col.colname as fkcolumn_name, " +
+ " fk_col.colseq as key_seq, " +
+ " decode (ref.updaterule, 'A', 3, 'R', 1, 1) as update_rule, " +
+ " decode (ref.deleterule, 'A', 3, 'C', 0, 'N', 2, 'R', 1, 1) as delete_rule, " +
+ " ref.constname as fk_name, " +
+ " ref.refkeyname as pk_name, " +
+ " 7 as deferrability " +
+ "FROM " +
+ "syscat.references ref " +
+ "join syscat.keycoluse fk_col on ref.constname=fk_col.constname and ref.tabschema=fk_col.tabschema and ref.tabname=fk_col.tabname " +
+ "join syscat.keycoluse pk_col on ref.refkeyname=pk_col.constname and ref.reftabschema=pk_col.tabschema and ref.reftabname=pk_col.tabname and pk_col.colseq=fk_col.colseq " +
+ "WHERE ref.tabschema = ? ");
+ parameters.add(jdbcSchemaName);
+ if (tableName != null) {
+ sql.append("and fk_col.tabname = ? ");
+ parameters.add(tableName);
+ }
+ sql.append("ORDER BY fk_col.colseq");
+ return executeAndExtract(database, sql.toString(), parameters.toArray());
+ }
+
+ private String getDB2ForAs400Sql(String jdbcSchemaName, String tableName) {
+ return "SELECT " +
+ "pktable_cat, " +
+ "pktable_name, " +
+ "pkcolumn_name, " +
+ "fktable_cat, " +
+ "fktable_name, " +
+ "fkcolumn_name, " +
+ "key_seq, " +
+ "update_rule, " +
+ "delete_rule, " +
+ "fk_name, " +
+ "pk_name, " +
+ "deferrability " +
+ "FROM " +
+ "sysibm.SQLFORKEYS " +
+ "WHERE " +
+ "FKTABLE_SCHEM = '" + jdbcSchemaName + "' " +
+ "AND FKTABLE_NAME = '" + tableName + "'";
+ }
+
+ protected List queryDb2Zos(CatalogAndSchema catalogAndSchema, String tableName) throws DatabaseException, SQLException {
+
+ List parameters = new ArrayList<>(2);
+ StringBuilder sql = new StringBuilder("SELECT " +
+ " ref.REFTBCREATOR AS pktable_cat, " +
+ " ref.REFTBNAME as pktable_name, " +
+ " pk_col.colname as pkcolumn_name, " +
+ " ref.CREATOR as fktable_cat, " +
+ " ref.TBNAME as fktable_name, " +
+ " fk_col.colname as fkcolumn_name, " +
+ " fk_col.colseq as key_seq, " +
+ " decode (ref.deleterule, 'A', 3, 'C', 0, 'N', 2, 'R', 1, 1) as delete_rule, " +
+ " ref.relname as fk_name, " +
+ " pk_col.colname as pk_name, " +
+ " 7 as deferrability " +
+ "FROM " +
+ "SYSIBM.SYSRELS ref " +
+ "join SYSIBM.SYSFOREIGNKEYS fk_col " +
+ "on ref.relname = fk_col.RELNAME " +
+ "and ref.CREATOR = fk_col.CREATOR " +
+ "and ref.TBNAME = fk_col.TBNAME " +
+ "join SYSIBM.SYSKEYCOLUSE pk_col " +
+ "on ref.REFTBCREATOR = pk_col.TBCREATOR " +
+ "and ref.REFTBNAME = pk_col.TBNAME " +
+ "and pk_col.colseq=fk_col.colseq " +
+ "WHERE ref.CREATOR = ? ");
+ parameters.add(((AbstractJdbcDatabase) CachingDatabaseMetaData.this.database).getJdbcSchemaName(catalogAndSchema));
+ if (tableName != null) {
+ sql.append("AND ref.TBNAME = ? ");
+ parameters.add(tableName);
+ }
+ sql.append("ORDER BY fk_col.colseq");
+
+ return executeAndExtract(CachingDatabaseMetaData.this.database, sql.toString(), parameters.toArray());
+ }
+
+ @Override
+ protected boolean shouldBulkSelect(String schemaKey, ResultSetCache resultSetCache) {
+ if (database instanceof AbstractDb2Database || database instanceof MSSQLDatabase) {
+ return super.shouldBulkSelect(schemaKey, resultSetCache); //can bulk and fast fetch
+ } else {
+ return database instanceof OracleDatabase; //oracle is slow, always bulk select while you are at it. Other databases need to go through all tables.
+ }
+ }
+ }
+
+ private class GetNotNullConstraintsResultSetCache extends ResultSetCache.SingleResultSetExtractor {
+ final String catalogName;
+ final String schemaName;
+ final String tableName;
+
+ private GetNotNullConstraintsResultSetCache(Database database, String catalogName, String schemaName, String tableName) {
+ super(database);
+ this.catalogName = catalogName;
+ this.schemaName = schemaName;
+ this.tableName = tableName;
+ }
+
+ @Override
+ public ResultSetCache.RowData rowKeyParameters(CachedRow row) {
+ return new ResultSetCache.RowData(row.getString("TABLE_CAT"), row.getString("TABLE_SCHEMA"),
+ database, row.getString("TABLE_NAME"));
+ }
+
+ @Override
+ public ResultSetCache.RowData wantedKeyParameters() {
+ return new ResultSetCache.RowData(catalogName, schemaName, database, tableName);
+ }
+
+ @Override
+ public boolean bulkContainsSchema(String schemaKey) {
+ return database instanceof OracleDatabase;
+ }
+
+ @Override
+ public String getSchemaKey(CachedRow row) {
+ return row.getString("TABLE_SCHEMA");
+ }
+
+ @Override
+ protected boolean shouldBulkSelect(String schemaKey, ResultSetCache resultSetCache) {
+ LiquibaseTableNamesFactory liquibaseTableNamesFactory = Scope.getCurrentScope().getSingleton(LiquibaseTableNamesFactory.class);
+ List liquibaseTableNames = liquibaseTableNamesFactory.getLiquibaseTableNames(database);
+ return liquibaseTableNames.stream().noneMatch(tableName::equalsIgnoreCase);
+ }
+
+ @Override
+ public List fastFetchQuery() throws SQLException, DatabaseException {
+ if (database instanceof OracleDatabase) {
+ return oracleQuery(false);
+ }
+ return Collections.emptyList();
+ }
+
+ @Override
+ public List bulkFetchQuery() throws SQLException, DatabaseException {
+ if (database instanceof OracleDatabase) {
+ return oracleQuery(true);
+ }
+ return Collections.emptyList();
+ }
+
+ private List oracleQuery(boolean bulk) throws DatabaseException, SQLException {
+ CatalogAndSchema catalogAndSchema = new CatalogAndSchema(catalogName, schemaName).customize(database);
+
+ String jdbcSchemaName = ((AbstractJdbcDatabase) database).getJdbcSchemaName(catalogAndSchema);
+ String jdbcTableName = database.escapeStringForDatabase(tableName);
+ String sqlToSelectNotNullConstraints = "SELECT NULL AS TABLE_CAT, atc.OWNER AS TABLE_SCHEMA, atc.OWNER, atc.TABLE_NAME, " +
+ "atc.COLUMN_NAME, NULLABLE, ac.VALIDATED as VALIDATED, ac.SEARCH_CONDITION, ac.CONSTRAINT_NAME " +
+ "FROM ALL_TAB_COLS atc " +
+ "JOIN all_cons_columns acc ON atc.OWNER = acc.OWNER AND atc.TABLE_NAME = acc.TABLE_NAME AND atc.COLUMN_NAME = acc.COLUMN_NAME " +
+ "JOIN all_constraints ac ON atc.OWNER = ac.OWNER AND atc.TABLE_NAME = ac.TABLE_NAME AND acc.CONSTRAINT_NAME = ac.CONSTRAINT_NAME ";
+
+ if (!bulk || getAllCatalogsStringScratchData() == null) {
+ sqlToSelectNotNullConstraints += " WHERE atc.OWNER='" + jdbcSchemaName + "' AND atc.hidden_column='NO' AND ac.CONSTRAINT_TYPE='C' and ac.search_condition is not null ";
+ } else {
+ sqlToSelectNotNullConstraints += " WHERE atc.OWNER IN ('" + jdbcSchemaName + "', " + getAllCatalogsStringScratchData() + ") "
+ + " AND atc.hidden_column='NO' AND ac.CONSTRAINT_TYPE='C' and ac.search_condition is not null ";
+ }
+
+ sqlToSelectNotNullConstraints += (!bulk && tableName != null && !tableName.isEmpty()) ? " AND atc.TABLE_NAME='" + jdbcTableName + "'" : "";
+
+ return this.executeAndExtract(sqlToSelectNotNullConstraints, database);
+ }
+
+ @Override
+ protected List extract(ResultSet resultSet, boolean informixIndexTrimHint) throws SQLException {
+ List cachedRowList = new ArrayList<>();
+ if (!(database instanceof OracleDatabase)) {
+ return cachedRowList;
+ }
+
+ resultSet.setFetchSize(database.getFetchSize());
+
+ try {
+ List