tried to add MySQLConnection

Author: kerryjiang

src/SuperSocket.MySQL/IMySQLPacketFactory.cs

@@ -2,7 +2,7 @@
 
 namespace SuperSocket.MySQL
 {
-    public interface IMySQLPacketFactory
+    internal interface IMySQLPacketFactory
     {
         MySQLPacket Create(int packageType);
     }

src/SuperSocket.MySQL/MySQLConnection.cs

@@ -0,0 +1,60 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using System.Threading;
+using System.Threading.Tasks;
+using SuperSocket.Client;
+using SuperSocket.MySQL.Packets;
+using SuperSocket.ProtoBase;
+
+namespace SuperSocket.MySQL
+{
+    public class MySQLConnection : EasyClient<MySQLPacket>
+    {
+        private const int DefaultPort = 3306;
+        private readonly string _host;
+        private readonly int _port;
+        private readonly string _userName;
+        private readonly string _password;
+
+        private static readonly MySQLPacketEncoder PacketEncoder = new MySQLPacketEncoder();
+
+        public MySQLConnection(string host, int port, string userName, string password)
+            : this(new MySQLPacketFactory().RegisterPacketType<HandshakeResponsePacket>(0x00))
+        {
+            _host = host ?? throw new ArgumentNullException(nameof(host));
+            _port = port > 0 ? port : DefaultPort;
+            _userName = userName ?? throw new ArgumentNullException(nameof(userName));
+            _password = password ?? throw new ArgumentNullException(nameof(password));
+        }
+
+        internal MySQLConnection(IMySQLPacketFactory mySQLPacketFactory)
+            : this(new MySQLPacketDecoder(mySQLPacketFactory))
+        {
+        }
+
+        internal MySQLConnection(IPackageDecoder<MySQLPacket> packageDecoder)
+            : base(new MySQLPacketFilter(packageDecoder))
+        {
+        }
+
+        public async Task ConnectAsync(CancellationToken cancellationToken = default)
+        {
+            if (string.IsNullOrEmpty(_host))
+                throw new ArgumentException("Host cannot be null or empty.", nameof(_host));
+
+            if (_port <= 0)
+                throw new ArgumentOutOfRangeException(nameof(_port), "Port must be a positive integer.");
+
+            var endPoint = new DnsEndPoint(_host, _port);
+
+            await ConnectAsync(endPoint, cancellationToken).ConfigureAwait(false);
+
+            // Send initial handshake packet
+            var handshakePacket = new HandshakePacket();
+            await SendAsync(PacketEncoder, handshakePacket).ConfigureAwait(false);
+
+            // Handle authentication to be implemented here
+        }
+    }
+}

src/SuperSocket.MySQL/MySQLPacketDecoder.cs

@@ -4,7 +4,7 @@
 
 namespace SuperSocket.MySQL
 {
-    public class MySQLPacketDecoder : IPackageDecoder<MySQLPacket>
+    internal class MySQLPacketDecoder : IPackageDecoder<MySQLPacket>
     {
         private readonly IMySQLPacketFactory _packetFactory;
 

src/SuperSocket.MySQL/MySQLPacketFactory.cs

@@ -9,10 +9,11 @@ internal class MySQLPacketFactory : IMySQLPacketFactory
     {
         private readonly Dictionary<int, Func<MySQLPacket>> _packetCreators = new ();
 
-        public void RegisterPacketType<TMySQLPacket>(int packageType)
+        public MySQLPacketFactory RegisterPacketType<TMySQLPacket>(int packageType)
             where TMySQLPacket : MySQLPacket, new()
         {
             _packetCreators[packageType] = () => new TMySQLPacket();
+            return this;
         }
 
         public MySQLPacket Create(int packageType)

src/SuperSocket.MySQL/MySQLPacketFilter.cs

@@ -4,13 +4,14 @@
 
 namespace SuperSocket.MySQL
 {
-    public class MySQLPacketFilter : FixedHeaderPipelineFilter<MySQLPacket>
+    internal class MySQLPacketFilter : FixedHeaderPipelineFilter<MySQLPacket>
     {
         private const int headerSize = 4; // MySQL package header size is 4 bytes
 
-        public MySQLPacketFilter()
+        public MySQLPacketFilter(IPackageDecoder<MySQLPacket> decoder)
             : base(headerSize)
         {
+            this.Decoder = decoder ?? throw new ArgumentNullException(nameof(decoder));
         }
 
         protected override int GetBodyLengthFromHeader(ref ReadOnlySequence<byte> buffer)

src/SuperSocket.MySQL/SuperSocket.MySQL.csproj

@@ -3,6 +3,7 @@
     <TargetFrameworks>.net9</TargetFrameworks>
   </PropertyGroup>
   <ItemGroup>
+    <PackageReference Include="SuperSocket.Client" Version="2.0.1" />
     <PackageReference Include="SuperSocket.ProtoBase" Version="2.0.1" />
   </ItemGroup>
 </Project>