110 lines
4.7 KiB
C#
110 lines
4.7 KiB
C#
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());
|
|
//update json data
|
|
if (vehicle.Id != default)
|
|
{
|
|
serializedData = JsonSerializer.Serialize(vehicle);
|
|
string cmdU = $"UPDATE app.{tableName} SET data = CAST(@data AS jsonb) WHERE id = @id";
|
|
using (var ctextU = new NpgsqlCommand(cmdU, pgDataSource))
|
|
{
|
|
ctextU.Parameters.AddWithValue("id", vehicle.Id);
|
|
ctextU.Parameters.AddWithValue("data", serializedData);
|
|
return ctextU.ExecuteNonQuery() > 0;
|
|
}
|
|
}
|
|
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;
|
|
}
|
|
}
|
|
}
|