fix: add table exists exception catch

masastack · Dec 4, 2023 · 82291b6 · 82291b6
1 parent 1edb818
commit 82291b6
Showing 1 changed file with 14 additions and 7 deletions.
diff --git a/src/Contrib/StackSdks/Tests/Masa.Contrib.StackSdks.Tsc.Clickhouse.Tests/Common.cs b/src/Contrib/StackSdks/Tests/Masa.Contrib.StackSdks.Tsc.Clickhouse.Tests/Common.cs
@@ -16,8 +16,16 @@ public static void InitTable(bool isLog)
         {
             var sql = reader.ReadToEnd();
             cmd.CommandText = sql;
-            cmd.ExecuteNonQuery();
+            try
+            {
+                cmd.ExecuteNonQuery();
+            }
+            catch
+            {
+                //table is exists
+            }
         }
+
         path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, $"Data/otel_{name}_data.txt");
         using (var dataReader = new StreamReader(path))
         {
@@ -34,11 +42,10 @@ public static void InitTableData(bool isLog)
         connection.Open();
         using var cmd = connection.CreateCommand();
         var path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, $"Data/otel_{name}_data.txt");
-        using (var dataReader = new StreamReader(path))
-        {
-            var sql = dataReader.ReadToEnd();
-            cmd.CommandText = sql;
-            cmd.ExecuteNonQuery();
-        }
+        using var dataReader = new StreamReader(path);
+        var sql = dataReader.ReadToEnd();
+        cmd.CommandText = sql;
+        cmd.ExecuteNonQuery();
+
     }
 }