This is an automated email from the ASF dual-hosted git repository.
terrymanu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 68c4600f080 Stabilize Ubuntu nativeTest CI under GraalVM Native Image
(#38880)
68c4600f080 is described below
commit 68c4600f080acf97f233fece980bc5d839b337ed
Author: Hengqian Ling <[email protected]>
AuthorDate: Sun Jun 21 15:43:59 2026 +0800
Stabilize Ubuntu nativeTest CI under GraalVM Native Image (#38880)
---
.../graalvm-native-image/development/_index.cn.md | 41 -
.../graalvm-native-image/development/_index.en.md | 42 -
.../startup/graalvm-native-image.cn.md | 2 +-
.../startup/graalvm-native-image.en.md | 2 +-
.../reachability-metadata.json | 908 +++++++++++----------
.../natived/commons/util/ProxyTestingServer.java | 56 +-
.../test/natived/commons/util/ResourceUtils.java | 2 +
.../natived/jdbc/modes/cluster/ZookeeperTest.java | 32 +-
.../src/test/resources/testcontainers.properties | 1 +
9 files changed, 524 insertions(+), 562 deletions(-)
diff --git
a/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.cn.md
b/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.cn.md
index 3454172fe95..481481ba127 100644
---
a/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.cn.md
+++
b/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.cn.md
@@ -222,47 +222,6 @@ cd ./shardingsphere/
## 已知限制
-### `reachability-metadata.json` 限制
-
-受 https://github.com/apache/shardingsphere/issues/33206 影响，
-开发者执行 `./mvnw -PgenerateMetadata -T 1C -e clean test native:metadata-copy` 后，
-`infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json`
会生成不必要的包含绝对路径的 JSON 条目，
-
-对于 Ubuntu，类似如下，
-
-```json
-{
- "resources": [
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/mysql/"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/mysql//global.yaml"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/postgresql/"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/postgresql//global.yaml"
- }
- ]
-}
-```
-
-需要为 ShardingSphere 提交 PR 的贡献者应始终手动删除这些包含绝对路径的 JSON 条目，并等待
https://github.com/oracle/graal/issues/8417 被解决。
-
### 单元测试库限制
对于 `shardingsphere-test-native` 的 Maven Module，
diff --git
a/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.en.md
b/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.en.md
index af258665021..c393a605e36 100644
---
a/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.en.md
+++
b/docs/document/content/user-manual/shardingsphere-jdbc/graalvm-native-image/development/_index.en.md
@@ -229,48 +229,6 @@ developer should place it in the classpath of the
`shardingsphere-test-native` s
## Known limitations
-### `reachability-metadata.json` limitations
-
-Affected by https://github.com/apache/shardingsphere/issues/33206,
-after developers execute `./mvnw -PgenerateMetadata -T 1C -e clean test
native:metadata-copy`,
-`infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json`
will generate unnecessary JSON entries containing absolute paths.
-
-For Ubuntu, it is similar to the following,
-
-```json
-{
- "resources": [
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/mysql/"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/mysql//global.yaml"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/postgresql/"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader"
- },
- "glob":
"home/runner/work/shardingsphere/shardingsphere/test/native/src/test/resources/test-native/yaml/proxy/databases/postgresql//global.yaml"
- }
- ]
-}
-```
-
-Contributors who need to submit PRs for ShardingSphere should always manually
remove these JSON entries containing absolute paths
-and wait for https://github.com/oracle/graal/issues/8417 to be resolved.
-
### Unit test library limitations
For the Maven Module of `shardingsphere-test-native`,
diff --git
a/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.cn.md
b/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.cn.md
index e452542fb8c..561ef354f82 100644
---
a/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.cn.md
+++
b/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.cn.md
@@ -185,7 +185,7 @@ vfox install [email protected]
vfox use --global [email protected]
```
-当 Windows 弹出窗口，要求允许类似
`C:\users\lingh\.version-fox\cache\java\v-21.0.7-ms\java-21.0.7-ms\bin\java.exe`
路径的应用通过 Windows 防火墙时，
+当 Windows 弹出窗口，要求允许类似
`C:\users\shard\.version-fox\cache\java\v-21.0.7-ms\java-21.0.7-ms\bin\java.exe`
路径的应用通过 Windows 防火墙时，
应当批准。
背景参考
https://support.microsoft.com/en-us/windows/risks-of-allowing-apps-through-windows-firewall-654559af-3f54-3dcf-349f-71ccd90bcc5c
。
diff --git
a/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.en.md
b/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.en.md
index 7b5d8f49636..2a99d9db186 100644
---
a/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.en.md
+++
b/docs/document/content/user-manual/shardingsphere-proxy/startup/graalvm-native-image.en.md
@@ -189,7 +189,7 @@ vfox install [email protected]
vfox use --global [email protected]
```
-When Windows pops up a window asking you to allow an application with a path
like
`C:\users\lingh\.version-fox\cache\java\v-21.0.7-ms\java-21.0.7-ms\bin\java.exe`
to pass through Windows Firewall,
+When Windows pops up a window asking you to allow an application with a path
like
`C:\users\shard\.version-fox\cache\java\v-21.0.7-ms\java-21.0.7-ms\bin\java.exe`
to pass through Windows Firewall,
you should approve it.
Background reference
https://support.microsoft.com/en-us/windows/risks-of-allowing-apps-through-windows-firewall-654559af-3f54-3dcf-349f-71ccd90bcc5c
.
diff --git
a/infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json
b/infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json
index 2ccad039dad..26b18836254 100644
---
a/infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json
+++
b/infra/reachability-metadata/src/main/resources/META-INF/native-image/org.apache.shardingsphere/generated-reachability-metadata/reachability-metadata.json
@@ -335,7 +335,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistEnabledService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistService"
},
"type": "java.lang.Object"
},
@@ -430,12 +430,6 @@
},
"type": "java.lang.Readable"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.infra.metadata.database.schema.manager.SystemSchemaManager"
- },
- "type": "java.lang.Record"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.frontend.ShardingSphereProxy"
@@ -544,6 +538,21 @@
},
"type": "java.net.ServerSocket"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type": "java.net.Socket",
+ "methods": [
+ {
+ "name": "setOption",
+ "parameterTypes": [
+ "java.net.SocketOption",
+ "java.lang.Object"
+ ]
+ }
+ ]
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.expr.groovy.GroovyInlineExpressionParser"
@@ -562,6 +571,20 @@
},
"type": "java.net.URL"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type": "java.net.UnixDomainSocketAddress",
+ "methods": [
+ {
+ "name": "of",
+ "parameterTypes": [
+ "java.lang.String"
+ ]
+ }
+ ]
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
@@ -646,6 +669,20 @@
},
"type": "java.nio.charset.Charset"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type": "java.security.AccessController",
+ "methods": [
+ {
+ "name": "doPrivileged",
+ "parameterTypes": [
+ "java.security.PrivilegedExceptionAction"
+ ]
+ }
+ ]
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
@@ -678,6 +715,17 @@
},
"type": "java.sql.Date"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.mode.repository.standalone.jdbc.JDBCRepository"
+ },
+ "type": "java.sql.SQLException",
+ "fields": [
+ {
+ "name": "next"
+ }
+ ]
+ },
{
"condition": {
"typeReached": "org.apache.shardingsphere.infra.util.yaml.YamlEngine"
@@ -732,6 +780,12 @@
},
"type": "java.util.Iterator"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type": "java.util.List"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.expr.groovy.GroovyInlineExpressionParser"
@@ -1032,7 +1086,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.authority.distsql.parser.facade.AuthorityDistSQLParserFacade"
},
@@ -1123,18 +1177,6 @@
"type":
"org.apache.shardingsphere.authority.yaml.config.YamlAuthorityRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.authority.yaml.config.YamlAuthorityRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.authority.yaml.config.YamlAuthorityRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.metadata.manager.rule.DatabaseRuleConfigurationManager"
@@ -1309,19 +1351,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.broadcast.distsql.parser.facade.BroadcastDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.broadcast.rule.changed.BroadcastRuleChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.broadcast.rule.changed.BroadcastTableChangedProcessor"
},
@@ -1503,7 +1545,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.facade.CDCDistSQLParserFacade"
},
@@ -1945,7 +1987,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.data.pipeline.scenario.migration.distsql.parser.facade.MigrationDistSQLParserFacade"
},
@@ -1957,7 +1999,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.clickhouse.jdbcurl.ClickHouseConnectionPropertiesParser"
},
@@ -1969,7 +2011,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.firebird.jdbcurl.FirebirdConnectionPropertiesParser"
},
@@ -1999,13 +2041,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.infra.datasource.pool.props.validator.DataSourcePoolPropertiesValidator"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.h2.checker.H2DatabasePrivilegeChecker"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.h2.jdbcurl.H2ConnectionPropertiesParser"
},
@@ -2035,7 +2077,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.hive.jdbcurl.HiveConnectionPropertiesParser"
},
@@ -2077,19 +2119,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.infra.datasource.pool.props.validator.DataSourcePoolPropertiesValidator"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.mysql.checker.MySQLDatabasePrivilegeChecker"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.mysql.jdbcurl.MySQLConnectionPropertiesParser"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.mysql.jdbcurl.MySQLDefaultQueryPropertiesProvider"
},
@@ -2111,12 +2153,6 @@
},
"type":
"org.apache.shardingsphere.database.connector.mysql.metadata.database.system.MySQLSystemDatabase"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.database.connector.mysql.metadata.identifier.MySQLIdentifierCaseRuleProvider"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.props.TypedPropertyValue"
@@ -2125,13 +2161,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.infra.datasource.pool.props.validator.DataSourcePoolPropertiesValidator"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.opengauss.checker.OpenGaussDatabasePrivilegeChecker"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.opengauss.jdbcurl.OpenGaussConnectionPropertiesParser"
},
@@ -2153,12 +2189,6 @@
},
"type":
"org.apache.shardingsphere.database.connector.opengauss.metadata.database.system.OpenGaussSystemDatabase"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.database.connector.opengauss.metadata.identifier.OpenGaussIdentifierCaseRuleProvider"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.props.TypedPropertyValue"
@@ -2167,7 +2197,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.oracle.jdbcurl.OracleConnectionPropertiesParser"
},
@@ -2183,12 +2213,6 @@
},
"type":
"org.apache.shardingsphere.database.connector.oracle.metadata.database.OracleDatabaseMetaData"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.database.connector.oracle.metadata.identifier.OracleIdentifierCaseRuleProvider"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.props.TypedPropertyValue"
@@ -2197,13 +2221,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.infra.datasource.pool.props.validator.DataSourcePoolPropertiesValidator"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.postgresql.checker.PostgreSQLDatabasePrivilegeChecker"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.postgresql.jdbcurl.PostgreSQLConnectionPropertiesParser"
},
@@ -2225,12 +2249,6 @@
},
"type":
"org.apache.shardingsphere.database.connector.postgresql.metadata.database.system.PostgreSQLSystemDatabase"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.database.connector.postgresql.metadata.identifier.PostgreSQLIdentifierCaseRuleProvider"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.props.TypedPropertyValue"
@@ -2239,7 +2257,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.presto.jdbcurl.PrestoConnectionPropertiesParser"
},
@@ -2263,7 +2281,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.sql92.jdbcurl.SQL92ConnectionPropertiesParser"
},
@@ -2275,7 +2293,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.database.connector.sql92.sqlserver.jdbcurl.SQLServerConnectionPropertiesParser"
},
@@ -2493,6 +2511,12 @@
},
"type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.database.DatabaseTypeEngine"
@@ -2505,12 +2529,30 @@
},
"type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabaseFactory"
+ },
+ "type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabasesFactory"
+ },
+ "type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder"
},
"type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.persist.service.StandaloneMetaDataManagerPersistService"
+ },
+ "type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.repository.standalone.jdbc.JDBCRepository"
@@ -2565,6 +2607,12 @@
},
"type": "org.apache.shardingsphere.driver.ShardingSphereDriver"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.resultset.ShardingSphereResultSet"
+ },
+ "type":
"org.apache.shardingsphere.driver.jdbc.core.resultset.MySQLResultSetValueConverter"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.encrypt.checker.config.EncryptRuleConfigurationChecker"
@@ -2741,19 +2789,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.encrypt.distsql.parser.facade.EncryptDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.encrypt.rule.changed.EncryptTableChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.encrypt.rule.changed.EncryptorChangedProcessor"
},
@@ -2853,7 +2901,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.globalclock.distsql.parser.facade.GlobalClockDistSQLParserFacade"
},
@@ -2938,36 +2986,12 @@
"type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfigurationBeanInfo"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
},
"type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfigurationBeanInfo"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfigurationCustomizer"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.globalclock.yaml.config.YamlGlobalClockRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
@@ -3138,6 +3162,24 @@
},
"type":
"org.apache.shardingsphere.infra.algorithm.keygen.snowflake.SnowflakeKeyGenerateAlgorithm"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.snowflake.SnowflakeKeyGenerateAlgorithm"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabaseFactory"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.snowflake.SnowflakeKeyGenerateAlgorithm"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabasesFactory"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.snowflake.SnowflakeKeyGenerateAlgorithm"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder"
@@ -3234,6 +3276,24 @@
},
"type":
"org.apache.shardingsphere.infra.algorithm.keygen.uuid.UUIDKeyGenerateAlgorithm"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.uuid.UUIDKeyGenerateAlgorithm"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabaseFactory"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.uuid.UUIDKeyGenerateAlgorithm"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabasesFactory"
+ },
+ "type":
"org.apache.shardingsphere.infra.algorithm.keygen.uuid.UUIDKeyGenerateAlgorithm"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder"
@@ -3380,13 +3440,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.mysql.MySQLSQLStatementContextWarpProvider"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.mysql.bind.MySQLSQLBindEngine"
},
@@ -3398,13 +3458,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.opengauss.OpenGaussSQLStatementContextWarpProvider"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.opengauss.bind.OpenGaussSQLBindEngine"
},
@@ -3422,25 +3482,25 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.postgresql.PostgreSQLSQLStatementContextWarpProvider"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.postgresql.bind.PostgreSQLSQLBindEngine"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.sqlserver.SQLServerSQLStatementContextWarpProvider"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.infra.binder.sqlserver.bind.SQLServerSQLBindEngine"
},
@@ -3926,18 +3986,6 @@
},
"type":
"org.apache.shardingsphere.infra.expr.literal.LiteralInlineExpressionParser"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.infra.instance.metadata.jdbc.JDBCInstanceMetaDataBuilder"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.infra.instance.metadata.proxy.ProxyInstanceMetaDataBuilder"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.persist.service.ClusterComputeNodePersistService"
@@ -3973,31 +4021,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
+ "typeReached":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.factory.PostgreSQLSelectAdminExecutorFactory"
},
- "type":
"org.apache.shardingsphere.infra.metadata.identifier.DefaultIdentifierCaseRuleProvider"
+ "type":
"org.apache.shardingsphere.infra.metadata.statistics.collector.opengauss.OpenGaussStatisticsCollector"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
+ "typeReached":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.factory.PostgreSQLSelectAdminExecutorFactory"
},
- "type":
"org.apache.shardingsphere.infra.metadata.statistics.builder.dialect.PostgreSQLStatisticsAppender"
+ "type":
"org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLStatisticsCollector"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.factory.PostgreSQLSelectAdminExecutorFactory"
- },
- "type":
"org.apache.shardingsphere.infra.metadata.statistics.collector.opengauss.OpenGaussStatisticsCollector"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.factory.PostgreSQLSelectAdminExecutorFactory"
- },
- "type":
"org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLStatisticsCollector"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLStatisticsCollector"
+ "typeReached":
"org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.PostgreSQLStatisticsCollector"
},
"type":
"org.apache.shardingsphere.infra.metadata.statistics.collector.postgresql.table.PostgreSQLPgClassTableStatisticsCollector"
},
@@ -4051,7 +4087,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type": "org.apache.shardingsphere.infra.util.yaml.YamlConfiguration"
},
@@ -4061,12 +4097,6 @@
},
"type":
"org.apache.shardingsphere.infra.yaml.config.pojo.rule.YamlGlobalRuleConfiguration"
},
- {
- "condition": {
- "typeReached": "org.apache.shardingsphere.infra.util.yaml.YamlEngine"
- },
- "type":
"org.apache.shardingsphere.infra.yaml.config.shortcut.YamlRuleConfigurationShortcuts"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableRowDataPersistService"
@@ -4083,18 +4113,6 @@
}
]
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableRowDataPersistService"
- },
- "type":
"org.apache.shardingsphere.infra.yaml.data.pojo.YamlRowStatisticsBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableRowDataPersistService"
- },
- "type":
"org.apache.shardingsphere.infra.yaml.data.pojo.YamlRowStatisticsCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.persist.service.ClusterMetaDataManagerPersistService"
@@ -4110,7 +4128,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistEnabledService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistService"
},
"type":
"org.apache.shardingsphere.infra.yaml.schema.pojo.YamlShardingSphereTable",
"methods": [
@@ -4476,19 +4494,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.mask.distsql.parser.facade.MaskDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.mask.rule.changed.MaskAlgorithmChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.mask.rule.changed.MaskTableChangedProcessor"
},
@@ -4528,12 +4546,6 @@
},
"type": "org.apache.shardingsphere.mode.deliver.DeliverEventSubscriber"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.DataChangedEventListenerRegistry"
@@ -4624,12 +4636,6 @@
},
"type":
"org.apache.shardingsphere.mode.manager.cluster.yaml.ClusterYamlPersistRepositoryConfigurationSwapper"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.persist.PersistServiceFacade"
@@ -4760,7 +4766,12 @@
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.TableChangedHandler"
},
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath"
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath",
+ "fields": [
+ {
+ "name": "databaseName"
+ }
+ ]
},
{
"condition": {
@@ -4826,13 +4837,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.factory.init.type.LocalConfigurationMetaDataContextsInitFactory"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.resource.StorageUnitManager"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.resource.StorageUnitManager"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.rule.DatabaseRuleConfigurationManager"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath"
},
@@ -4905,7 +4916,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistEnabledService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistService"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath",
"fields": [
@@ -4937,17 +4948,6 @@
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher"
- },
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath",
- "fields": [
- {
- "name": "databaseName"
- }
- ]
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.repository.cluster.zookeeper.ZookeeperRepository"
@@ -5231,6 +5231,18 @@
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.distsql.handler.engine.update.rdl.rule.engine.database.DatabaseRuleDefinitionExecuteEngine"
+ },
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.distsql.handler.engine.update.rdl.rule.engine.database.type.CreateDatabaseRuleOperator"
+ },
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.distsql.handler.executor.rdl.resource.RegisterStorageUnitExecutor"
@@ -5241,7 +5253,15 @@
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.TableChangedHandler"
},
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath",
+ "fields": [
+ {
+ "name": "database"
+ },
+ {
+ "name": "schemaName"
+ }
+ ]
},
{
"condition": {
@@ -5277,13 +5297,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.factory.init.type.LocalConfigurationMetaDataContextsInitFactory"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.resource.StorageUnitManager"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.resource.StorageUnitManager"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.rule.DatabaseRuleConfigurationManager"
+ },
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.manager.rule.DatabaseRuleItemManager"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
},
@@ -5309,7 +5335,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistEnabledService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistService"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath",
"fields": [
@@ -5347,20 +5373,6 @@
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher"
- },
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.SchemaMetaDataNodePath",
- "fields": [
- {
- "name": "database"
- },
- {
- "name": "schemaName"
- }
- ]
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.repository.cluster.zookeeper.ZookeeperRepository"
@@ -5395,7 +5407,15 @@
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata.TableChangedHandler"
},
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.TableMetaDataNodePath"
+ "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.TableMetaDataNodePath",
+ "fields": [
+ {
+ "name": "schema"
+ },
+ {
+ "name": "tableName"
+ }
+ ]
},
{
"condition": {
@@ -5431,7 +5451,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistEnabledService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.metadata.service.TableMetaDataPersistService"
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.TableMetaDataNodePath",
"fields": [
@@ -5455,20 +5475,6 @@
},
"type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.TableMetaDataNodePath"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher"
- },
- "type":
"org.apache.shardingsphere.mode.node.path.type.database.metadata.schema.TableMetaDataNodePath",
- "fields": [
- {
- "name": "schema"
- },
- {
- "name": "tableName"
- }
- ]
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.repository.cluster.zookeeper.ZookeeperRepository"
@@ -6134,6 +6140,20 @@
}
]
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.global.node.compute.type.ComputeNodeOnlineHandler"
+ },
+ "type":
"org.apache.shardingsphere.mode.node.path.type.global.node.compute.status.OnlineNodePath",
+ "fields": [
+ {
+ "name": "instanceId"
+ },
+ {
+ "name": "instanceType"
+ }
+ ]
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.DataChangedEventListenerRegistry"
@@ -6415,7 +6435,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.parser.distsql.parser.facade.SQLParserDistSQLParserFacade"
},
@@ -6492,36 +6512,12 @@
"type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfigurationBeanInfo"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
},
"type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfigurationBeanInfo"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfigurationCustomizer"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.parser.yaml.config.YamlSQLParserRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
@@ -6536,7 +6532,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.proxy.backend.firebird.handler.admin.FirebirdAdminExecutorCreator"
},
@@ -6866,7 +6862,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLAdminExecutorCreator"
},
@@ -6902,7 +6898,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.proxy.backend.opengauss.handler.admin.OpenGaussAdminExecutorCreator"
},
@@ -6920,7 +6916,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.PostgreSQLAdminExecutorCreator"
},
@@ -7202,7 +7198,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.readwritesplitting.distsql.parser.facade.ReadwriteSplittingDistSQLParserFacade"
},
@@ -7214,13 +7210,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.readwritesplitting.rule.changed.ReadwriteSplittingDataSourceChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.readwritesplitting.rule.changed.ReadwriteSplittingLoadBalancerChangedProcessor"
},
@@ -7600,31 +7596,31 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.shadow.distsql.parser.facade.ShadowDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.shadow.rule.changed.DefaultShadowAlgorithmNameChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.shadow.rule.changed.ShadowAlgorithmChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.shadow.rule.changed.ShadowDataSourceChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.shadow.rule.changed.ShadowTableChangedProcessor"
},
@@ -8641,85 +8637,85 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.sharding.distsql.parser.facade.ShardingDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.DefaultDatabaseShardingStrategyChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.DefaultKeyGenerateStrategyChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.DefaultShardingAuditorStrategyChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.DefaultShardingColumnChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.DefaultTableShardingStrategyChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.KeyGenerateStrategiesChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.KeyGeneratorChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingAlgorithmChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingAuditorChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingAutoTableChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingCacheChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingTableChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.rule.changed.ShardingTableReferenceChangedProcessor"
},
@@ -8893,13 +8889,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.rule.YamlTableRuleConfigurationBeanInfo"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.rule.YamlTableRuleConfigurationCustomizer"
},
@@ -8997,13 +8993,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.keygen.YamlKeyGenerateStrategyRuleConfigurationBeanInfo"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.keygen.YamlKeyGenerateStrategyRuleConfigurationCustomizer"
},
@@ -9025,12 +9021,25 @@
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
+ "allDeclaredFields": true
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "allDeclaredFields": true,
+ "allDeclaredFields": true
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.persist.service.StandaloneMetaDataManagerPersistService"
+ },
+ "type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
"methods": [
{
"name": "getComplex",
@@ -9052,7 +9061,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.persist.service.StandaloneMetaDataManagerPersistService"
+ "typeReached":
"org.apache.shardingsphere.mode.metadata.persist.MetaDataPersistFacade"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
"methods": [
@@ -9096,13 +9105,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfigurationBeanInfo"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfigurationCustomizer"
},
@@ -9298,19 +9307,19 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.single.distsql.parser.facade.SingleDistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.single.rule.changed.DefaultDataSourceChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"type":
"org.apache.shardingsphere.single.rule.changed.SingleTableChangedProcessor"
},
@@ -9348,13 +9357,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.clickhouse.parser.ClickHouseParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.clickhouse.visitor.statement.ClickHouseStatementVisitorFacade"
},
@@ -9430,13 +9439,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.firebird.parser.FirebirdParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.firebird.visitor.statement.FirebirdStatementVisitorFacade"
},
@@ -9498,13 +9507,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.hive.parser.HiveParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.hive.visitor.statement.HiveStatementVisitorFacade"
},
@@ -9580,13 +9589,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.mysql.parser.MySQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.mysql.visitor.statement.MySQLStatementVisitorFacade"
},
@@ -9704,13 +9713,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.opengauss.parser.OpenGaussParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.opengauss.visitor.statement.OpenGaussStatementVisitorFacade"
},
@@ -9744,13 +9753,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.oracle.parser.OracleParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.oracle.visitor.statement.OracleStatementVisitorFacade"
},
@@ -9812,13 +9821,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.postgresql.parser.PostgreSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.postgresql.visitor.statement.PostgreSQLStatementVisitorFacade"
},
@@ -9908,13 +9917,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.presto.parser.PrestoParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.presto.visitor.statement.PrestoStatementVisitorFacade"
},
@@ -9934,13 +9943,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.sql92.parser.SQL92ParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.sql92.visitor.statement.SQL92StatementVisitorFacade"
},
@@ -9974,13 +9983,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.sqlserver.parser.SQLServerParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"type":
"org.apache.shardingsphere.sql.parser.engine.sqlserver.visitor.statement.SQLServerStatementVisitorFacade"
},
@@ -10281,7 +10290,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.sqlfederation.distsql.parser.facade.SQLFederationDistSQLParserFacade"
},
@@ -10291,24 +10300,12 @@
},
"type":
"org.apache.shardingsphere.sqlfederation.mysql.MySQLSQLFederationConnectionConfigBuilder"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.mysql.MySQLSQLFederationFunctionRegister"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.sqlfederation.compiler.context.connection.config.SQLFederationConnectionConfigBuilderFactory"
},
"type":
"org.apache.shardingsphere.sqlfederation.opengauss.OpenGaussSQLFederationConnectionConfigBuilder"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.opengauss.OpenGaussSQLFederationFunctionRegister"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.sqlfederation.compiler.context.connection.config.SQLFederationConnectionConfigBuilderFactory"
@@ -10321,12 +10318,6 @@
},
"type":
"org.apache.shardingsphere.sqlfederation.postgresql.PostgreSQLSQLFederationConnectionConfigBuilder"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.postgresql.PostgreSQLSQLFederationFunctionRegister"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.sqlfederation.compiler.context.connection.config.SQLFederationConnectionConfigBuilderFactory"
@@ -10410,36 +10401,12 @@
"type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfigurationBeanInfo"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
},
"type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfigurationBeanInfo"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfigurationCustomizer"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.sqlfederation.yaml.config.YamlSQLFederationRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
@@ -10512,7 +10479,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.sqltranslator.distsql.parser.facade.SQLTranslatorDistSQLParserFacade"
},
@@ -10593,36 +10560,12 @@
"type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfigurationBeanInfo"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
},
"type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfigurationBeanInfo"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfigurationCustomizer"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.sqltranslator.yaml.config.YamlSQLTranslatorRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
@@ -10941,7 +10884,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"type":
"org.apache.shardingsphere.transaction.distsql.parser.facade.TransactionDistSQLParserFacade"
},
@@ -10969,6 +10912,48 @@
}
]
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.FirebirdXAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.H2XAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.MariaDBXAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.MySQLXAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.OpenGaussXAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.OracleXAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
+ },
+ "type":
"org.apache.shardingsphere.transaction.xa.jta.connection.dialect.PostgreSQLXAConnectionWrapper"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.xa.XAShardingSphereTransactionManager"
@@ -11058,36 +11043,12 @@
"type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfiguration",
"allDeclaredFields": true
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfigurationBeanInfo"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfigurationBeanInfo"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
},
"type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfigurationBeanInfo"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
- },
- "type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfigurationCustomizer"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.mode.manager.standalone.StandaloneContextManagerBuilder"
- },
- "type":
"org.apache.shardingsphere.transaction.yaml.config.YamlTransactionRuleConfigurationCustomizer"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
@@ -11096,7 +11057,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.mode.repository.standalone.jdbc.JDBCRepository"
},
"type": {
"proxy": [
@@ -11396,13 +11357,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.infra.datasource.pool.props.validator.DataSourcePoolPropertiesValidator"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.database.connector.core.checker.DialectDatabasePrivilegeChecker"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.database.connector.core.jdbcurl.DialectDefaultQueryPropertiesProvider"
},
@@ -11414,7 +11375,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.database.connector.core.jdbcurl.parser.ConnectionPropertiesParser"
},
@@ -11436,12 +11397,6 @@
},
"glob":
"META-INF/services/org.apache.shardingsphere.database.connector.core.metadata.database.system.DialectSystemDatabase"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.database.connector.core.metadata.identifier.IdentifierCaseRuleProvider"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.props.TypedPropertyValue"
@@ -11450,37 +11405,43 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.AdvancedDistSQLUpdateExecutor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.rdl.rule.spi.database.DatabaseRuleDefinitionExecutor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.resultset.ShardingSphereResultSet"
+ },
+ "glob":
"META-INF/services/org.apache.shardingsphere.driver.jdbc.core.resultset.DialectResultSetValueConverter"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.infra.algorithm.keygen.spi.KeyGenerateAlgorithm"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.parse.PostgreSQLComParseExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.infra.binder.context.DialectCommonSQLStatementContextWarpProvider"
},
@@ -11492,7 +11453,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.infra.binder.engine.DialectSQLBindEngine"
},
@@ -11544,18 +11505,6 @@
},
"glob":
"META-INF/services/org.apache.shardingsphere.infra.executor.sql.prepare.driver.SQLExecutionUnitBuilder"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.infra.instance.metadata.InstanceMetaDataBuilder"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.builder.DialectStatisticsAppender"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.proxy.backend.postgresql.handler.admin.factory.PostgreSQLSelectAdminExecutorFactory"
@@ -11580,12 +11529,6 @@
},
"glob":
"META-INF/services/org.apache.shardingsphere.infra.util.yaml.constructor.ShardingSphereYamlConstruct"
},
- {
- "condition": {
- "typeReached": "org.apache.shardingsphere.infra.util.yaml.YamlEngine"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.infra.util.yaml.shortcuts.ShardingSphereYamlShortcuts"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.yaml.config.swapper.mode.YamlModeConfigurationSwapper"
@@ -11598,12 +11541,6 @@
},
"glob":
"META-INF/services/org.apache.shardingsphere.mode.deliver.DeliverEventSubscriber"
},
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.mode.manager.builder.ContextManagerBuilder"
- },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.DataChangedEventListenerRegistry"
@@ -11636,19 +11573,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
- },
- "glob":
"META-INF/services/org.apache.shardingsphere.mode.repository.standalone.StandalonePersistRepository"
- },
- {
- "condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.mode.spi.rule.RuleItemConfigurationChangedProcessor"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.extended.Portal"
},
"glob":
"META-INF/services/org.apache.shardingsphere.proxy.backend.connector.AdvancedProxySQLExecutor"
},
@@ -11660,7 +11591,7 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.backend.handler.ProxyBackendHandlerFactory"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.proxy.backend.handler.admin.executor.DatabaseAdminExecutorCreator"
},
@@ -11702,13 +11633,13 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.sql.parser.spi.DialectSQLParserFacade"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor"
+ "typeReached":
"org.apache.shardingsphere.proxy.frontend.postgresql.command.query.simple.PostgreSQLComQueryExecutor"
},
"glob":
"META-INF/services/org.apache.shardingsphere.sql.parser.spi.SQLStatementVisitorFacade"
},
@@ -11720,21 +11651,27 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
+ "typeReached":
"org.apache.shardingsphere.sqltranslator.rule.SQLTranslatorRule"
},
- "glob":
"META-INF/services/org.apache.shardingsphere.sqlfederation.compiler.sql.function.DialectSQLFederationFunctionRegister"
+ "glob":
"META-INF/services/org.apache.shardingsphere.sqltranslator.spi.SQLTranslator"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.sqltranslator.rule.SQLTranslatorRule"
+ "typeReached":
"org.apache.shardingsphere.transaction.ShardingSphereTransactionManagerEngine"
},
- "glob":
"META-INF/services/org.apache.shardingsphere.sqltranslator.spi.SQLTranslator"
+ "glob":
"META-INF/services/org.apache.shardingsphere.transaction.spi.ShardingSphereDistributedTransactionManager"
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.initializer.BootstrapInitializer"
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.jta.datasource.XATransactionDataSource"
},
- "glob":
"META-INF/services/org.apache.shardingsphere.timeservice.spi.TimestampService"
+ "glob":
"META-INF/services/org.apache.shardingsphere.transaction.xa.jta.connection.XAConnectionWrapper"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.XAShardingSphereTransactionManager"
+ },
+ "glob":
"META-INF/services/org.apache.shardingsphere.transaction.xa.spi.XATransactionManagerProvider"
},
{
"condition": {
@@ -11742,18 +11679,36 @@
},
"glob": "META-INF/services/org.codehaus.groovy.runtime.ExtensionModule"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob":
"META-INF/services/org.testcontainers.containers.JdbcDatabaseContainerProvider"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
},
"glob":
"META-INF/services/org.testcontainers.containers.JdbcDatabaseContainerProvider"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob":
"META-INF/services/org.testcontainers.core.CreateContainerCmdModifier"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
},
"glob":
"META-INF/services/org.testcontainers.core.CreateContainerCmdModifier"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob": "client-v2-version.properties"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.xa.atomikos.manager.AtomikosTransactionManagerProvider"
@@ -11772,6 +11727,18 @@
},
"glob": "com/atomikos/icatch/provider/imp/transactions.properties"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob":
"com/clickhouse/client/internal/org/apache/hc/client5/version.properties"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob": "container-license-acceptance.txt"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.infra.version.ShardingSphereVersion"
@@ -11820,6 +11787,12 @@
},
"glob": "org/h2/util/data.zip"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob": "org/postgresql/driverconfig.properties"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
@@ -13098,6 +13071,18 @@
},
"glob": "sql/H2.xml"
},
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob": "test-native/sql/clickhouse-init.sql"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource"
+ },
+ "glob": "test-native/sql/seata-script-client-at-postgresql.sql"
+ },
{
"condition": {
"typeReached":
"org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingSphereTransactionManager"
@@ -13244,13 +13229,34 @@
},
{
"condition": {
- "typeReached":
"org.apache.shardingsphere.proxy.frontend.mysql.authentication.MySQLAuthenticationEngine"
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.atomikos.manager.AtomikosTransactionManagerProvider"
+ },
+ "module": "java.logging",
+ "glob": "sun/util/logging/resources/logging_zh.properties"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.atomikos.manager.AtomikosTransactionManagerProvider"
},
- "module": "jdk.jfr",
- "glob": "jdk/jfr/internal/types/metadata.bin"
+ "module": "java.logging",
+ "glob": "sun/util/logging/resources/logging_zh_Hans.properties"
+ },
+ {
+ "condition": {
+ "typeReached":
"org.apache.shardingsphere.transaction.xa.atomikos.manager.AtomikosTransactionManagerProvider"
+ },
+ "module": "java.logging",
+ "glob": "sun/util/logging/resources/logging_zh_Hans_CN.properties"
+ }
+ ],
+ "bundles": [
+ {
+ "name": "com.microsoft.sqlserver.jdbc.SQLServerResource",
+ "locales": [
+ "zh-CN"
+ ]
}
],
- "bundles": [],
"jni": [
{
"condition": {
diff --git
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ProxyTestingServer.java
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ProxyTestingServer.java
index d29aef2d607..312dea72b55 100644
---
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ProxyTestingServer.java
+++
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ProxyTestingServer.java
@@ -19,13 +19,21 @@ package org.apache.shardingsphere.test.natived.commons.util;
import lombok.Getter;
import org.apache.curator.test.InstanceSpec;
-import org.apache.shardingsphere.proxy.Bootstrap;
-import org.awaitility.Awaitility;
+import org.apache.shardingsphere.infra.config.props.ConfigurationPropertyKey;
+import org.apache.shardingsphere.proxy.arguments.BootstrapArguments;
+import org.apache.shardingsphere.proxy.backend.config.ProxyConfigurationLoader;
+import org.apache.shardingsphere.proxy.backend.config.YamlProxyConfiguration;
+import org.apache.shardingsphere.proxy.frontend.CDCServer;
+import org.apache.shardingsphere.proxy.frontend.ShardingSphereProxy;
+import org.apache.shardingsphere.proxy.frontend.ssl.ProxySSLContext;
+import org.apache.shardingsphere.proxy.initializer.BootstrapInitializer;
import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.ServerSocket;
import java.sql.SQLException;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.TimeUnit;
+import java.util.List;
+import java.util.Optional;
/**
* This class is designed to start ShardingSphere Proxy directly in the
current process,
@@ -39,30 +47,48 @@ public final class ProxyTestingServer {
@Getter
private final int proxyPort;
- private final CompletableFuture<Void> completableFuture;
+ private final ShardingSphereProxy proxy;
/**
- * Call this method to start the Server side of ShardingSphere Proxy in a
separate thread.
+ * Call this method to start the Server side of ShardingSphere Proxy.
*
* @param configAbsolutePath The absolute path to the directory where
{@code global.yaml} is located.
+ * @see org.apache.shardingsphere.proxy.Bootstrap
*/
public ProxyTestingServer(final String configAbsolutePath) {
proxyPort = InstanceSpec.getRandomPort();
- completableFuture = CompletableFuture.runAsync(() -> {
- try {
- Bootstrap.main(new String[]{String.valueOf(proxyPort),
configAbsolutePath, "0.0.0.0"});
- } catch (final IOException | SQLException ex) {
- throw new RuntimeException(ex);
+ String[] args = new String[]{String.valueOf(proxyPort),
configAbsolutePath, "0.0.0.0"};
+ try {
+ BootstrapArguments bootstrapArgs = new BootstrapArguments(args);
+ YamlProxyConfiguration yamlConfig =
ProxyConfigurationLoader.load(bootstrapArgs.getConfigurationPath());
+ int port = bootstrapArgs.getPort().orElseThrow(() -> new
IllegalStateException("Check
`org.apache.curator.test.InstanceSpec#getRandomPort`."));
+ List<String> addresses = bootstrapArgs.getAddresses();
+ checkPort(addresses, port);
+ new BootstrapInitializer().init(yamlConfig, port);
+ Optional.ofNullable((Integer)
yamlConfig.getServerConfiguration().getProps().get(ConfigurationPropertyKey.CDC_SERVER_PORT.getKey()))
+ .ifPresent(optional -> new Thread(new CDCServer(addresses,
optional)).start());
+ ProxySSLContext.init();
+ proxy = new ShardingSphereProxy();
+ bootstrapArgs.getSocketPath().ifPresent(proxy::start);
+ proxy.startInternal(port, addresses);
+ } catch (final SQLException | IOException | InterruptedException ex) {
+ throw new RuntimeException(ex);
+ }
+ }
+
+ private void checkPort(final List<String> addresses, final int port)
throws IOException {
+ for (String each : addresses) {
+ try (ServerSocket socket = new ServerSocket()) {
+ socket.bind(new InetSocketAddress(each, port));
}
- });
+ }
}
/**
- * Force close ShardingSphere Proxy.
+ * Close ShardingSphere Proxy.
*
*/
public void close() {
- completableFuture.cancel(false);
- Awaitility.await().atMost(1L,
TimeUnit.MINUTES).until(completableFuture::isDone);
+ proxy.close();
}
}
diff --git
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ResourceUtils.java
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ResourceUtils.java
index 849901846cb..1b16d62b9fc 100644
---
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ResourceUtils.java
+++
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/commons/util/ResourceUtils.java
@@ -46,6 +46,7 @@ public class ResourceUtils {
public static void closeJdbcDataSource(final DataSource dataSource) throws
SQLException {
try (Connection connection = dataSource.getConnection()) {
ContextManager contextManager =
connection.unwrap(ShardingSphereConnection.class).getContextManager();
+ close(dataSource);
contextManager.getStorageUnits(DefaultDatabase.LOGIC_NAME).values().stream().map(StorageUnit::getDataSource).forEach(ResourceUtils::close);
contextManager.close();
}
@@ -62,6 +63,7 @@ public class ResourceUtils {
public static void closeJdbcDataSource(final DataSource dataSource, final
String logicDataBaseName) throws SQLException {
try (Connection connection = dataSource.getConnection()) {
ContextManager contextManager =
connection.unwrap(ShardingSphereConnection.class).getContextManager();
+ close(dataSource);
contextManager.getStorageUnits(logicDataBaseName).values().stream().map(StorageUnit::getDataSource).forEach(ResourceUtils::close);
contextManager.close();
}
diff --git
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/jdbc/modes/cluster/ZookeeperTest.java
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/jdbc/modes/cluster/ZookeeperTest.java
index 6072e6b8f01..dcfb58f95f8 100644
---
a/test/native/src/test/java/org/apache/shardingsphere/test/natived/jdbc/modes/cluster/ZookeeperTest.java
+++
b/test/native/src/test/java/org/apache/shardingsphere/test/natived/jdbc/modes/cluster/ZookeeperTest.java
@@ -32,6 +32,7 @@ import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledInNativeImage;
import javax.sql.DataSource;
+import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.time.Duration;
@@ -49,27 +50,36 @@ class ZookeeperTest {
private TestShardingService testShardingService;
+ private TestingServer testingServer;
+
@BeforeEach
- void beforeEach() {
+ void beforeEach() throws Exception {
assertNull(System.getProperty(systemPropKeyPrefix + "server-lists"));
+ testingServer = new TestingServer();
}
@AfterEach
- void afterEach() throws SQLException {
- ResourceUtils.closeJdbcDataSource(logicDataSource);
+ void afterEach() throws SQLException, IOException {
System.clearProperty(systemPropKeyPrefix + "server-lists");
+ try {
+ if (null != logicDataSource) {
+ ResourceUtils.closeJdbcDataSource(logicDataSource);
+ }
+ } finally {
+ if (null != testingServer) {
+ testingServer.close();
+ }
+ }
}
@Test
void assertShardingInLocalTransactions() throws Exception {
- try (TestingServer testingServer = new TestingServer()) {
- String connectString = testingServer.getConnectString();
- logicDataSource = createDataSource(connectString);
- testShardingService = new TestShardingService(logicDataSource);
- initEnvironment();
- testShardingService.processSuccess();
- testShardingService.cleanEnvironment();
- }
+ String connectString = testingServer.getConnectString();
+ logicDataSource = createDataSource(connectString);
+ testShardingService = new TestShardingService(logicDataSource);
+ initEnvironment();
+ testShardingService.processSuccess();
+ testShardingService.cleanEnvironment();
}
/**
diff --git a/test/native/src/test/resources/testcontainers.properties
b/test/native/src/test/resources/testcontainers.properties
index 970174d7d8d..1d26333230f 100644
--- a/test/native/src/test/resources/testcontainers.properties
+++ b/test/native/src/test/resources/testcontainers.properties
@@ -16,3 +16,4 @@
#
pull.timeout = 240
+client.ping.timeout = 30
