chore(release): bump version to 1.5.1

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.5.0</Version>
+    <Version>1.5.1</Version>
   </PropertyGroup>
 </Project>

src/CosmoSQLClient.Core/CosmoSQLClient.Core.csproj

@@ -1,14 +1,14 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFrameworks>net10.0;netstandard2.0</TargetFrameworks>
     <AssemblyName>CosmoSQLClient.Core</AssemblyName>
     <RootNamespace>CosmoSQLClient.Core</RootNamespace>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 
     <PackageId>CosmoSQLClient.Core</PackageId>
-    <Version>1.5.0</Version>
+    <Version>1.5.1</Version>
     <Authors>Veeran Puthumkara</Authors>
     <Description>Shared core types and interfaces for CosmoSQLClient — a unified .NET database driver for MSSQL, PostgreSQL, MySQL and SQLite using DotNetty.</Description>
     <PackageTags>sql;mssql;postgres;mysql;sqlite;database;driver;dotnetty;nio</PackageTags>
@@ -22,6 +22,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="System.Text.Json" Version="10.0.0" />
+    <PackageReference Include="Microsoft.Bcl.AsyncInterfaces" Version="10.0.0" />
+    <PackageReference Include="System.Threading.Channels" Version="9.0.0" />
     <None Include="..\..\README.md" Pack="true" PackagePath="\" />
   </ItemGroup>
 

src/CosmoSQLClient.Core/ISqlDatabase.cs

@@ -196,13 +196,23 @@ public static System.Data.DataRow ToDataRow(this SqlRow row)
     ///               onError:    ex => MessageBox.Show(ex.Message));
     /// </code>
     /// </example>
+#if !NET10_0_OR_GREATER
     public static async Task FillDataTableAsync(
         this IAsyncEnumerable<SqlRow> rows,
         System.Data.DataTable table,
         int batchSize = 500,
         Action<int>? onProgress = null,
         Action<Exception>? onError = null,
         CancellationToken ct = default)
+#else
+    public static async Task FillDataTableAsync(
+        this IAsyncEnumerable<SqlRow> rows,
+        System.Data.DataTable table,
+        int batchSize = 500,
+        Action<int>? onProgress = null,
+        Action<Exception>? onError = null,
+        CancellationToken ct = default)
+#endif
     {
         // Bounded channel: producer (background) reads network; consumer (UI thread) flushes batches.
         // Capacity of 4 batches provides back-pressure so we don't read infinitely ahead of the UI.
@@ -269,6 +279,33 @@ public static async Task FillDataTableAsync(
         await producer;
     }
 
+#if !NET10_0_OR_GREATER
+    private static void FlushBatch(System.Data.DataTable table, List<SqlRow> batch)
+    {
+        // Add column schema from first batch
+        if (table.Columns.Count == 0)
+        {
+            foreach (var col in batch[0].Columns)
+                table.Columns.Add(col.Name, typeof(object));
+        }
+
+        table.BeginLoadData(); // suspend DataGridView notifications and index rebuilds
+        try
+        {
+            foreach (var row in batch)
+            {
+                var dataRow = table.NewRow();
+                for (int i = 0; i < row.ColumnCount; i++)
+                    dataRow[i] = row[i].ToClrObject() ?? DBNull.Value;
+                table.Rows.Add(dataRow);
+            }
+        }
+        finally
+        {
+            table.EndLoadData(); // one bulk notification → one DataGridView refresh
+        }
+    }
+#else
     private static void FlushBatch(System.Data.DataTable table, List<SqlRow> batch)
     {
         // Add column schema from first batch
@@ -294,4 +331,5 @@ private static void FlushBatch(System.Data.DataTable table, List<SqlRow> batch)
             table.EndLoadData(); // one bulk notification → one DataGridView refresh
         }
     }
+#endif
 }

src/CosmoSQLClient.Core/Polyfills.cs

@@ -0,0 +1,36 @@
+#if !NET10_0_OR_GREATER
+
+namespace System.Runtime.CompilerServices
+{
+    using System.ComponentModel;
+
+    [EditorBrowsable(EditorBrowsableState.Never)]
+    internal static class IsExternalInit { }
+
+    [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Field | AttributeTargets.Property, AllowMultiple = false, Inherited = false)]
+    internal sealed class RequiredMemberAttribute : Attribute { }
+
+    [AttributeUsage(AttributeTargets.All, AllowMultiple = true, Inherited = false)]
+    internal sealed class CompilerFeatureRequiredAttribute : Attribute
+    {
+        public CompilerFeatureRequiredAttribute(string featureName) { FeatureName = featureName; }
+        public string FeatureName { get; }
+        public bool IsOptional { get; set; }
+        public const string RequiredMembers = nameof(RequiredMembers);
+        public const string RefStructs = nameof(RefStructs);
+    }
+}
+
+namespace System.Diagnostics.CodeAnalysis
+{
+    [AttributeUsage(AttributeTargets.Constructor, AllowMultiple = false, Inherited = false)]
+    internal sealed class SetsRequiredMembersAttribute : Attribute { }
+
+    [AttributeUsage(AttributeTargets.Field | AttributeTargets.Parameter | AttributeTargets.Property, Inherited = false)]
+    internal sealed class AllowNullAttribute : Attribute { }
+
+    [AttributeUsage(AttributeTargets.Field | AttributeTargets.Parameter | AttributeTargets.Property, Inherited = false)]
+    internal sealed class DisallowNullAttribute : Attribute { }
+}
+
+#endif

