mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-06 14:30:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2610 from actiontech/prepared-statement-10

Browse Source 
fix bug for com_stmt_prepare
This commit is contained in:
Collapsar
2021-04-27 18:01:10 +08:00
committed by GitHub
parent cfb833ccc3 5e068f2f7e
commit 5e011c1cf5
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/services/rwsplit/MysqlPrepareLogicHandler.java
+14 -10
View File
@@ -33,16 +33,20 @@ public class MysqlPrepareLogicHandler extends MysqlBackendLogicHandler {
}
switch (resultStatus) {
case PREPARED_OK:
// Prepare ok
handleOkPacket(data);
int paramCount = ByteUtil.readUB2(data, 3);
params = new ArrayList<>(paramCount);
int fieldCount = ByteUtil.readUB2(data, 5);
fields = new ArrayList<>(fieldCount);
if (paramCount > 0) {
resultStatus = PREPARED_PARAM;
} else if (fieldCount > 0) {
resultStatus = PREPARED_FIELD;
boolean executeResponse = service.syncAndExecute();
if (executeResponse) {
// Prepare ok
handleOkPacket(data);
int fieldCount = ByteUtil.readUB2(data, 9);
int paramCount = ByteUtil.readUB2(data, 11);
if (fieldCount > 0) {
fields = new ArrayList<>(fieldCount);
resultStatus = PREPARED_FIELD;
}
if (paramCount > 0) {
params = new ArrayList<>(paramCount);
resultStatus = PREPARED_PARAM;
}
}
break;
case PREPARED_PARAM: