Changes from 29.08.2023

ACCDataAdapter/ACCDataAdapter.csproj

@@ -7,6 +7,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="7.0.1" />
+    <PackageReference Include="Npgsql" Version="7.0.4" />
     <PackageReference Include="System.Data.SqlClient" Version="4.8.5" />
   </ItemGroup>
 

ACCDataAdapter/DPApp/BaseDAL.cs

@@ -1,7 +1,7 @@
 using ACCDataModel.DPApp;
 using System.Collections.Generic;
 using System.Data;
-using System.Data.SqlClient;
+using Npgsql;
 using System.Reflection;
 using System.Threading;
 using System.Threading.Tasks;
@@ -10,30 +10,30 @@ namespace ACCDataAdapter.DPApp
 {
     public abstract class BaseDAL
     {
-
+        // TODO: Überschreiben zu Pgsql
         protected string ConnectionString { get; set; }
 
         public BaseDAL(string connectionString)
         {
             ConnectionString = connectionString;
         }
 
-        protected async Task<SqlConnection> GetSqlConnectionAsync(CancellationToken cancellationToken = default)
+        protected async Task<NpgsqlConnection> GetSqlConnectionAsync(CancellationToken cancellationToken = default)
         {
-            SqlConnection connection;
+            NpgsqlConnection connection;
 
-            connection = new SqlConnection(ConnectionString);
+            connection = new NpgsqlConnection(ConnectionString);
             await connection.OpenAsync(cancellationToken);
 
             return connection;
         }
 
-        protected async Task<SqlDataReader> CreateReaderFromCommandAsync(SqlCommand cmd, CancellationToken cancellationToken = default)
+        protected async Task<NpgsqlDataReader> CreateReaderFromCommandAsync(NpgsqlCommand cmd, CancellationToken cancellationToken = default)
         {
 
             cmd.Connection = await GetSqlConnectionAsync(cancellationToken);
 
-            SqlDataReader rdr = await cmd.ExecuteReaderAsync(cancellationToken);
+            NpgsqlDataReader rdr = await cmd.ExecuteReaderAsync(cancellationToken);
             return rdr;
 
         }
@@ -43,14 +43,14 @@ protected async Task<IEnumerable<T>> ReadDPAppObjectAsync<T>(string commandText,
 
             List<T> listObjects = new();
 
-            using (SqlConnection connection = await GetSqlConnectionAsync(cancellationToken))
+            using (NpgsqlConnection connection = await GetSqlConnectionAsync(cancellationToken))
             {
 
-                using (SqlCommand cmd = new(commandText, connection))
+                using (NpgsqlCommand cmd = new(commandText, connection))
                 {
                     cmd.CommandType = CommandType.Text;
 
-                    using SqlDataReader reader = await cmd.ExecuteReaderAsync(cancellationToken);
+                    using NpgsqlDataReader reader = await cmd.ExecuteReaderAsync(cancellationToken);
 
                     while (await reader.ReadAsync(cancellationToken))
                     {

ACCDataAdapter/DPApp/MasterdataDAL.cs

@@ -5,6 +5,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using ACCDataModel.DPApp;
+using Npgsql;
 
 namespace ACCDataAdapter.DPApp
 {
@@ -19,12 +20,12 @@ public MasterdataDAL(string connectionString) : base(connectionString)
         public async Task<DataTable> ReadCostCenterAsync(CancellationToken cancellationToken = default)
         {
 
-            SqlCommand cmd = new(Properties.Resources.ReadCostCenters, await GetSqlConnectionAsync(cancellationToken))
+            NpgsqlCommand cmd = new(Properties.Resources.ReadCostCenters, await GetSqlConnectionAsync(cancellationToken))
             {
                 CommandType = CommandType.Text
             };
 
-            SqlDataAdapter da = new(cmd);
+            NpgsqlDataAdapter da = new(cmd);
             DataSet ds = new();
 
             da.Fill(ds);

ACCDataAdapter/DPApp/ReadDPObjectFromReaderDelegate.cs

@@ -1,12 +1,12 @@
 using ACCDataModel.DPApp;
+using Npgsql;
 using System;
 using System.Collections.Generic;
-using System.Data.SqlClient;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
 namespace ACCDataAdapter.DPApp
 {
-    public delegate T ReadDPObjectFromReaderDelegate<T>(SqlDataReader reader) where T : DPAppObject;
+    public delegate T ReadDPObjectFromReaderDelegate<T>(NpgsqlDataReader reader) where T : DPAppObject;
 }