You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2022/01/06 11:27:13 UTC
[shardingsphere] branch master updated (24f6bbc -> f9c5cd6)
This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 24f6bbc Refactor storage node of registry center (#14568)
add f9c5cd6 ShardingSphere-Proxy MySQL with Vert.x backend (#14559)
No new revisions were added by this update.
Summary of changes:
pom.xml | 8 +
.../AbstractCommandExecutorTaskAdviceTest.java | 3 -
.../shardingsphere-infra-common/pom.xml | 4 +
.../properties/ConfigurationPropertyKey.java | 7 +-
.../engine/driver/vertx/VertxExecutionUnit.java | 42 +++++
.../execute/engine/driver/vertx/VertxExecutor.java | 49 +++++
.../engine/driver/vertx/VertxExecutorCallback.java | 67 +++++++
.../vertx/VertxMySQLQueryResultMetaData.java | 90 +++++++++
.../query/impl/driver/vertx/VertxQueryResult.java | 79 ++++++++
.../prepare/driver/vertx/ExecutorVertxManager.java | 13 +-
.../driver/vertx/VertxExecutionContext.java | 8 +-
.../builder/PreparedQueryExecutionUnitBuilder.java | 45 +++++
.../vertx/builder/VertxExecutionUnitBuilder.java | 13 +-
...utor.sql.prepare.driver.SQLExecutionUnitBuilder | 1 +
.../driver/vertx/VertxExecutorCallbackTest.java | 87 +++++++++
.../backend/communication/BackendConnection.java | 15 +-
.../communication/DatabaseCommunicationEngine.java | 202 +++-----------------
.../DatabaseCommunicationEngineFactory.java | 34 +++-
.../backend/communication/ProxySQLExecutor.java | 3 +-
...Executor.java => ReactiveProxySQLExecutor.java} | 91 +++------
.../{jdbc/transaction => }/TransactionManager.java | 24 ++-
.../jdbc/JDBCDatabaseCommunicationEngine.java | 203 +++++++++++++++++++++
.../jdbc/connection/ConnectionPostProcessor.java | 8 +-
.../jdbc/connection/JDBCBackendConnection.java | 34 ++--
.../jdbc/executor/ProxyJDBCExecutor.java | 6 +-
.../callback/ProxyJDBCExecutorCallback.java | 6 +-
.../callback/ProxyJDBCExecutorCallbackFactory.java | 4 +-
.../ProxyPreparedStatementExecutorCallback.java | 4 +-
.../impl/ProxyStatementExecutorCallback.java | 4 +-
...ger.java => JDBCBackendTransactionManager.java} | 29 +--
.../jdbc/transaction/LocalTransactionManager.java | 33 ++--
.../vertx/VertxBackendConnection.java | 179 ++++++++++++++++++
.../vertx/VertxBackendDataSource.java | 150 +++++++++++++++
.../vertx/VertxDatabaseCommunicationEngine.java | 82 +++++++++
.../vertx/executor/ProxyReactiveExecutor.java | 65 +++++++
.../transaction/VertxLocalTransactionManager.java | 77 ++++++++
.../context/ReactiveProxyContext.java} | 26 ++-
.../proxy/backend/session/ConnectionSession.java | 12 +-
.../backend/text/TextProtocolBackendHandler.java | 14 ++
.../admin/mysql/MySQLAdminExecutorFactory.java | 5 +-
.../executor/UnicastResourceShowExecutor.java | 7 +-
.../backend/text/data/DatabaseBackendHandler.java | 10 +
.../data/impl/BroadcastDatabaseBackendHandler.java | 25 ++-
.../impl/SchemaAssignedDatabaseBackendHandler.java | 29 ++-
.../data/impl/UnicastDatabaseBackendHandler.java | 26 ++-
.../transaction/TransactionBackendHandler.java | 43 ++++-
.../communication/ProxySQLExecutorTest.java | 17 +-
.../JDBCDatabaseCommunicationEngineTest.java} | 24 +--
.../jdbc/connection/JDBCBackendConnectionTest.java | 30 +--
...java => JDBCBackendTransactionManagerTest.java} | 8 +-
.../backend/session/ConnectionSessionTest.java | 28 ++-
.../ral/ShowVariableBackendHandlerTest.java | 2 -
.../TransactionBackendHandlerFactoryTest.java | 6 +-
.../shardingsphere-proxy-bootstrap/pom.xml | 5 +
.../src/main/resources/conf/server.yaml | 2 +
.../shardingsphere-proxy-frontend/pom.xml | 3 +
.../proxy/frontend/ShardingSphereProxy.java | 14 +-
.../netty/FrontendChannelInboundHandler.java | 2 -
.../proxy/frontend/state/ProxyStateContext.java | 12 +-
.../{OKProxyState.java => JDBCOKProxyState.java} | 21 ++-
.../proxy/frontend/state/impl/OKProxyState.java | 52 +-----
...ngsphere.proxy.frontend.state.impl.OKProxyState | 3 +-
.../netty/FrontendChannelInboundHandlerTest.java | 9 -
...oxyStateTest.java => JDBCOKProxyStateTest.java} | 12 +-
.../execute/MySQLComStmtExecuteExecutor.java | 9 +-
.../fieldlist/MySQLComFieldListPacketExecutor.java | 6 +-
.../execute/MySQLComStmtExecuteExecutorTest.java | 4 +-
.../command/query/extended/PostgreSQLPortal.java | 7 +-
.../query/extended/PostgreSQLPortalTest.java | 8 +-
.../pom.xml | 31 ++--
.../command/ReactiveCommandExecuteTask.java | 134 ++++++++++++++
...ctiveDatabaseProtocolFrontendEngineFactory.java | 50 +++++
.../reactive/state/impl/ReactiveOKProxyState.java | 56 ++++++
.../wrap/WrappedReactiveCommandExecutor.java | 57 ++++++
...ngsphere.proxy.frontend.state.impl.OKProxyState | 3 +-
.../pom.xml | 33 ++--
.../ReactiveMySQLCommandExecutorFactory.java | 68 +++++++
.../mysql/command/ReactiveMySQLFrontendEngine.java | 74 ++++++++
.../ReactiveMySQLComStmtExecuteExecutor.java} | 63 ++++---
.../ReactiveMySQLComFieldListPacketExecutor.java} | 37 ++--
.../query/ReactiveMySQLComQueryPacketExecutor.java | 100 ++++++++++
...tive.spi.ReactiveDatabaseProtocolFrontendEngine | 3 +-
.../pom.xml | 28 +--
.../command/ReactiveCommandExecuteEngine.java} | 21 ++-
.../command/executor/ReactiveCommandExecutor.java} | 27 ++-
.../ReactiveDatabaseProtocolFrontendEngine.java} | 16 +-
86 files changed, 2431 insertions(+), 620 deletions(-)
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/driver/vertx/VertxExecutionUnit.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/driver/vertx/VertxExecutor.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/driver/vertx/VertxExecutorCallback.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/vertx/VertxMySQLQueryResultMetaData.java
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/vertx/VertxQueryResult.java
copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/DatabaseBackendHandler.java => shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/driver/vertx/ExecutorVertxManager.java (61%)
copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/DatabaseBackendHandler.java => shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/driver/vertx/VertxExecutionContext.java (75%)
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/driver/vertx/builder/PreparedQueryExecutionUnitBuilder.java
copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/DatabaseBackendHandler.java => shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/prepare/driver/vertx/builder/VertxExecutionUnitBuilder.java (52%)
create mode 100644 shardingsphere-infra/shardingsphere-infra-executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/execute/engine/driver/vertx/VertxExecutorCallbackTest.java
copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/{ProxySQLExecutor.java => ReactiveProxySQLExecutor.java} (52%)
rename shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/{jdbc/transaction => }/TransactionManager.java (70%)
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/JDBCDatabaseCommunicationEngine.java
rename shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/transaction/{BackendTransactionManager.java => JDBCBackendTransactionManager.java} (86%)
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/vertx/VertxBackendConnection.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/vertx/VertxBackendDataSource.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/vertx/VertxDatabaseCommunicationEngine.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/vertx/executor/ProxyReactiveExecutor.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/vertx/transaction/VertxLocalTransactionManager.java
copy shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/{communication/jdbc/connection/ConnectionPostProcessor.java => reactive/context/ReactiveProxyContext.java} (53%)
rename shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/communication/{DatabaseCommunicationEngineTest.java => jdbc/JDBCDatabaseCommunicationEngineTest.java} (92%)
rename shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/transaction/{BackendTransactionManagerTest.java => JDBCBackendTransactionManagerTest.java} (96%)
copy shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/state/impl/{OKProxyState.java => JDBCOKProxyState.java} (86%)
copy shardingsphere-infra/shardingsphere-infra-executor/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.executor.sql.prepare.driver.SQLExecutionUnitBuilder => shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/resources/META-INF/services/org.apache.shardingsphere.proxy.frontend.state.impl.OKProxyState (78%)
rename shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/test/java/org/apache/shardingsphere/proxy/frontend/state/impl/{OKProxyStateTest.java => JDBCOKProxyStateTest.java} (93%)
copy shardingsphere-proxy/shardingsphere-proxy-frontend/{ => shardingsphere-proxy-frontend-reactive-core}/pom.xml (54%)
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteTask.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/protocol/ReactiveDatabaseProtocolFrontendEngineFactory.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/state/impl/ReactiveOKProxyState.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-core/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/wrap/WrappedReactiveCommandExecutor.java
copy shardingsphere-infra/shardingsphere-infra-executor/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.executor.sql.prepare.driver.SQLExecutionUnitBuilder => shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-core/src/main/resources/META-INF/services/org.apache.shardingsphere.proxy.frontend.state.impl.OKProxyState (78%)
copy shardingsphere-proxy/shardingsphere-proxy-frontend/{ => shardingsphere-proxy-frontend-reactive-mysql}/pom.xml (54%)
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/mysql/command/ReactiveMySQLCommandExecutorFactory.java
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/mysql/command/ReactiveMySQLFrontendEngine.java
copy shardingsphere-proxy/shardingsphere-proxy-frontend/{shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/execute/MySQLComStmtExecuteExecutor.java => shardingsphere-proxy-frontend-reactive-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/mysql/command/query/binary/execute/ReactiveMySQLComStmtExecuteExecutor.java} (76%)
copy shardingsphere-proxy/shardingsphere-proxy-frontend/{shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/text/fieldlist/MySQLComFieldListPacketExecutor.java => shardingsphere-proxy-frontend-reactive-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/mysql/command/query/text/fieldlist/ReactiveMySQLComFieldListPacketExecutor.java} (79%)
create mode 100644 shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/mysql/command/query/text/query/ReactiveMySQLComQueryPacketExecutor.java
copy shardingsphere-infra/shardingsphere-infra-executor/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.executor.sql.prepare.driver.SQLExecutionUnitBuilder => shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.proxy.frontend.reactive.spi.ReactiveDatabaseProtocolFrontendEngine (78%)
copy shardingsphere-proxy/shardingsphere-proxy-frontend/{ => shardingsphere-proxy-frontend-reactive-spi}/pom.xml (58%)
copy shardingsphere-proxy/{shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/ConnectionPostProcessor.java => shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-spi/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/ReactiveCommandExecuteEngine.java} (51%)
copy shardingsphere-proxy/{shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/ConnectionPostProcessor.java => shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-spi/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/command/executor/ReactiveCommandExecutor.java} (59%)
copy shardingsphere-proxy/{shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/ConnectionPostProcessor.java => shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-reactive-spi/src/main/java/org/apache/shardingsphere/proxy/frontend/reactive/spi/ReactiveDatabaseProtocolFrontendEngine.java} (60%)