Метод для получения и конвертации ответа от бд (использовать только с 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"));
Что не так?
- дак у вас все запросы SQL на выборку данных. С чего бы чему то сохраняться?