tried to supprot enum and set

Author: kerryjiang

src/SciSharp.MySQL.Replication/ColumnMetadata.cs

@@ -20,7 +20,7 @@ public class ColumnMetadata
             /// <summary>
             /// Gets or sets the metadata value associated with the column.
             /// </summary>
-            public short MetadataValue { get; set; }
+            public ushort MetadataValue { get; set; }
 
             /// <summary>
             /// Gets or sets the column max value length.

src/SciSharp.MySQL.Replication/Events/EnumTypeTableMetadataInitializer.cs

@@ -0,0 +1,33 @@
+using System;
+using SciSharp.MySQL.Replication.Types;
+
+namespace SciSharp.MySQL.Replication.Events
+{
+    class EnumTypeTableMetadataInitializer : ITableMetadataInitializer
+    {
+        public void InitializeMetadata(TableMetadata metadata)
+        {
+            var enumColumnIndex = 0;
+
+            foreach (var column in metadata.Columns)
+            {
+                if (!IsEnumColumn(column))
+                    continue;
+
+                column.EnumValues = metadata.EnumStrValues[enumColumnIndex++];
+            }
+        }
+
+        private bool IsEnumColumn(ColumnMetadata columnMetadata)
+        {
+            if (columnMetadata.Type == ColumnType.ENUM)
+                return true;
+
+            if (columnMetadata.Type != ColumnType.STRING)
+                return false;
+            
+            // Len = 1 or 2
+            return (columnMetadata.MetadataValue & 0xFF) < 3;
+        }
+    }
+}

src/SciSharp.MySQL.Replication/Events/ITableMetadataInitializer.cs

@@ -0,0 +1,7 @@
+namespace SciSharp.MySQL.Replication.Events
+{
+    interface ITableMetadataInitializer
+    {
+        void InitializeMetadata(TableMetadata tableMetadata);
+    }
+}

src/SciSharp.MySQL.Replication/Events/LogEvent.cs

@@ -69,7 +69,8 @@ static LogEvent()
             DataTypes[(int)ColumnType.DATETIME] = new DateTimeType();
             DataTypes[(int)ColumnType.DATETIME_V2] = new DateTimeV2Type();
             //DataTypes[(int)ColumnType.TIMESTAMP] = new TimestampType();
-            //DataTypes[(int)ColumnType.ENUM] = new EnumType();
+            DataTypes[(int)ColumnType.ENUM] = new EnumType();
+            DataTypes[(int)ColumnType.SET] = new SetType();
         }
 
         /// <summary>

src/SciSharp.MySQL.Replication/Events/NumericTypeTableMetadataInitializer.cs

@@ -0,0 +1,24 @@
+using System;
+using SciSharp.MySQL.Replication.Types;
+
+namespace SciSharp.MySQL.Replication.Events
+{
+    class NumericTypeTableMetadataInitializer : ITableMetadataInitializer
+    {
+        public void InitializeMetadata(TableMetadata metadata)
+        {
+            var numericColumnIndex = 0;
+
+            foreach (var column in metadata.Columns)
+            {
+                if (!column.Type.IsNumberColumn())
+                    continue;
+
+                column.IsUnsigned = metadata.Signedness[numericColumnIndex];
+                column.NumericColumnIndex = numericColumnIndex;
+
+                numericColumnIndex++;
+            }
+        }
+    }
+}

src/SciSharp.MySQL.Replication/Events/SetTypeTableMetadataInitializer.cs

@@ -0,0 +1,22 @@
+using System;
+using SciSharp.MySQL.Replication.Types;
+
+namespace SciSharp.MySQL.Replication.Events
+{
+    class SetTypeTableMetadataInitializer : ITableMetadataInitializer
+    {
+        public void InitializeMetadata(TableMetadata metadata)
+        {
+            var setColumnIndex = 0;
+
+            foreach (var column in metadata.Columns)
+            {
+                if (column.Type != ColumnType.SET)
+                    continue;
+
+                column.SetValues = metadata.SetStrValues[setColumnIndex];
+                setColumnIndex++;
+            }
+        }
+    }
+}

src/SciSharp.MySQL.Replication/Events/TableMapEvent.cs

@@ -55,6 +55,13 @@ public sealed class TableMapEvent : LogEvent
         /// Gets or sets the metadata of the table.
         /// </summary>
         public TableMetadata Metadata { get; set; }
+
+        private readonly IReadOnlyList<ITableMetadataInitializer> _tableMetadataInitializers = new List<ITableMetadataInitializer>
+        {
+            new NumericTypeTableMetadataInitializer(),
+            new EnumTypeTableMetadataInitializer(),
+            new SetTypeTableMetadataInitializer()
+        };
 
         /// <summary>
         /// Initializes a new instance of the <see cref="TableMapEvent"/> class.
