fixed unit tests

Author: kerryjiang

tests/Test/MainTest.cs

@@ -141,21 +141,23 @@ public async Task TestUpdateEvent()
             }
         }
 
-        //[Fact]
+        [Fact]
         public async Task TestGetEventLogStream()
         {
+            var mysqlFixture = MySQLFixture.CreateMySQLFixture(3);
+
             // Insert a new pet
-            var cmd = _mysqlFixture.CreateCommand();
+            var cmd = mysqlFixture.CreateCommand();
             cmd.CommandText = "INSERT INTO pet (name, owner, species, sex, birth, death) values ('Buddy', 'Alex', 'dog', 'M', '2020-01-15', NULL); SELECT LAST_INSERT_ID();";
             var id = (UInt64)(await cmd.ExecuteScalarAsync());
 
             // Update the pet
-            cmd = _mysqlFixture.CreateCommand();
+            cmd = mysqlFixture.CreateCommand();
             cmd.CommandText = $"UPDATE pet SET owner='Sarah' WHERE id={id}";
             await cmd.ExecuteNonQueryAsync();
 
             // Delete the pet
-            cmd = _mysqlFixture.CreateCommand();
+            cmd = mysqlFixture.CreateCommand();
             cmd.CommandText = $"DELETE FROM pet WHERE id={id}";
             await cmd.ExecuteNonQueryAsync();
 
@@ -166,7 +168,7 @@ public async Task TestGetEventLogStream()
             var sawDelete = false;
 
             // Process only the next 5 events (or fewer if we reach the end)
-            await foreach (var logEvent in _mysqlFixture.Client.GetEventLogStream())
+            await foreach (var logEvent in mysqlFixture.Client.GetEventLogStream())
             {
                 eventCount++;
                 _outputHelper.WriteLine($"Event type: {logEvent.EventType}");

tests/Test/MySQLFixture.cs

@@ -13,21 +13,29 @@ public class MySQLFixture : IDisposable
         internal const string Username = "root";
         internal const string Password = "root";
 
+        private readonly int _serverId;
+
         public IReplicationClient Client { get; private set; }
 
         private SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
 
-        public static MySQLFixture Instance { get; } = new MySQLFixture();
+        public static MySQLFixture Instance { get; } = new MySQLFixture(1);
+
+        internal static MySQLFixture CreateMySQLFixture(int serverId)
+        {
+            return new MySQLFixture(serverId);
+        }
 
-        private MySQLFixture()
+        private MySQLFixture(int serverId)
         {
+            this._serverId = serverId;
             Client = new ReplicationClient();
             ConnectAsync().Wait();
         }
 
         private async Task ConnectAsync()
         {
-            await Client.ConnectAsync(Host, Username, Password, 1);
+            await Client.ConnectAsync(Host, Username, Password, _serverId);
         }
 
         private MySqlConnection GetConnection()