0

Я сохраняю изменения в таблице базы по нажатию на кнопку, вот сам код:

else if (comboBox1.SelectedItem == "Элек")
{
label3.Text = "Электричество";
string script = "SELECT id, name, Mx_pw_VT, Pr_pw_VT, elec_kVT_hr, Print_time_fact, YZV_power_VT FROM elec;";
mycon = new MySqlConnection(connect);
mycon.Open();
MySqlDataAdapter ms_data = new MySqlDataAdapter(script, connect);
var cb = new MySqlCommandBuilder(ms_data);
cb.GetInsertCommand();
ms_data.Update(dataGridView1.DataSource as DataTable);
ms_data.InsertCommand = cb.GetInsertCommand();
ms_data.InsertCommand.CommandText += "; select * from elec where id = last_insert_id();";
ms_data.InsertCommand.UpdatedRowSource = UpdateRowSource.FirstReturnedRecord;
}

Но мне почему то выдает ошибку «Нарушение параллелизма: UpdateCommand затронула 0 из ожидаемых 1 записей.» Причем у меня есть такой же блок кода для другой таблицы и он работает, в этой таблице изменения происходят, сам блок:

else if (comboBox1.SelectedItem == "Рбт")
{
label3.Text = "Рбт";
string script = "SELECT id, name, Model_preparation_R_Hr, Time_for_preparation_hr, Time_for_post_processing_hr, YZV_work FROM rbt;";
mycon = new MySqlConnection(connect);
mycon.Open();
MySqlDataAdapter ms_data = new MySqlDataAdapter(script, connect);
var cb = new MySqlCommandBuilder(ms_data);
cb.GetInsertCommand();
ms_data.Update(dataGridView1.DataSource as DataTable);
ms_data.InsertCommand = cb.GetInsertCommand();
ms_data.InsertCommand.CommandText += "; select * from rbt where id = last_insert_id();";
ms_data.InsertCommand.UpdatedRowSource = UpdateRowSource.FirstReturnedRecord;
}

Что не так? Подскажите пожалуйста

6
  • Что не так? - дак у вас все запросы SQL на выборку данных. С чего бы чему то сохраняться?
    – tym32167
    7 мар 2022 в 1:25
  • Так оно же так и работает, вот тот второй блок кода, такой же, но для другой таблицы, работает и все изменяет/вставляет, без ошибок
    – xto
    7 мар 2022 в 1:35
  • Хотя теперь и второй блок не работает на изменение... Только на добавление, что странно, до этого работал, у меня еще есть 4 таких же блока для 4 еще других таблиц и они пока работают без проблем, выглядят абсолютно также, все добавляют и изменяют и сохраняют, не знаю, программа будто рандомно срабатывает
    – xto
    7 мар 2022 в 1:45
  • А, не, я вот это не увидел MySqlCommandBuilder. Тогда хз если честно :)
    – tym32167
    7 мар 2022 в 1:45
  • Могу предложить иное взаимодействие с бд. Часа через 4 буду за компом и напишу в ответ вариант реализации, который я очень часто использую
    – Frehzy
    7 мар 2022 в 11:03

1 ответ 1

1

Метод для получения и конвертации ответа от бд (использовать только с SELECT):

public List<T> SqlQuery<T>(string query)
    {
        var result = new List<T>();

        using (MySqlConnection connection = GetDBConnection(1))
        {
            connection.Open();
            using var command = connection.CreateCommand();
            command.CommandText = query;
            using var reader = command.ExecuteReader();
            var columns = Enumerable.Range(0, reader.FieldCount).Select(reader.GetName).ToArray();
            var properties = typeof(T).GetProperties();

            while (reader.Read())
            {
                var data = new object[reader.FieldCount];
                reader.GetValues(data);

                var instance = (T)Activator.CreateInstance(typeof(T));

                for (var i = 0; i < data.Length; ++i)
                {
                    if (data[i] == DBNull.Value)
                        data[i] = null;

                    var property = properties.SingleOrDefault(x => x.Name.Equals(columns[i], StringComparison.InvariantCultureIgnoreCase));

                    if (property is not null)
                    {
                        var dataValue = Guid.TryParse(data[i].ToString(), out Guid res) is true ? res : data[i];
                        property.SetValue(instance, Convert.ChangeType(dataValue, property.PropertyType));
                    }
                }
                result.Add(instance);
            }
        }
        return result;
    }

Метод для получения строки sql-запроса на вставку. Гораздо удобнее. Не нужно писать 1000 и 1 Insert строку для таблиц. Нужно лишь создать класс:

    public static string GetInsertSqlString<TValue>(TValue instance, string tableName)
    {
        var columnsName = instance.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance).Select(x => x.Name).ToArray();
        var values = instance.GetType()
            .GetProperties(BindingFlags.Public | BindingFlags.Instance)
            .Select(x => x.GetValue(instance, null));
        var hasBool = values.FirstOrDefault(x => x.GetType() == typeof(bool)) is not null;
        if (hasBool is false)
            return $"INSERT INTO {tableName}({string.Join(",", columnsName)}) VALUES ('{string.Join("','", values)}')";
        else
        {
            List<string> valuesWithBool = new();
            foreach (var val in values)
                if (val.GetType().Equals(typeof(bool)))
                    valuesWithBool.Add(val.ToString());
                else
                    valuesWithBool.Add($"'{val}'");

            return $"INSERT INTO {tableName}({string.Join(",", columnsName)}) VALUES ({string.Join(",", valuesWithBool)})";
        }
    }

Метод для Insert:

public DBResponseStatus ExecuteNonQuery(string query)
    {
        using MySqlConnection myConnection = GetDBConnection();
        try
        {
            if (myConnection.State == ConnectionState.Closed)
                myConnection.Open();

            MySqlCommand command = new(query, myConnection);
            command.ExecuteNonQuery();
            return DBResponseStatus.OK;
        }
        catch (Exception ex)
        {
            Log.Error(ex.ToString());
            return DBResponseStatus.Error;
        }
    }

Перечисление, которое возвращается из метода ExecuteNonQuery:

public enum DBResponseStatus
{
    OK = 0,
    Error = 1
}

Метод GetDBConnection для получения строки для БД:

public MySqlConnection GetDBConnection(int timeOut = 30)
    {
        string connString = "Server=" + Host
            + ";Database=" + DataBaseName
            + ";port=" + Port
            + ";User Id=" + Username
            + ";password=" + Password
            + ";Connection Timeout=" + timeOut;

        MySqlConnection conn = new(connString);

        return conn;
    }

Пример класса для нормальной работы методов:

internal class ProductDB
{
    public Guid OrderId { get; set; }

    public Guid ProductId { get; set; }

    public ProductDB() { }

    public ProductDB(Guid orderId, Guid productID)
    {
        OrderId = orderId;
        ProductId = productID;
    }
}

Пример вызова метода SqlQuery для Select:

List<Product> GetProducts() =>
            DB.SqlQuery<Product>("SELECT * FROM products");

Пример вызова метода ExecuteNonQuery для Insert:

db.ExecuteNonQuery(SQLString.GetInsertSqlString(*экземпляр класса*, "ordersproducts"));
1
  • Данными методами пользуюсь довольно-таки давно уже. Думаю, это сможет решить вашу проблему. Если есть предложения по улучшению кода - готов выслушать критику
    – Frehzy
    7 мар 2022 в 14:52

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.