Changed decode41

Author: svats0001

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/message/server/DefinitionMetadataMessage.java

@@ -175,7 +175,6 @@ private static DefinitionMetadataMessage decode41(ByteBuf buf, ConnectionContext
 
         CharCollation collation = context.getClientCollation();
         Charset charset = collation.getCharset();
-        System.out.println("Buffer val: " + buf);
         String database = readVarIntSizedString(buf, charset);
         String table = readVarIntSizedString(buf, charset);
         String originTable = readVarIntSizedString(buf, charset);
@@ -184,8 +183,13 @@ private static DefinitionMetadataMessage decode41(ByteBuf buf, ConnectionContext
 
         String extendTypeInfo = null;
         if (context.getCapability().isMariaDb() &&  context.getCapability().isExtendedTypeInfo()) {
-            buf.readUnsignedByte();
-            extendTypeInfo = readVarIntSizedString(buf, charset);
+            buf.markReaderIndex();
+            short extendedTypeInfoDataType = buf.readUnsignedByte();
+            if (extendedTypeInfoDataType == 0 || extendedTypeInfoDataType == 1) {
+                extendTypeInfo = readVarIntSizedString(buf, charset);
+            } else {
+                buf.resetReaderIndex();
+            }
         }
 
         // Skip constant 0x0c encoded by var integer