cphipps/lubelog
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

simplified vehicle data access.

Browse Source
This commit is contained in:
DESKTOP-GENO133\IvanPlex
2024-02-07 21:08:11 -07:00
parent 8be252e949
commit 1feb89acf5
2 changed files with 6 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
External/Implementations/Postgres/NoteDataAccess.cs vendored
View File

@@ -1,5 +1,4 @@
using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models;
using Npgsql;
using System.Text.Json;
@@ -9,6 +8,7 @@ namespace CarCareTracker.External.Implementations
public class PGNoteDataAccess: INoteDataAccess
{
private NpgsqlConnection pgDataSource;
private static string tableName = "notes";
public PGNoteDataAccess(IConfiguration config)
{
pgDataSource = new NpgsqlConnection(config["POSTGRES_CONNECTION"]);
@@ -20,7 +20,6 @@ namespace CarCareTracker.External.Implementations
ctext.ExecuteNonQuery();
}
}
private static string tableName = "notes";
public List<Note> GetNotesByVehicleId(int vehicleId)
{
string cmd = $"SELECT data FROM app.{tableName} WHERE vehicleId = @vehicleId";

17
External/Implementations/Postgres/VehicleDataAccess.cs vendored
View File

@@ -1,7 +1,6 @@
using CarCareTracker.External.Interfaces;
using CarCareTracker.Models;
using Npgsql;
using System.Reflection.Metadata.Ecma335;
using System.Text.Json;
namespace CarCareTracker.External.Implementations
@@ -9,6 +8,7 @@ namespace CarCareTracker.External.Implementations
public class PGVehicleDataAccess: IVehicleDataAccess
{
private NpgsqlConnection pgDataSource;
private static string tableName = "vehicles";
public PGVehicleDataAccess(IConfiguration config)
{
pgDataSource = new NpgsqlConnection(config["POSTGRES_CONNECTION"]);
@@ -20,9 +20,12 @@ namespace CarCareTracker.External.Implementations
ctext.ExecuteNonQuery();
}
}
private static string tableName = "vehicles";
public bool SaveVehicle(Vehicle vehicle)
{
if (string.IsNullOrWhiteSpace(vehicle.ImageLocation))
{
vehicle.ImageLocation = "/defaults/noimage.png";
}
if (vehicle.Id == default)
{
string cmd = $"INSERT INTO app.{tableName} (data) VALUES(CAST(@data AS jsonb)) RETURNING id";
@@ -75,11 +78,6 @@ namespace CarCareTracker.External.Implementations
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);
}
}
@@ -96,11 +94,6 @@ namespace CarCareTracker.External.Implementations
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;