SegmentLinkedList

Author: csbernath

Foundation/.NetStandard-2.0/Collections/ReadOnly/IEnumerableExtensions.cs

@@ -15,6 +15,18 @@ public static ReadOnlyList<T> ToReadOnlyList<T>(this IEnumerable<T> source)
             return list.ToReadOnlyList();
         }
 
+        public static ReadOnlySegmentLinkedList<T> ToReadOnlySegmentLinkedList<T>(this IEnumerable<T> source, int segmentLength)
+        {
+            Assert.IsNotNull(source);
+            var segmentLinkedListBuilder = new SegmentLinkedListBuilder<T>(segmentLength);
+
+            foreach (var item in source)
+                segmentLinkedListBuilder.Add(item);
+
+            var readOnlySegmentLinkedList = segmentLinkedListBuilder.ToReadOnlySegmentLinkedList();
+            return readOnlySegmentLinkedList;
+        }
+
         public static ReadOnlySortedList<TKey, TValue> ToReadOnlySortedList<TKey, TValue>(this IEnumerable<TValue> values, Func<TValue, TKey> keySelector)
         {
             Assert.IsNotNull(values);

Foundation/.NetStandard-2.0/Collections/ReadOnly/ReadOnlySegmentLinkeList.cs

@@ -0,0 +1,38 @@
+using System.Collections;
+using System.Collections.Generic;
+using Foundation.Assertions;
+
+namespace Foundation.Collections.ReadOnly
+{
+    public class ReadOnlySegmentLinkedList<T> : IEnumerable<T>
+    {
+        private readonly LinkedList<T[]> _linkedList;
+        private readonly int _count;
+
+        public ReadOnlySegmentLinkedList(LinkedList<T[]> linkedList, int count)
+        {
+            Assert.IsNotNull(linkedList);
+            Assert.IsInRange(count >= 0);
+
+            _linkedList = linkedList;
+            _count = count;
+        }
+
+        public int Count => _count;
+
+        public IEnumerator<T> GetEnumerator()
+        {
+            var linkedListNode = _linkedList.First;
+            while (linkedListNode != null)
+            {
+                var segment = linkedListNode.Value;
+                var count = linkedListNode != _linkedList.Last ? segment.Length : _count % segment.Length;
+                for (var i = 0; i < count; ++i)
+                    yield return segment[i];
+                linkedListNode = linkedListNode.Next;
+            }
+        }
+
+        IEnumerator IEnumerable.GetEnumerator() => GetEnumerator();
+    }
+}

Foundation/.NetStandard-2.0/Collections/SegmentLinkedListBuilder.cs

@@ -0,0 +1,37 @@
+using System.Collections.Generic;
+using Foundation.Assertions;
+using Foundation.Collections.ReadOnly;
+
+namespace Foundation.Collections
+{
+    public class SegmentLinkedListBuilder<T>
+    {
+        private readonly LinkedList<T[]> _linkedList = new LinkedList<T[]>();
+        private readonly int _segmentLength;
+        private int _count = 0;
+
+        public SegmentLinkedListBuilder(int segmentLength)
+        {
+            Assert.IsInRange(segmentLength > 0);
+            _segmentLength = segmentLength;
+        }
+
+        public void Add(T item)
+        {
+            T[] segment;
+            var index = _count % _segmentLength;
+            if (index == 0)
+            {
+                segment = new T[_segmentLength];
+                _linkedList.AddLast(segment);
+            }
+            else
+                segment = _linkedList.Last.Value;
+
+            segment[index] = item;
+            ++_count;
+        }
+
+        public ReadOnlySegmentLinkedList<T> ToReadOnlySegmentLinkedList() => new ReadOnlySegmentLinkedList<T>(_linkedList, _count);
+    }
+}

Foundation/.NetStandard-2.0/Data/DbProviderFactoryExtensions.cs

@@ -26,6 +26,16 @@ public static DataTable ExecuteDataTable(this DbProviderFactory factory, DbConne
             return table;
         }
 
+        public static DataTable ExecuteDataTable(this DbProviderFactory dbProviderFactory, string connectionString, string commandText)
+        {
+            using (var connection = dbProviderFactory.CreateConnection())
+            {
+                connection.ConnectionString = connectionString;
+                connection.Open();
+                return ExecuteDataTable(dbProviderFactory, connection, commandText);
+            }
+        }
+
         public static void ExecuteReader(this DbProviderFactory dbProviderFactory, string connectionString, ExecuteReaderRequest request,
             Action<IDataReader> read)
         {

Foundation/.NetStandard-2.0/Data/DbQueryBuilding/DbRequestBuilder.cs

@@ -288,7 +288,8 @@ private string GetExecuteReaderMethod()
                     next = "Next";
                 }
 
-                stringBuilder.Append($"        var {ToLower(result.FieldName)} = dataReader.Read{next}Result(Read{result.Name}).ToReadOnlyList();");
+                stringBuilder.Append(
+                    $"        var {ToLower(result.FieldName)} = dataReader.Read{next}Result(Read{result.Name}).ToReadOnlySegmentLinkedList(128);");
             }
 
             stringBuilder.Append($"\r\n        result = new {_request.Name}DbQueryResult(");
@@ -369,7 +370,7 @@ private string GetExecuteReaderAsyncMethodFragment()
             {
                 var next = sequence.Next() == 0 ? null : "Next";
                 stringBuilder.Append(
-                    $"var {ToLower(result.FieldName)} = (await dataReader.Read{next}ResultAsync(Read{result.Name}, request.CancellationToken)).ToReadOnlyList();\r\n");
+                    $"var {ToLower(result.FieldName)} = (await dataReader.Read{next}ResultAsync(Read{result.Name}, request.CancellationToken)).ToReadOnlySegmentLinkedList(128);\r\n");
             }
 
             stringBuilder.Append($"result = new {_request.Name}DbQueryResult({GetResultVariableNames()});");
@@ -387,7 +388,7 @@ private string GetQueryResultClass()
                 if (sequence.Next() > 0)
                     stringBuilder.Append("\r\n");
 
-                stringBuilder.Append($"    public readonly ReadOnlyList<{result.Name}> {result.FieldName};");
+                stringBuilder.Append($"    public readonly ReadOnlySegmentLinkedList<{result.Name}> {result.FieldName};");
             }
 
             stringBuilder.Append("\r\n\r\n");
@@ -407,7 +408,7 @@ private string GetQueryResultClassConstructor(ReadOnlyList<DbQueryResult> result
                 if (sequence.Next() > 0)
                     stringBuilder.Append(", ");
 
-                stringBuilder.Append($"ReadOnlyList<{result.Name}> {ToLower(result.FieldName)}");
+                stringBuilder.Append($"ReadOnlySegmentLinkedList<{result.Name}> {ToLower(result.FieldName)}");
             }
 
             stringBuilder.Append(")\r\n");