From 9c225ff7a0f595f819ae0c379e39f9394173ead7 Mon Sep 17 00:00:00 2001
From: "DESKTOP-GENO133\\IvanPlex" <ivancheahkf@gmail.com>
Date: Tue, 6 Feb 2024 20:24:05 -0700
Subject: [PATCH] postgres backend for vehicle.

---
 CarCareTracker.csproj                         |  1 +
 .../Postgres/VehicleDataAccess.cs             | 97 +++++++++++++++++++
 Program.cs                                    |  8 +-
 3 files changed, 105 insertions(+), 1 deletion(-)
 create mode 100644 External/Implementations/Postgres/VehicleDataAccess.cs

diff --git a/CarCareTracker.csproj b/CarCareTracker.csproj
index 814c5d0..a0622e3 100644
--- a/CarCareTracker.csproj
+++ b/CarCareTracker.csproj
@@ -13,6 +13,7 @@
   <ItemGroup>
     <PackageReference Include="CsvHelper" Version="30.0.1" />
     <PackageReference Include="LiteDB" Version="5.0.17" />
+    <PackageReference Include="Npgsql" Version="8.0.1" />
   </ItemGroup>
 
 </Project>
diff --git a/External/Implementations/Postgres/VehicleDataAccess.cs b/External/Implementations/Postgres/VehicleDataAccess.cs
new file mode 100644
index 0000000..e6cebcc
--- /dev/null
+++ b/External/Implementations/Postgres/VehicleDataAccess.cs
@@ -0,0 +1,97 @@
+using CarCareTracker.External.Interfaces;
+using CarCareTracker.Models;
+using Npgsql;
+using System.Reflection.Metadata.Ecma335;
+using System.Text.Json;
+
+namespace CarCareTracker.External.Implementations
+{
+    public class PGVehicleDataAccess: IVehicleDataAccess
+    {
+        private NpgsqlConnection pgDataSource;
+        public PGVehicleDataAccess(IConfiguration config)
+        {
+            pgDataSource = new NpgsqlConnection(config["POSTGRES_CONNECTION"]);
+            pgDataSource.Open();
+            //create table if not exist.
+            string initCMD = $"CREATE TABLE IF NOT EXISTS app.{tableName} (id INT GENERATED ALWAYS AS IDENTITY primary key, data jsonb not null)";
+            using (var ctext = new NpgsqlCommand(initCMD, pgDataSource))
+            {
+                ctext.ExecuteNonQuery();
+            }
+        }
+        private static string tableName = "vehicles";
+        public bool SaveVehicle(Vehicle vehicle)
+        {
+            var serializedData = JsonSerializer.Serialize(vehicle);
+            if (vehicle.Id == default)
+            {
+                string cmd = $"INSERT INTO app.{tableName} (data) VALUES(CAST(@data AS jsonb)) RETURNING id";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("data", serializedData);
+                    vehicle.Id = Convert.ToInt32(ctext.ExecuteScalar());
+                    return vehicle.Id != default;
+                }
+            } else
+            {
+                string cmd = $"UPDATE app.{tableName} SET data = CAST(@data AS jsonb) WHERE id = @id";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("id", vehicle.Id);
+                    ctext.Parameters.AddWithValue("data", serializedData);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+        }
+        public bool DeleteVehicle(int vehicleId)
+        {
+            string cmd = $"DELETE FROM app.{tableName} WHERE id = @id";
+            using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+            {
+                ctext.Parameters.AddWithValue("id", vehicleId);
+                return ctext.ExecuteNonQuery() > 0;
+            }
+        }
+        public List<Vehicle> GetVehicles()
+        {
+            string cmd = $"SELECT id, data FROM app.{tableName} ORDER BY id ASC";
+            var results = new List<Vehicle>();
+            using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+            {
+                using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                while (reader.Read())
+                {
+                    Vehicle vehicle = JsonSerializer.Deserialize<Vehicle>(reader["data"] as string);
+                    vehicle.Id = Convert.ToInt32(reader["id"]);
+                    if (string.IsNullOrWhiteSpace(vehicle.ImageLocation))
+                    {
+                            vehicle.ImageLocation = "/defaults/noimage.png";
+                    }
+                    results.Add(vehicle);
+                }
+            }
+            return results;
+        }
+        public Vehicle GetVehicleById(int vehicleId)
+        {
+            string cmd = $"SELECT id, data FROM app.{tableName} WHERE id = @id";
+            Vehicle vehicle = new Vehicle();
+            using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+            {
+                ctext.Parameters.AddWithValue("id", vehicleId);
+                using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                    while (reader.Read())
+                    {
+                        vehicle = JsonSerializer.Deserialize<Vehicle>(reader["data"] as string);
+                        vehicle.Id = Convert.ToInt32(reader["id"]);
+                        if (string.IsNullOrWhiteSpace(vehicle.ImageLocation))
+                        {
+                            vehicle.ImageLocation = "/defaults/noimage.png";
+                        }
+                    }
+            }
+            return vehicle;
+        }
+    }
+}
diff --git a/Program.cs b/Program.cs
index b212639..de6d718 100644
--- a/Program.cs
+++ b/Program.cs
@@ -12,7 +12,13 @@ var builder = WebApplication.CreateBuilder(args);
 
 // Add services to the container.
 builder.Services.AddControllersWithViews();
-builder.Services.AddSingleton<IVehicleDataAccess, VehicleDataAccess>();
+//data access method
+if (!string.IsNullOrWhiteSpace(builder.Configuration["POSTGRES_CONNECTION"])){
+    builder.Services.AddSingleton<IVehicleDataAccess, PGVehicleDataAccess>();
+} else
+{
+    builder.Services.AddSingleton<IVehicleDataAccess, VehicleDataAccess>();
+}
 builder.Services.AddSingleton<INoteDataAccess, NoteDataAccess>();
 builder.Services.AddSingleton<IServiceRecordDataAccess, ServiceRecordDataAccess>();
 builder.Services.AddSingleton<IGasRecordDataAccess, GasRecordDataAccess>();