Reset decode41

asyncer-io · Jan 11, 2025 · 31d02c4 · 31d02c4
1 parent 72aa2a0
commit 31d02c4
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/...-mysql/src/main/java/io/asyncer/r2dbc/mysql/message/server/DefinitionMetadataMessage.java b/...-mysql/src/main/java/io/asyncer/r2dbc/mysql/message/server/DefinitionMetadataMessage.java
@@ -183,13 +183,8 @@ private static DefinitionMetadataMessage decode41(ByteBuf buf, ConnectionContext
 
         String extendTypeInfo = null;
         if (context.getCapability().isMariaDb() &&  context.getCapability().isExtendedTypeInfo()) {
-            buf.markReaderIndex();
-            short extendedTypeInfoDataType = buf.readUnsignedByte();
-            if (extendedTypeInfoDataType == 0 || extendedTypeInfoDataType == 1) {
-                extendTypeInfo = readVarIntSizedString(buf, charset);
-            } else {
-                buf.resetReaderIndex();
-            }
+            buf.readUnsignedByte();
+            extendTypeInfo = readVarIntSizedString(buf, charset);
         }
 
         // Skip constant 0x0c encoded by var integer