Как обновить данные в БД, если запись уже существует, а если нет, то создать?

Question

У меня есть GET запрос который получает данные в формате json и записывает их в БД. Мне нужно что бы те данные, которые уже есть в таблице обновлялись, а те которых нет добавлялись. У меня в базе есть поле shipmentId, оно всегда остается неизменным, я предполагаю что можно его как то использовать, но не понимаю как это сделать. Помогите пожалуйста, заранее спасибо)

static async Task<OtvetGet> GetRequest(string url, ZaprosGet zapros)
        {
            OtvetContext context = new OtvetContext();

            string jsonString = System.Text.Json.JsonSerializer.Serialize(zapros);
            HttpClient client = new HttpClient();
            var content = new StringContent(jsonString, Encoding.UTF8, "application/json");
            var result = client.PostAsync(url, content).Result;

            var customerJsonString = await result.Content.ReadAsStringAsync();
            var ans = JsonConvert.DeserializeObject<OtvetGet>(custome‌rJsonString);

            context.Otvets.Add(ans);
            context.SaveChanges();

            return ans;

        }

Модель OtvetGet

public class OtvetGet
    {
        public int Id { get; set; }
        [JsonProperty("success")]
        public int success { get; set; }
        [JsonProperty("meta")]
        public Meta? meta { get; set; }
        [JsonProperty("data")]

        public Data? data { get; set; }
    }

    public class Meta
    {
        public int Id { get; set; }
        public string? fromProxy { get; set; }
        public string? requestId { get; set; }
    }

    public class Data
    {
        public int Id { get; set; }

        [JsonProperty("shipments")]
        public List<Shipment> shipments { get; set; } = new List<Shipment>();
    }

    public class Shipment
    {
        public int Id { get; set; }
        public string? orderCode { get; set; }
        public string? status { get; set; }
        public string? shipmentId { get; set; }
        public string? confirmedTimeLimit { get; set; }
        public string? packingTimeLimit { get; set; }
        public string? shippingTimeLimit { get; set; }
        public string? shipmentDateFrom { get; set; }
        public string? shipmentDateTo { get; set; }
        public string? deliveryId { get; set; }
        public bool shipmentDateShift { get; set; }
        public bool shipmentIsChangeable { get; set; }
        public string? customerFullName { get; set; }
        public string? customerAddress { get; set; }
        public string? shippingPoint { get; set; }
        public string? creationDate { get; set; }
        public string? deliveryDate { get; set; }
        public string? deliveryDateFrom { get; set; }
        public string? deliveryDateTo { get; set; }
        //[JsonProperty("items")]
        public List<Item> items { get; set; } = new List<Item>();
        public string? deliveryMethodId { get; set; }
        public string? serviceScheme { get; set; }
        public string? customer { get; set; }
        public int depositedAmount { get; set; }
    }

    public class Item
    {
        public int Id { get; set; }
        public string? itemIndex { get; set; }
        public string? status { get; set; }
        public string? subStatus { get; set; }
        public int price { get; set; }
        public int finalPrice { get; set; }
        public List<Discount> discounts { get; set; } = new List<Discount>();
        [NotMapped]
        public string[]? priceAdjustments { get; set; }
        public int quantity { get; set; }
        public string? offerId { get; set; }
        public string? goodsId { get; set; }
        public string? digitalMark { get; set; }
        public Goodsdata? goodsData { get; set; }
        public List<Event> events { get; set; } = new List<Event>();
        public string? boxIndex { get; set; }
    }

    public class Goodsdata
    {
        public int Id { get; set; }
        public string? name { get; set; }
        public bool isDelivery { get; set; }
        public string? categoryName { get; set; }
        public bool isDigitalMarkRequired { get; set; }
    }

    public class Discount
    {
        public int Id { get; set; }
        public string? discountType { get; set; }
        public string? discountDescription { get; set; }
        public int discountAmount { get; set; }
    }

    public class Event
    {
        public int Id { get; set; }
        public string? eventDate { get; set; }
        public string? eventName { get; set; }
        public string? eventValue { get; set; }
    }

Answer 1

Вы можете использовать shipmentId как ключ для обновления или вставки данных в БД. Вам нужно использовать инструкцию SQL UPSERT (update или insert) для выполнения этой операции.

Например, если вы используете SQLite, вы можете использовать следующий запрос:

INSERT INTO table_name (shipmentId, column1, column2, ...) VALUES (:shipmentId, :value1, :value2, ...) ON CONFLICT (shipmentId) DO UPDATE SET column1 = :value1, column2 = :value2, ...;

Если вы используете MySQL, вам нужно использовать следующий запрос:

INSERT INTO table_name (shipmentId, column1, column2, ...) VALUES (:shipmentId, :value1, :value2, ...) ON DUPLICATE KEY UPDATE column1 = VALUES(column1), column2 = VALUES(column2), ...;

Здесь, shipmentId является ключом для обновления или вставки данных. Вместо использования конкретных значений, вы можете использовать параметры запроса, чтобы динамически передавать значения из json в запрос.

Обратите внимание, что это только общий пример, и использование, синтаксис и методы могут отличаться в зависимости от типа базы данных, которую вы используете. Поэтому, убедитесь, что вы используете синтаксис, соответствующий вашей базе данных.

Answer 2

Добавляю к предыдущему ответу. В C# вы можете использовать библиотеку, такую как Newtonsoft.Json, для анализа данных JSON и извлечения свойств, которые вы хотите вставить в таблицу. Затем вы можете использовать ADO.NET (например, SqlCommand и SqlParameter) для создания и выполнения инструкции INSERT INTO с извлеченными свойствами в качестве значений. Вот пример:

using Newtonsoft.Json.Linq;
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    JObject jsonData = JObject.Parse(jsonString);
    string property1 = jsonData["property1"].Value<string>();
    string property2 = jsonData["property2"].Value<string>();
    string property3 = jsonData["property3"].Value<string>();

    string query = "INSERT INTO table_name (column1, column2, column3) VALUES (@value1, @value2, @value3)";
    using (SqlCommand command = new SqlCommand(query, connection))
    {
        command.Parameters.AddWithValue("@value1", property1);
        command.Parameters.AddWithValue("@value2", property2);
        command.Parameters.AddWithValue("@value3", property3);
        command.ExecuteNonQuery();
    }
}

Вам нужно будет заменить connectionString на вашу фактическую строку подключения к базе данных, а jsonString на данные json, которые вы хотите вставить.

БЛОГ НА HUSL

Как обновить данные в БД, если запись уже существует, а если нет, то создать?

Ответы (2 шт):