@@ -100,6 +107,11 @@ protected internal override void DecodeBody(ref SequenceReader<byte> reader, obj
 
             Metadata = ReadTableMetadata(ref reader);
 
+            foreach (var tableMetadataInitializer in _tableMetadataInitializers)
+            {
+                tableMetadataInitializer.InitializeMetadata(Metadata);
+            }
+
             foreach (var columnMetadata in Metadata.Columns)
             {
                 var valueTypeIndex = (int)columnMetadata.Type;

src/SciSharp.MySQL.Replication/TableMetadata.cs

@@ -89,25 +89,16 @@ public void BuildColumnMetadataList(IReadOnlyList<ColumnType> columnTypes, IRead
         {
             var columnMetadatas = new List<ColumnMetadata>(ColumnNames.Count);
 
-            var numericColumnIndex = -1;
-
             for (int i = 0; i < columnTypes.Count; i++)
             {
                 var columnType = columnTypes[i];
-                var isNumberColumn = columnType.IsNumberColumn();
-                numericColumnIndex++;
 
                 var columnMetadata = new ColumnMetadata
                 {
                     Name = ColumnNames[i],
                     Type = columnType,
                     CharsetId = ColumnCharsets != null ? ColumnCharsets[i] : 0,
-                    //If the bit is set (1), the column is UNSIGNED; if not set (0), it's SIGNED (default)
-                    IsUnsigned = isNumberColumn ? Signedness[numericColumnIndex] : false,
-                    EnumValues = EnumStrValues != null ? EnumStrValues[i] : null,
-                    SetValues = SetStrValues != null  ? SetStrValues[i] : null,
-                    MetadataValue = (short)columnMetadataValues[i],
-                    NumericColumnIndex = isNumberColumn ? numericColumnIndex : -1
+                    MetadataValue = (ushort)columnMetadataValues[i]
                 };
 
                 columnMetadatas.Add(columnMetadata);

src/SciSharp.MySQL.Replication/Types/EnumType.cs

@@ -11,25 +11,37 @@ namespace SciSharp.MySQL.Replication.Types
     /// <remarks>
     /// Handles the reading and conversion of MySQL ENUM values.
     /// </remarks>
-    class EnumType : IMySQLDataType
+    class EnumType : IMySQLDataType, IColumnMetadataLoader
     {
+        public void LoadMetadataValue(ColumnMetadata columnMetadata)
+        {
+            columnMetadata.MaxLength = columnMetadata.MetadataValue & 0xFF;
+        }
+
         /// <summary>
         /// Reads an ENUM value from the binary log.
         /// </summary>
         /// <param name="reader">The sequence reader containing the bytes to read.</param>
         /// <param name="columnMetadata">Metadata for the column.</param>
         /// <returns>An integer representing the index of the ENUM value.</returns>
-        public object ReadValue(ref SequenceReader<byte> reader, ColumnMetadata columnMetadata)
+        public virtual object ReadValue(ref SequenceReader<byte> reader, ColumnMetadata columnMetadata)
         {
-            var enumIndex = reader.ReadInteger(2);
+            var enumIndex = columnMetadata.MaxLength == 1
+                ? reader.TryRead(out byte l) ? (int)l : 0
+                : reader.TryReadLittleEndian(out short sl) ? (int)sl : 0;
 
             // Out of range check
             if (enumIndex >= columnMetadata.EnumValues.Count)
             {
                 return null;
             }
 
-            return columnMetadata.EnumValues[enumIndex];
+            if (enumIndex == 0)
+            {
+                return string.Empty;
+            }
+
+            return columnMetadata.EnumValues[enumIndex - 1];
         }
     }
 }

src/SciSharp.MySQL.Replication/Types/SetType.cs

@@ -10,8 +10,13 @@ namespace SciSharp.MySQL.Replication.Types
     /// <remarks>
     /// Handles the reading and conversion of MySQL SET values.
     /// </remarks>
-    class SetType : IMySQLDataType
+    class SetType : IMySQLDataType, IColumnMetadataLoader
     {
+        public void LoadMetadataValue(ColumnMetadata columnMetadata)
+        {
+            columnMetadata.MaxLength = columnMetadata.MetadataValue & 0xFF;
+        }
+
         /// <summary>
         /// Reads a SET value from the binary log.
         /// </summary>
@@ -20,18 +25,18 @@ class SetType : IMySQLDataType
         /// <returns>A long value representing the MySQL SET value as a bitmap.</returns>
         public object ReadValue(ref SequenceReader<byte> reader, ColumnMetadata columnMetadata)
         {
-            var setValue = reader.ReadLong(4);
+            var flags = reader.ReadLong(columnMetadata.MaxLength);
 
-            if (setValue == 0)
+            if (flags == 0)
             {
-                return 0;
+                return string.Empty;
             }
 
             var setCellValues = new List<string>();
 
             for (int i = 0; i < columnMetadata.SetValues.Count; i++)
             {
-                if ((setValue & (1 << i)) != 0)
+                if ((flags & (1 << i)) != 0)
                 {
                     setCellValues.Add(columnMetadata.SetValues[i]);
                 }