feat: implement AddWithValue across all providers and stabilize CI tests

Author: vkuttyp

Directory.Build.props

@@ -7,6 +7,6 @@
     <Authors>vkuttyp</Authors>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
     <RepositoryUrl>https://github.com/vkuttyp/CosmoSQLClient-Dotnet</RepositoryUrl>
-    <Version>1.9.0</Version>
+    <Version>1.9.1</Version>
   </PropertyGroup>
 </Project>

src/CosmoSQLClient.MsSql/MsSqlConnection.cs

@@ -35,7 +35,7 @@ public sealed record MsSqlConfiguration
 
     public static MsSqlConfiguration Parse(string connectionString)
     {
-        if (string.IsNullOrEmpty(connectionString)) return new MsSqlConfiguration { Host = "localhost", Database = "dummy" };
+        if (string.IsNullOrWhiteSpace(connectionString)) return new MsSqlConfiguration { Host = "localhost", Database = "dummy", TrustServerCertificate = true };
         var dict = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
         foreach (var part in connectionString.Split(new[] { ';' }, StringSplitOptions.RemoveEmptyEntries))
         {
@@ -177,7 +177,10 @@ private async Task ConnectTdsAsync(CancellationToken ct)
         if (_config.Encrypt)
         {
             var tdsTls = new TdsTlsStream(_stream!);
-            var ssl = new SslStream(tdsTls, true, (s, c, ch, err) => _config.TrustServerCertificate || err == SslPolicyErrors.None);
+            var ssl = new SslStream(tdsTls, true, (s, c, ch, err) => {
+                if (_config.TrustServerCertificate) return true;
+                return err == SslPolicyErrors.None;
+            });
             await ssl.AuthenticateAsClientAsync(_config.Host).ConfigureAwait(false);
             tdsTls.SwitchToPassthrough();
 

src/CosmoSQLClient.MySql/MySqlCommand.cs

@@ -53,6 +53,14 @@ public override int IndexOf(string parameterName)
         return -1;
     }
     public override void Insert(int index, object value) => _params.Insert(index, (MySqlParameter)value);
+
+    public MySqlParameter AddWithValue(string name, object? value)
+    {
+        var p = new MySqlParameter(name, value);
+        _params.Add(p);
+        return p;
+    }
+
     public override void Remove(object value) => _params.Remove((MySqlParameter)value);
     public override void RemoveAt(int index) => _params.RemoveAt(index);
     public override void RemoveAt(string parameterName) { int i = IndexOf(parameterName); if (i != -1) _params.RemoveAt(i); }

src/CosmoSQLClient.Postgres/PostgresParameter.cs

@@ -83,6 +83,14 @@ public sealed class PostgresParameterCollection : DbParameterCollection
     public override System.Collections.IEnumerator GetEnumerator() => _params.GetEnumerator();
     public override int IndexOf(object value) => _params.IndexOf((PostgresParameter)value);
     public override int IndexOf(string parameterName) => GetIndex(parameterName);
+
+    public PostgresParameter AddWithValue(string name, object? value)
+    {
+        var p = new PostgresParameter(name, value);
+        _params.Add(p);
+        return p;
+    }
+
     public override void Insert(int index, object value) => _params.Insert(index, (PostgresParameter)value);
     public override void Remove(object value) => _params.Remove((PostgresParameter)value);
     public override void RemoveAt(int index) => _params.RemoveAt(index);

src/CosmoSQLClient.Sqlite/SqliteCommand.cs

@@ -53,6 +53,14 @@ public override int IndexOf(string parameterName)
         return -1;
     }
     public override void Insert(int index, object value) => _params.Insert(index, (SqliteParameter)value);
+
+    public SqliteParameter AddWithValue(string name, object? value)
+    {
+        var p = new SqliteParameter(name, value);
+        _params.Add(p);
+        return p;
+    }
+
     public override void Remove(object value) => _params.Remove((SqliteParameter)value);
     public override void RemoveAt(int index) => _params.RemoveAt(index);
     public override void RemoveAt(string parameterName) { int i = IndexOf(parameterName); if (i != -1) _params.RemoveAt(i); }

tests/CosmoSQLClient.MsSql.Tests/AdoNetTests.cs

@@ -39,7 +39,7 @@ private static bool ShouldSkip {
         }
     }
 
-    private static string ConnectionString => (EnvConn ?? "") + ";TrustServerCertificate=True";
+    private static string ConnectionString => (EnvConn ?? "") + (string.IsNullOrEmpty(EnvConn) ? "" : ";TrustServerCertificate=True");
 
     [Fact]
     public async Task StandardAdoNet_Flow_ShouldWork()
@@ -96,6 +96,23 @@ public async Task StandardAdoNet_Parameters_ShouldWork()
         Assert.Equal("Hello ADO.NET", result);
     }
 
+    [Fact]
+    public async Task StandardAdoNet_AddWithValue_ShouldWork()
+    {
+        if (ShouldSkip) return;
+
+        using var conn = new MsSqlConnection(ConnectionString);
+        await conn.OpenAsync();
+
+        using var cmd = new MsSqlCommand("SELECT @val AS Echo", conn);
+        
+        // This is the method the user reported missing in some versions/providers
+        cmd.Parameters.AddWithValue("@val", "Hello AddWithValue");
+
+        var result = await cmd.ExecuteScalarAsync();
+        Assert.Equal("Hello AddWithValue", result);
+    }
+
     [Fact]
     public async Task StandardAdoNet_Transactions_ShouldWork()
     {