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/11/18 06:47:55 UTC
[shardingsphere] branch master updated: Remove pipeline incremental task connecting MySQL use default database (#22252)
This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng 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 67fdefd9ae5 Remove pipeline incremental task connecting MySQL use default database (#22252)
67fdefd9ae5 is described below
commit 67fdefd9ae5408bdc390a5d9f3bb2cfb4e2dc5a4
Author: Xinze Guo <10...@users.noreply.github.com>
AuthorDate: Fri Nov 18 14:47:49 2022 +0800
Remove pipeline incremental task connecting MySQL use default database (#22252)
---
.../data/pipeline/mysql/ingest/client/netty/MySQLNegotiateHandler.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLNegotiateHandler.java b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLNegotiateHandler.java
index 69b0481e8fb..5261d2286c3 100644
--- a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLNegotiateHandler.java
+++ b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/client/netty/MySQLNegotiateHandler.java
@@ -72,7 +72,6 @@ public final class MySQLNegotiateHandler extends ChannelInboundHandlerAdapter {
MySQLHandshakeResponse41Packet handshakeResponsePacket = new MySQLHandshakeResponse41Packet(1, MAX_PACKET_SIZE, CHARACTER_SET, username);
handshakeResponsePacket.setAuthResponse(generateAuthResponse(handshake.getAuthPluginData().getAuthenticationPluginData()));
handshakeResponsePacket.setCapabilityFlags(generateClientCapability());
- handshakeResponsePacket.setDatabase("mysql");
handshakeResponsePacket.setAuthPluginName(MySQLAuthenticationMethod.SECURE_PASSWORD_AUTHENTICATION);
ctx.channel().writeAndFlush(handshakeResponsePacket);
serverInfo = new ServerInfo();