Add Addax with workaround

Workaround filed here: alexanderkozlenko/addax#21
joelverhagen · Jan 12, 2024 · 45fecf7 · 45fecf7
1 parent b8989a9
commit 45fecf7
Show file tree

Hide file tree

Showing 3 changed files with 73 additions and 0 deletions.
diff --git a/NCsvPerf/CsvReadable/Benchmarks/PackageAssetsSuite.cs b/NCsvPerf/CsvReadable/Benchmarks/PackageAssetsSuite.cs
@@ -56,6 +56,12 @@ private void Execute(ICsvReader reader)
             }
         }
 
+        [Benchmark]
+        public void Addax_Formats_Tabular()
+        {
+            Execute(new Addax_Formats_Tabular());
+        }
+
         [Benchmark]
         public void Angara_Table()
         {

diff --git a/NCsvPerf/CsvReadable/Implementations/Addax_Formats_Tabular.cs b/NCsvPerf/CsvReadable/Implementations/Addax_Formats_Tabular.cs
@@ -0,0 +1,66 @@
+using Addax.Formats.Tabular;
+using System.Collections.Generic;
+using System.IO;
+
+namespace Knapcode.NCsvPerf.CsvReadable
+{
+    /// <summary>
+    /// Package: https://www.nuget.org/packages/Addax.Formats.Tabular
+    /// Source: https://github.com/alexanderkozlenko/addax
+    /// </summary>
+    public class Addax_Formats_Tabular : ICsvReader
+    {
+        private readonly TabularDialect _dialect;
+
+        public Addax_Formats_Tabular()
+        {
+            _dialect = new TabularDialect("\r\n", ',', '\"');
+        }
+
+        public List<T> GetRecords<T>(MemoryStream stream) where T : ICsvReadable, new()
+        {
+            var allRecords = new List<T>();
+
+            using (var reader = new TabularReader(stream, _dialect))
+            {
+                while (reader.TryPickRecord())
+                {
+                    // workaround for https://github.com/alexanderkozlenko/addax/issues/21
+                    string firstValue;
+                    if (!reader.TryReadField() || !reader.TryGetString(out firstValue))
+                    {
+                        break;
+                    }
+
+                    string secondValue;
+                    if (!reader.TryReadField() || !reader.TryGetString(out secondValue))
+                    {
+                        break;
+                    }
+
+                    var record = new T();
+                    record.Read(i =>
+                    {
+                        if (i == 0)
+                        {
+                            return firstValue;
+                        }
+                        else if (i == 1)
+                        {
+                            return secondValue;
+                        }
+                        else if (reader.TryReadField() && reader.TryGetString(out var value))
+                        {
+                            return value;
+                        }
+
+                        return null;
+                    });
+                    allRecords.Add(record);
+                }
+            }
+
+            return allRecords;
+        }
+    }
+}
diff --git a/NCsvPerf/NCsvPerf.csproj b/NCsvPerf/NCsvPerf.csproj
@@ -9,6 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Addax.Formats.Tabular" Version="1.2.0" />
     <PackageReference Include="Angara.Table" Version="0.3.3" NoWarn="NU1701" />
     <PackageReference Include="Angara.Serialization" Version="0.3.0" NoWarn="NU1701" />
     <PackageReference Include="Angara.Statistics" Version="0.1.4" NoWarn="NU1701" />