This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a change to branch opengauss_adapt
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
discard 5bae300 add jdbc:opengauss supoort (#10601)
discard 69f7895 Update OpenGaussDataSourceMetaData
discard 358c05a Add OpenGauss Database type (#10292)
add 568e8cd Update documents dev-manual/proxy (#10621)
add 5e4b14e fix select with group by rewrite error (#10620)
add ff4b505 Refactor gov.registry.node package (#10622)
add 9500ee6 Revert DataSourceChangedEvent (#10623)
add ce94a2a Refactor RDL backend handler (#10624)
add d4d1ca2 Minor refactor for RQL (#10625)
add 1a31bbc Refactor DropResourceBackendHandler (#10628)
add 7c42a4e Return no generated key for PostgreSQL (#10627)
add a54ae1d Fix PostgreSQL select no columns cause NPE (#10632)
add dc033b4 Fix Row Description may be missing for PostgreSQL (#10636)
add acbf570 Add SQLNotificationEvent (#10637)
add face266 fix group by having merge result error (#10639)
add a0d369f Minor refactor for RDL (#10643)
add 7e5257b Refactor database created & dropped event (#10648)
new c1cf25f Add OpenGauss Database type (#10292)
new d08ebb6 Update OpenGaussDataSourceMetaData
new 195b66a add jdbc:opengauss supoort (#10601)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5bae300)
\
N -- N -- N refs/heads/opengauss_adapt (195b66a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/document/content/dev-manual/proxy.cn.md | 11 +++
docs/document/content/dev-manual/proxy.en.md | 11 +++
.../merge/dal/show/LogicTablesMergedResult.java | 5 +-
.../merge/dal/show/ShowIndexMergedResult.java | 5 +-
.../merge/dql/ShardingDQLResultMerger.java | 35 +++++--
.../dql/groupby/GroupByMemoryMergedResult.java | 5 +-
.../having/HavingDecoratorMergedResult.java | 84 +++++++++++++++++
.../merge/ShardingResultMergerEngineTest.java | 2 +-
.../merge/dql/ShardingDQLResultMergerTest.java | 62 ++++++-------
.../dql/groupby/GroupByMemoryMergedResultTest.java | 2 +-
.../dql/groupby/GroupByRowComparatorTest.java | 16 ++--
.../dql/groupby/GroupByStreamMergedResultTest.java | 2 +-
.../iterator/IteratorStreamMergedResultTest.java | 2 +-
.../dql/orderby/OrderByStreamMergedResultTest.java | 2 +-
.../merge/dql/orderby/OrderByValueTest.java | 6 +-
.../pagination/LimitDecoratorMergedResultTest.java | 6 +-
.../RowNumberDecoratorMergedResultTest.java | 16 ++--
.../TopAndRowNumberDecoratorMergedResultTest.java | 10 +-
.../generator/impl/OrderByTokenGenerator.java | 22 +----
.../src/test/resources/sharding/select.xml | 16 +++-
.../listener/PrivilegeNodeChangedWatcher.java | 2 +-
.../metadata/GovernanceMetaDataContexts.java | 16 ++--
.../metadata/GovernanceMetaDataContextsTest.java | 12 +--
.../instance => }/GovernanceInstance.java | 2 +-
.../core/lock/service/LockRegistryService.java | 4 +-
.../governance/core/registry/RegistryCenter.java | 8 +-
...CreatedEvent.java => SQLNotificationEvent.java} | 13 +--
.../core/registry/cache/RegistryCacheManager.java | 1 +
.../cache/{ => event}/StartScalingEvent.java | 2 +-
.../core/registry/cache/{ => node}/CacheNode.java | 2 +-
.../ScalingRegistrySubscriber.java | 6 +-
...va => DataSourceAddedSQLNotificationEvent.java} | 6 +-
...teredEvent.java => DataSourceChangedEvent.java} | 4 +-
.../DataSourceDroppedSQLNotificationEvent.java} | 10 +-
...ConfigurationsAlteredSQLNotificationEvent.java} | 5 +-
.../config/{service => }/node/GlobalNode.java | 2 +-
.../{service => }/node/SchemaMetadataNode.java | 2 +-
.../service/impl/DataSourceRegistryService.java | 20 ++--
.../service/impl/GlobalRuleRegistryService.java | 4 +-
.../service/impl/PropertiesRegistryService.java | 2 +-
.../service/impl/SchemaRuleRegistryService.java | 6 +-
.../config/watcher/GlobalRuleChangedWatcher.java | 2 +-
.../config/watcher/PropertiesChangedWatcher.java | 2 +-
...va => DatabaseCreatedSQLNotificationEvent.java} | 7 +-
...va => DatabaseDroppedSQLNotificationEvent.java} | 7 +-
.../metadata/service/SchemaRegistryService.java | 22 ++---
.../metadata/watcher/MetaDataChangedWatcher.java | 12 +--
.../process/{service => node}/ProcessNode.java | 2 +-
.../ProcessRegistrySubscriber.java | 3 +-
.../state/event/DisabledStateChangedEvent.java | 2 +-
.../state/event/PrimaryStateChangedEvent.java | 2 +-
.../state/{service => node}/StatesNode.java | 4 +-
.../service/DataSourceStatusRegistryService.java | 1 +
.../watcher/DataSourceStateChangedWatcher.java | 2 +-
.../state/watcher/TerminalStateChangedWatcher.java | 4 +-
.../{registry => }/schema/GovernanceSchema.java | 2 +-
.../schema/GovernanceSchemaGroup.java | 2 +-
.../instance => }/GovernanceInstanceTest.java | 2 +-
.../ScalingRegistrySubscriberTest.java | 3 +-
.../config/{service => }/node/GlobalNodeTest.java | 2 +-
.../{service => }/node/SchemaMetadataNodeTest.java | 2 +-
.../impl/DataSourceRegistryServiceTest.java | 9 +-
.../impl/SchemaRuleRegistryServiceTest.java | 4 +-
.../service/SchemaRegistryServiceTest.java | 12 +--
.../state/{service => node}/StatesNodeTest.java | 4 +-
.../DataSourceStatusRegistryServiceTest.java | 1 +
.../watcher/DataSourceStateChangedWatcherTest.java | 2 +-
.../schema/GovernanceSchemaGroupTest.java | 2 +-
.../schema/GovernanceSchemaTest.java | 2 +-
.../segment/select/groupby/GroupByContext.java | 2 -
.../groupby/engine/GroupByContextEngine.java | 6 +-
.../binder/segment/select/having/HavingColumn.java | 13 ++-
.../segment/select/having/HavingContext.java | 12 ++-
.../select/having/engine/HavingContextEngine.java | 93 +++++++++++++++++++
.../statement/dml/SelectStatementContext.java | 38 ++++++++
.../groupby/engine/GroupByContextEngineTest.java | 2 -
.../orderby/engine/OrderByContextEngineTest.java | 10 +-
.../engine/ProjectionsContextEngineTest.java | 16 ++--
.../statement/impl/SelectStatementContextTest.java | 12 +--
.../metadata/resource/ShardingSphereResource.java | 2 +-
.../result/impl/memory/MemoryMergedResult.java | 17 +++-
.../result/impl/memory/MemoryQueryResultRow.java | 13 +++
.../memory/fixture/TestMemoryMergedResult.java | 5 +-
.../generator/generic/RemoveTokenGenerator.java | 9 ++
.../GovernanceShardingSphereDataSourceTest.java | 11 ++-
.../backend/communication/ProxySQLExecutor.java | 4 +-
.../rdl/impl/AddResourceBackendHandler.java | 10 +-
.../AlterDatabaseDiscoveryRuleBackendHandler.java | 84 +++++++----------
.../rdl/impl/AlterEncryptRuleBackendHandler.java | 62 ++++++-------
.../AlterReadwriteSplittingRuleBackendHandler.java | 70 ++++++--------
...terShardingBindingTableRulesBackendHandler.java | 57 ++++--------
...rShardingBroadcastTableRulesBackendHandler.java | 28 ++----
.../impl/AlterShardingTableRuleBackendHandler.java | 66 +++++++-------
.../rdl/impl/CreateDatabaseBackendHandler.java | 4 +-
.../CreateDatabaseDiscoveryRuleBackendHandler.java | 62 ++++---------
.../rdl/impl/CreateEncryptRuleBackendHandler.java | 55 ++++-------
...CreateReadwriteSplittingRuleBackendHandler.java | 63 ++++---------
...ateShardingBindingTableRulesBackendHandler.java | 54 ++++-------
...eShardingBroadcastTableRulesBackendHandler.java | 25 ++---
.../CreateShardingTableRuleBackendHandler.java | 40 +++-----
.../rdl/impl/DropDatabaseBackendHandler.java | 4 +-
.../DropDatabaseDiscoveryRuleBackendHandler.java | 59 ++++--------
.../rdl/impl/DropEncryptRuleBackendHandler.java | 53 ++++-------
.../DropReadwriteSplittingRuleBackendHandler.java | 67 ++++----------
.../rdl/impl/DropResourceBackendHandler.java | 73 +++++++--------
...ropShardingBindingTableRulesBackendHandler.java | 5 +-
...pShardingBroadcastTableRulesBackendHandler.java | 5 +-
.../impl/DropShardingTableRuleBackendHandler.java | 5 +-
.../text/distsql/rdl/impl/RDLBackendHandler.java | 94 +++++++++++++++++++
.../DatabaseDiscoveryRulesQueryBackendHandler.java | 3 +-
.../rql/impl/EncryptRulesQueryBackendHandler.java | 3 +-
...ReadwriteSplittingRulesQueryBackendHandler.java | 3 +-
.../DatabaseCommunicationEngineTest.java | 5 +-
.../text/distsql/RDLBackendHandlerFactoryTest.java | 8 +-
...terDatabaseDiscoveryRuleBackendHandlerTest.java | 5 +-
.../impl/AlterEncryptRuleBackendHandlerTest.java | 5 +-
...erReadwriteSplittingRuleBackendHandlerTest.java | 5 +-
.../AlterShardingTableRuleBackendHandlerTest.java | 19 +++-
.../CreateShardingTableRuleBackendHandlerTest.java | 2 +
...ropDatabaseDiscoveryRuleBackendHandlerTest.java | 7 +-
.../impl/DropEncryptRuleBackendHandlerTest.java | 7 +-
...opReadwriteSplittingRuleBackendHandlerTest.java | 7 +-
.../impl/GovernanceBootstrapInitializerTest.java | 4 +-
.../binary/bind/PostgreSQLComBindExecutor.java | 2 +-
.../query/text/PostgreSQLComQueryExecutor.java | 12 +--
.../binary/bind/PostgreSQLComBindExecutorTest.java | 8 +-
.../query/text/PostgreSQLComQueryExecutorTest.java | 6 +-
.../scaling/core/api/ScalingWorker.java | 2 +-
.../src/main/antlr4/imports/mysql/BaseRule.g4 | 2 +-
.../statement/impl/MySQLStatementSQLVisitor.java | 101 +++++++++++++--------
.../impl/OracleDMLStatementSQLVisitor.java | 11 +++
.../impl/PostgreSQLStatementSQLVisitor.java | 23 +++++
.../impl/SQL92DMLStatementSQLVisitor.java | 15 ++-
.../impl/SQLServerDMLStatementSQLVisitor.java | 11 +++
.../segment/dml/predicate/HavingSegment.java | 19 ++--
.../sql/common/segment/generic/WindowSegment.java | 11 ++-
.../sql/common/statement/dml/SelectStatement.java | 12 +++
.../handler/dml/SelectStatementHandler.java | 17 ++++
.../statement/mysql/dml/MySQLSelectStatement.java | 12 +++
.../postgresql/dml/PostgreSQLSelectStatement.java | 14 ++-
.../handler/dml/SelectStatementHandlerTest.java | 31 +++++++
.../asserts/segment/having/HavingClauseAssert.java | 45 +++++++++
.../statement/dml/impl/SelectStatementAssert.java | 23 +++++
.../segment/impl/having/ExpectedHavingClause.java | 25 ++---
.../segment/impl/window/ExpectedWindowClause.java | 20 ++--
.../statement/dml/SelectStatementTestCase.java | 10 +-
.../main/resources/case/dml/select-group-by.xml | 53 +++++++++++
.../sql/supported/dml/select-group-by.xml | 2 +
148 files changed, 1450 insertions(+), 1000 deletions(-)
create mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-merge/src/main/java/org/apache/shardingsphere/sharding/merge/dql/groupby/having/HavingDecoratorMergedResult.java
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/{registry/instance
=> }/GovernanceInstance.java (95%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{metadata/event/MetaDataCreatedEvent.java
=> SQLNotificationEvent.java} (74%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/cache/{
=> event}/StartScalingEvent.java (99%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/cache/{
=> node}/CacheNode.java (99%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/cache/{
=> subscriber}/ScalingRegistrySubscriber.java (94%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/datasource/{DataSourceAddedEvent.java
=> DataSourceAddedSQLNotificationEvent.java} (85%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/datasource/{DataSourceAlteredEvent.java
=> DataSourceChangedEvent.java} (93%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/{rule/RuleConfigurationsAlteredEvent.java
=> datasource/DataSourceDroppedSQLNotificationEvent.java} (78%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/rule/{RuleConfigurationsAlteredEvent.java
=> RuleConfigurationsAlteredSQLNotificationEvent.java} (83%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/{service
=> }/node/GlobalNode.java (98%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/{service
=> }/node/SchemaMetadataNode.java (99%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/metadata/event/{MetaDataCreatedEvent.java
=> DatabaseCreatedSQLNotificationEvent.java} (79%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/metadata/event/{MetaDataDroppedEvent.java
=> DatabaseDroppedSQLNotificationEvent.java} (79%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/process/{service
=> node}/ProcessNode.java (99%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/process/{service
=> subscriber}/ProcessRegistrySubscriber.java (98%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/state/{service
=> node}/StatesNode.java (98%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/{registry
=> }/schema/GovernanceSchema.java (95%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/{registry
=> }/schema/GovernanceSchemaGroup.java (96%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/{registry/instance
=> }/GovernanceInstanceTest.java (94%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/cache/{
=> subscriber}/ScalingRegistrySubscriberTest.java (96%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/config/{service
=> }/node/GlobalNodeTest.java (98%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/config/{service
=> }/node/SchemaMetadataNodeTest.java (99%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/state/{service
=> node}/StatesNodeTest.java (97%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/{registry
=> }/schema/GovernanceSchemaGroupTest.java (97%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/{registry
=> }/schema/GovernanceSchemaTest.java (96%)
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/metadata/event/MetaDataDroppedEvent.java
=>
shardingsphere-infra/shardingsphere-infra-binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/having/HavingColumn.java
(74%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/metadata/event/MetaDataChangedEvent.java
=>
shardingsphere-infra/shardingsphere-infra-binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/having/HavingContext.java
(78%)
create mode 100644
shardingsphere-infra/shardingsphere-infra-binder/src/main/java/org/apache/shardingsphere/infra/binder/segment/select/having/engine/HavingContextEngine.java
create mode 100644
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/RDLBackendHandler.java
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/rule/RuleConfigurationsAlteredEvent.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/predicate/HavingSegment.java
(65%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/metadata/event/MetaDataDroppedEvent.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/generic/WindowSegment.java
(75%)
create mode 100644
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/segment/having/HavingClauseAssert.java
copy
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/rule/RuleConfigurationsAlteredEvent.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/segment/impl/having/ExpectedHavingClause.java
(53%)
rename
shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/config/event/rule/RuleConfigurationsAlteredEvent.java
=>
shardingsphere-sql-parser/shardingsphere-sql-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/segment/impl/window/ExpectedWindowClause.java
(63%)
