This is an automated email from the ASF dual-hosted git repository.
zhangliang 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 729c0ae2c56 Add @HighFrequencyInvocation on sharding
SQLTokenGenerator's impl (#33694)
729c0ae2c56 is described below
commit 729c0ae2c56c7baf858331bb41e2b4b0a9e2002f
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Nov 17 01:40:06 2024 +0800
Add @HighFrequencyInvocation on sharding SQLTokenGenerator's impl (#33694)
---
.../token/generator/impl/ShardingAggregationDistinctTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingConstraintTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingCursorTokenGenerator.java | 2 ++
.../generator/impl/ShardingDistinctProjectionPrefixTokenGenerator.java | 2 ++
.../token/generator/impl/ShardingFetchDirectionTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingIndexTokenGenerator.java | 2 ++
.../token/generator/impl/ShardingInsertValuesTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingOffsetTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingOrderByTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingProjectionsTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingRemoveTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingRowCountTokenGenerator.java | 2 ++
.../rewrite/token/generator/impl/ShardingTableTokenGenerator.java | 2 ++
13 files changed, 26 insertions(+)
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingAggregationDistinctTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingAggregationDistinctTokenGenerator.java
index 3cafe2c3f1b..7281f03e103 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingAggregationDistinctTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingAggregationDistinctTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import com.google.common.base.Preconditions;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.segment.select.projection.DerivedColumn;
import
org.apache.shardingsphere.infra.binder.context.segment.select.projection.impl.AggregationDistinctProjection;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
@@ -33,6 +34,7 @@ import java.util.LinkedList;
/**
* Sharding aggregation distinct token generator.
*/
+@HighFrequencyInvocation
public final class ShardingAggregationDistinctTokenGenerator implements
CollectionSQLTokenGenerator<SQLStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingConstraintTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingConstraintTokenGenerator.java
index 0af8d014b80..ae58c423cc7 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingConstraintTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingConstraintTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.RequiredArgsConstructor;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import org.apache.shardingsphere.infra.binder.context.type.ConstraintAvailable;
import
org.apache.shardingsphere.infra.rewrite.sql.token.common.generator.CollectionSQLTokenGenerator;
@@ -33,6 +34,7 @@ import java.util.LinkedList;
/**
* Sharding constraint token generator.
*/
+@HighFrequencyInvocation
@RequiredArgsConstructor
public final class ShardingConstraintTokenGenerator implements
CollectionSQLTokenGenerator<SQLStatementContext> {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingCursorTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingCursorTokenGenerator.java
index 58f7bfa98c9..651fd2bf694 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingCursorTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingCursorTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.RequiredArgsConstructor;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import org.apache.shardingsphere.infra.binder.context.type.CursorAvailable;
import
org.apache.shardingsphere.infra.rewrite.sql.token.common.generator.OptionalSQLTokenGenerator;
@@ -30,6 +31,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.cursor.Cu
/**
* Sharding cursor token generator.
*/
+@HighFrequencyInvocation
@RequiredArgsConstructor
public final class ShardingCursorTokenGenerator implements
OptionalSQLTokenGenerator<SQLStatementContext> {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingDistinctProjectionPrefixTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingDistinctProjectionPrefixTokenGenerator.java
index 7c3ed07d70e..9bb42885cc1 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingDistinctProjectionPrefixTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingDistinctProjectionPrefixTokenGenerator.java
@@ -17,6 +17,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.dml.SelectStatementContext;
import
org.apache.shardingsphere.sharding.rewrite.token.generator.IgnoreForSingleRoute;
@@ -26,6 +27,7 @@ import
org.apache.shardingsphere.sharding.rewrite.token.pojo.DistinctProjectionP
/**
* Sharding distinct projection prefix token generator.
*/
+@HighFrequencyInvocation
public final class ShardingDistinctProjectionPrefixTokenGenerator implements
OptionalSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingFetchDirectionTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingFetchDirectionTokenGenerator.java
index 4c6b4228147..c7361d8c8f2 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingFetchDirectionTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingFetchDirectionTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.Setter;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.ddl.FetchStatementContext;
import org.apache.shardingsphere.infra.session.connection.ConnectionContext;
@@ -33,6 +34,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.FetchSt
/**
* Sharding fetch direction token generator.
*/
+@HighFrequencyInvocation
@Setter
public final class ShardingFetchDirectionTokenGenerator implements
OptionalSQLTokenGenerator<SQLStatementContext>, ConnectionContextAware {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingIndexTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingIndexTokenGenerator.java
index 88695e34f3c..aba851670d0 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingIndexTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingIndexTokenGenerator.java
@@ -19,6 +19,7 @@ package
org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import org.apache.shardingsphere.infra.binder.context.type.IndexAvailable;
import
org.apache.shardingsphere.infra.database.core.metadata.database.object.DialectObjectUniquenessLevelProvider;
@@ -40,6 +41,7 @@ import java.util.Map;
/**
* Sharding index token generator.
*/
+@HighFrequencyInvocation
@RequiredArgsConstructor
@Setter
public final class ShardingIndexTokenGenerator implements
CollectionSQLTokenGenerator<SQLStatementContext>, SchemaMetaDataAware {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingInsertValuesTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingInsertValuesTokenGenerator.java
index 3e02ac7b92c..b8b31ac6fbd 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingInsertValuesTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingInsertValuesTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.Setter;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.rewrite.sql.token.common.generator.aware.RouteContextAware;
import
org.apache.shardingsphere.sharding.rewrite.token.pojo.ShardingInsertValue;
import
org.apache.shardingsphere.sharding.rewrite.token.pojo.ShardingInsertValuesToken;
@@ -39,6 +40,7 @@ import java.util.List;
/**
* Insert values token generator for sharding.
*/
+@HighFrequencyInvocation
@Setter
public final class ShardingInsertValuesTokenGenerator implements
OptionalSQLTokenGenerator<InsertStatementContext>, RouteContextAware {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOffsetTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOffsetTokenGenerator.java
index e9d7dcb56a9..11c24b31175 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOffsetTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOffsetTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import com.google.common.base.Preconditions;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.segment.select.pagination.PaginationContext;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.dml.SelectStatementContext;
@@ -29,6 +30,7 @@ import
org.apache.shardingsphere.sharding.rewrite.token.pojo.OffsetToken;
/**
* Sharding offset token generator.
*/
+@HighFrequencyInvocation
public final class ShardingOffsetTokenGenerator implements
OptionalSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOrderByTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOrderByTokenGenerator.java
index a9c392e5770..ba24faf6257 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOrderByTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingOrderByTokenGenerator.java
@@ -17,6 +17,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.segment.select.orderby.OrderByItem;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.dml.SelectStatementContext;
@@ -31,6 +32,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectS
/**
* Sharding order by token generator.
*/
+@HighFrequencyInvocation
public final class ShardingOrderByTokenGenerator implements
OptionalSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingProjectionsTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingProjectionsTokenGenerator.java
index ccd585319af..23662a3b5aa 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingProjectionsTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingProjectionsTokenGenerator.java
@@ -19,6 +19,7 @@ package
org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import com.google.common.base.Preconditions;
import lombok.Setter;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.segment.select.projection.Projection;
import
org.apache.shardingsphere.infra.binder.context.segment.select.projection.impl.AggregationDistinctProjection;
import
org.apache.shardingsphere.infra.binder.context.segment.select.projection.impl.AggregationProjection;
@@ -51,6 +52,7 @@ import java.util.stream.Collectors;
/**
* Sharding projections token generator.
*/
+@HighFrequencyInvocation
@Setter
public final class ShardingProjectionsTokenGenerator implements
OptionalSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute,
RouteContextAware {
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRemoveTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRemoveTokenGenerator.java
index d57b08db77c..26ef1711310 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRemoveTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRemoveTokenGenerator.java
@@ -17,6 +17,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.dml.SelectStatementContext;
import
org.apache.shardingsphere.infra.rewrite.sql.token.common.generator.CollectionSQLTokenGenerator;
@@ -30,6 +31,7 @@ import java.util.LinkedList;
/**
* Sharding remove token generator.
*/
+@HighFrequencyInvocation
public final class ShardingRemoveTokenGenerator implements
CollectionSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRowCountTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRowCountTokenGenerator.java
index 2e4da13f054..02bc4e74a57 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRowCountTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingRowCountTokenGenerator.java
@@ -18,6 +18,7 @@
package org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import com.google.common.base.Preconditions;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.binder.context.segment.select.pagination.PaginationContext;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import
org.apache.shardingsphere.infra.binder.context.statement.dml.SelectStatementContext;
@@ -29,6 +30,7 @@ import
org.apache.shardingsphere.sharding.rewrite.token.pojo.RowCountToken;
/**
* Sharding row count token generator.
*/
+@HighFrequencyInvocation
public final class ShardingRowCountTokenGenerator implements
OptionalSQLTokenGenerator<SelectStatementContext>, IgnoreForSingleRoute {
@Override
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingTableTokenGenerator.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingTableTokenGenerator.java
index a36026ba80e..e870b627b8f 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingTableTokenGenerator.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/rewrite/token/generator/impl/ShardingTableTokenGenerator.java
@@ -19,6 +19,7 @@ package
org.apache.shardingsphere.sharding.rewrite.token.generator.impl;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import org.apache.shardingsphere.infra.binder.context.aware.CursorAware;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
import org.apache.shardingsphere.infra.binder.context.type.TableAvailable;
@@ -38,6 +39,7 @@ import java.util.LinkedList;
/**
* Sharding table token generator.
*/
+@HighFrequencyInvocation
@RequiredArgsConstructor
@Setter
public final class ShardingTableTokenGenerator implements
CollectionSQLTokenGenerator<SQLStatementContext>, RouteContextAware {
