mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-07 21:30:22 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix load balance in rwSplit (#2204)

Browse Source
This commit is contained in:
Collapsar
2020-10-27 13:11:54 +08:00
committed by GitHub
parent e08ac1d425
commit 142ddd1fbb
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/actiontech/dble/rwsplit/RWSplitNonBlockingSession.java
View File

@@ -28,11 +28,11 @@ public class RWSplitNonBlockingSession {
this.rwSplitService = service;
}
public void execute(boolean master, Callback callback) {
public void execute(Boolean master, Callback callback) {
execute(master, null, callback);
}
public void execute(boolean master, byte[] originPacket, Callback callback) {
public void execute(Boolean master, byte[] originPacket, Callback callback) {
try {
RWSplitHandler handler = new RWSplitHandler(rwSplitService, originPacket, callback);
if (conn != null && !conn.isClosed()) {

2
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitQueryHandler.java
View File

@@ -46,7 +46,7 @@ public class RWSplitQueryHandler implements FrontendQueryHandler {
break;
case RwSplitServerParse.SHOW:
case RwSplitServerParse.SELECT:
session.execute(false, null);
session.execute(null, null);
break;
case RwSplitServerParse.SET:
SetHandler.handle(sql, session.getService(), rs >>> 8);

2
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitService.java
View File

@@ -193,7 +193,7 @@ public class RWSplitService extends BusinessService {
int sqlType = rs & 0xff;
switch (sqlType) {
case ServerParse.SELECT:
session.execute(false, data, null);
session.execute(null, data, null);
break;
default:
session.execute(true, data, null);