src/CosmoSQLClient.Core/SqlDataTable.cs

@@ -100,7 +100,10 @@ private static Type SqlValueClrType(SqlColumn col)
 
         // Pre-resolve column index → property mapping once, reused for all rows.
         var map = Columns
-            .Select((col, idx) => (idx, prop: props.GetValueOrDefault(col.Name)))
+            .Select((col, idx) => {
+                props.TryGetValue(col.Name, out var p);
+                return (idx, prop: p);
+            })
             .Where(x => x.prop is not null)
             .ToList();
 

src/CosmoSQLClient.Core/SqlDump.cs

@@ -37,7 +37,7 @@ public static string GenerateInserts(SqlDataTable table, string? targetTableName
         SqlValue.Double d  => d.Value.ToString("R"),
         SqlValue.Decimal d => d.Value.ToString(),
         SqlValue.Text s    => $"'{s.Value.Replace("'", "''")}'",
-        SqlValue.Bytes b   => $"0x{Convert.ToHexString(b.Value)}",
+        SqlValue.Bytes b   => $"0x{BitConverter.ToString(b.Value).Replace("-", "")}",
         SqlValue.Uuid u    => $"'{u.Value}'",
         SqlValue.Date d    => $"'{d.Value:O}'",
         _                  => "NULL"

src/CosmoSQLClient.Core/SqlRowDecoder.cs

@@ -66,12 +66,12 @@ private static string ToSnakeCase(string s)
 
     private static string ToCamelCase(string s)
     {
-        var parts = s.Split('_', StringSplitOptions.RemoveEmptyEntries);
+        var parts = s.Split(new[] { '_' }, StringSplitOptions.RemoveEmptyEntries);
         if (parts.Length == 0) return s;
         var sb = new System.Text.StringBuilder(parts[0]);
         for (int i = 1; i < parts.Length; i++)
             if (parts[i].Length > 0)
-                sb.Append(char.ToUpper(parts[i][0])).Append(parts[i][1..]);
+                sb.Append(char.ToUpper(parts[i][0])).Append(parts[i].Substring(1));
         return sb.ToString();
     }
 
@@ -86,7 +86,7 @@ private static string ToCamelCase(string s)
         {
             if (v is SqlValue.Bool b)  return b.Value;
             if (v.AsInt() is long l)   return l != 0;
-            if (v.AsString() is string s) return s is "1" or "true" or "yes";
+            if (v.AsString() is string s) return s == "1" || s == "true" || s == "yes";
             return null;
         }
         // Guid
@@ -115,8 +115,14 @@ private static string ToCamelCase(string s)
         {
             if (v.AsString() is string s)
             {
-                if (Enum.TryParse(underlying, s, true, out var result))
-                    return result;
+                try
+                {
+                    return Enum.Parse(underlying, s, true);
+                }
+                catch
+                {
+                    return null;
+                }
             }
             if (v.AsInt() is long l)
             {

src/CosmoSQLClient.MsSql/CosmoSQLClient.MsSql.csproj

@@ -13,14 +13,14 @@
   </ItemGroup>
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFrameworks>net10.0;netstandard2.0</TargetFrameworks>
     <AssemblyName>CosmoSQLClient.MsSql</AssemblyName>
     <RootNamespace>CosmoSQLClient.MsSql</RootNamespace>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
 
     <PackageId>CosmoSQLClient.MsSql</PackageId>
-    <Version>1.5.0</Version>
+    <Version>1.5.1</Version>
     <Authors>Veeran Puthumkara</Authors>
     <Description>Microsoft SQL Server driver for CosmoSQLClient — TDS 7.4 wire protocol from scratch using DotNetty. Supports TLS, Windows/SQL auth, stored procedures and connection pooling.</Description>
     <PackageTags>sql;mssql;sqlserver;tds;database;driver;dotnetty;nio</PackageTags>

src/CosmoSQLClient.MsSql/JsonChunkAssembler.cs

@@ -42,12 +42,9 @@ public static async IAsyncEnumerable<JsonElement> AssembleJsonObjectsAsync(
         {
             if (string.IsNullOrEmpty(chunk)) continue;
 
-            // ── Encode chunk UTF-8 directly into the MemoryStream's backing array ──
-            // Avoids the intermediate byte[] allocation from Encoding.UTF8.GetBytes(string).
-            int byteCount = Encoding.UTF8.GetByteCount(chunk);
-            int oldLen    = (int)buf.Length;
-            buf.SetLength(oldLen + byteCount);
-            Encoding.UTF8.GetBytes(chunk.AsSpan(), buf.GetBuffer().AsSpan(oldLen, byteCount));
+            // ── Encode chunk UTF-8 directly into the MemoryStream ──
+            var bytes = Encoding.UTF8.GetBytes(chunk);
+            buf.Write(bytes, 0, bytes.Length);
 
             // Inner loop: drain as many complete elements as possible from the current buffer.
             bool madeProgress;