Класс для работы с базой данных (на примере MySQL) C#
Всё что ниже написано, больше как пример, лучше научитесь использовать Dapper.
В примере ниже, в отдельном классе реализованы не только методы выполняющие запросы типа (Scalar и NonQuery) но и метод возвращающий набор данных в DataTable. При этом продумана обработка исключительных ситуаций.
Привожу код как есть, он весь прокомментирован, на столько на сколько это необходимо для понимания.
Сам класс:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data;
using System.Data;
namespace MySqlLib
{
/// <summary>
/// Набор компонент для простой работы с MySQL базой данных.
/// </summary>
public class MySqlData
{
/// <summary>
/// Методы реализующие выполнение запросов с возвращением одного параметра либо без параметров вовсе.
/// </summary>
public class MySqlExecute
{
/// <summary>
/// Возвращаемый набор данных.
/// </summary>
public class MyResult
{
/// <summary>
/// Возвращает результат запроса.
/// </summary>
public string ResultText;
/// <summary>
/// Возвращает True - если произошла ошибка.
/// </summary>
public string ErrorText;
/// <summary>
/// Возвращает текст ошибки.
/// </summary>
public bool HasError;
}
/// <summary>
/// Для выполнения запросов к MySQL с возвращением 1 параметра.
/// </summary>
/// <param name="sql">Текст запроса к базе данных</param>
/// <param name="connection">Строка подключения к базе данных</param>
/// <returns>Возвращает значение при успешном выполнении запроса, текст ошибки - при ошибке.</returns>
public static MyResult SqlScalar(string sql, string connection)
{
MyResult result = new MyResult();
try
{
MySql.Data.MySqlClient.MySqlConnection connRC = new MySql.Data.MySqlClient.MySqlConnection(connection);
MySql.Data.MySqlClient.MySqlCommand commRC = new MySql.Data.MySqlClient.MySqlCommand(sql, connRC);
connRC.Open();
try
{
result.ResultText = commRC.ExecuteScalar().ToString();
result.HasError = false;
}
catch (Exception ex)
{
result.ErrorText = ex.Message;
result.HasError = true;
}
connRC.Close();
}
catch (Exception ex)//Этот эксепшн на случай отсутствия соединения с сервером.
{
result.ErrorText = ex.Message;
result.HasError = true;
}
return result;
}
/// <summary>
/// Для выполнения запросов к MySQL без возвращения параметров.
/// </summary>
/// <param name="sql">Текст запроса к базе данных</param>
/// <param name="connection">Строка подключения к базе данных</param>
/// <returns>Возвращает True - ошибка или False - выполнено успешно.</returns>
public static MyResult SqlNoneQuery(string sql, string connection)
{
MyResult result = new MyResult();
try
{
MySql.Data.MySqlClient.MySqlConnection connRC = new MySql.Data.MySqlClient.MySqlConnection(connection);
MySql.Data.MySqlClient.MySqlCommand commRC = new MySql.Data.MySqlClient.MySqlCommand(sql, connRC);
connRC.Open();
try
{
commRC.ExecuteNonQuery();
result.HasError = false;
}
catch (Exception ex)
{
result.ErrorText = ex.Message;
result.HasError = true;
}
connRC.Close();
}
catch (Exception ex)//Этот эксепшн на случай отсутствия соединения с сервером.
{
result.ErrorText = ex.Message;
result.HasError = true;
}
return result;
}
}
/// <summary>
/// Методы реализующие выполнение запросов с возвращением набора данных.
/// </summary>
public class MySqlExecuteData
{
/// <summary>
/// Возвращаемый набор данных.
/// </summary>
public class MyResultData
{
/// <summary>
/// Возвращает результат запроса.
/// </summary>
public DataTable ResultData;
/// <summary>
/// Возвращает True - если произошла ошибка.
/// </summary>
public string ErrorText;
/// <summary>
/// Возвращает текст ошибки.
/// </summary>
public bool HasError;
}
/// <summary>
/// Выполняет запрос выборки набора строк.
/// </summary>
/// <param name="sql">Текст запроса к базе данных</param>
/// <param name="connection">Строка подключения к базе данных</param>
/// <returns>Возвращает набор строк в DataSet.</returns>
public static MyResultData SqlReturnDataset(string sql, string connection)
{
MyResultData result = new MyResultData();
try
{
MySql.Data.MySqlClient.MySqlConnection connRC = new MySql.Data.MySqlClient.MySqlConnection(connection);
MySql.Data.MySqlClient.MySqlCommand commRC = new MySql.Data.MySqlClient.MySqlCommand(sql, connRC);
connRC.Open();
try
{
MySql.Data.MySqlClient.MySqlDataAdapter AdapterP = new MySql.Data.MySqlClient.MySqlDataAdapter();
AdapterP.SelectCommand = commRC;
DataSet ds1 = new DataSet();
AdapterP.Fill(ds1);
result.ResultData = ds1.Tables[0];
}
catch (Exception ex)
{
result.HasError = true;
result.ErrorText = ex.Message;
}
connRC.Close();
}
catch (Exception ex)//Этот эксепшн на случай отсутствия соединения с сервером.
{
result.ErrorText = ex.Message;
result.HasError = true;
}
return result;
}
}
}
}
Пример использования:
MySqlLib.MySqlData.MySqlExecuteData.MyResultData result = new MySqlLib.MySqlData.MySqlExecuteData.MyResultData();
result = MySqlLib.MySqlData.MySqlExecuteData.SqlReturnDataset("select * from table_name", "Database=base;Data Source=localhost;User Id=root;Password=pass");
if (result.HasError == false)
{
dataGridView1.Columns.Clear();
dataGridView1.DataSource = result.ResultData.DefaultView;
}
else
{
MessageBox.Show(result.ErrorText);
}
В данном примере происходит заполнение DataGridView данными из таблицы базы данных, при этом для всего действия, по сути необходима пара строчек кода.
Скачать исходные коды примеров:
Скачать файл: mysqllibexample.rar [192.09 Kb] (cкачиваний: 10)