SQl client refactored

2023-06-06 10:02:04 +02:00
parent 5c42eee949
commit f0155aeb95
28 changed files with 1104 additions and 1378 deletions
@@ -0,0 +1,108 @@
+namespace LaaProductionWeb.Data
+{
+    using LaaProductionWeb.Data.Interfaces;
+
+    using System;
+    using System.Collections.Generic;
+    using System.Data;
+    using System.Data.SqlClient;
+    using System.Linq;
+
+    public class FluentSQL : IFluentSQL
+    {
+        private readonly string connectionString;
+
+        public FluentSQL(string connectionString)
+        {
+            var connectionStringBuilder = new SqlConnectionStringBuilder(connectionString);
+
+            this.connectionString = connectionStringBuilder.ToString();
+        }
+
+        public FluentSQLCommand CreateCommand(string commandText) 
+            => new FluentSQLCommand(this, commandText);
+
+        internal int ExecuteNonQuery(FluentSQLCommand command)
+        {
+            command.ThrowIfNull();
+
+            var rowsAffected = 0;
+
+            using (var sqlConnection = new SqlConnection(this.connectionString))
+            {
+                sqlConnection.OpenWithErrorHandling();
+
+                using (var sqlCommand = sqlConnection.CreateCommand())
+                {
+                    sqlCommand.CommandText = command.CommandText;
+
+                    sqlCommand.Parameters.AddRange(command.Parameters);
+
+                    rowsAffected = sqlCommand.ExecuteNonQuery();
+                }
+            }
+
+            return rowsAffected;
+        }
+
+        internal IEnumerable<T> ExecuteReader<T>(FluentSQLCommand command, Func<IFluentSQLReader, T> expression)
+        {
+            command.ThrowIfNull();
+            expression.ThrowIfNull();
+
+            using (var sqlConnection = new SqlConnection(this.connectionString))
+            {
+                sqlConnection.OpenWithErrorHandling();
+
+                using (var sqlCommand = sqlConnection.CreateCommand())
+                {
+                    sqlCommand.CommandText = command.CommandText;
+
+                    sqlCommand.Parameters.AddRange(command.Parameters);
+
+                    using (FluentSQLReader sqlReader = sqlCommand.ExecuteReader(CommandBehavior.SequentialAccess))
+                    {
+                        while (sqlReader.Read())
+                        {
+                            yield return expression(sqlReader);
+                        }
+                    }
+                }
+            }
+        }
+
+        internal T ExecuteScalar<T>(FluentSQLCommand command, Func<IFluentSQLReader, T> expression)
+        {
+            command.ThrowIfNull();
+            expression.ThrowIfNull();
+
+            var scalarResult = default(T);
+
+            using (var sqlConnection = new SqlConnection(this.connectionString))
+            {
+                sqlConnection.OpenWithErrorHandling();
+
+                using (var sqlCommand = sqlConnection.CreateCommand())
+                {
+                    sqlCommand.CommandText = command.CommandText;
+
+                    sqlCommand.Parameters.AddRange(command.Parameters);
+
+                    var scalarObject = sqlCommand.ExecuteScalar();
+
+                    if (scalarObject is T scalarValue)
+                    {
+                        scalarResult = scalarValue;
+                    }
+                }
+            }
+
+            return scalarResult;
+        }
+
+        internal T FirstOrDefault<T>(FluentSQLCommand command, Func<IFluentSQLReader, T> expression) 
+            => this
+                .ExecuteReader(command, expression)
+                .FirstOrDefault();
+    }
+}