Accès aux données générique avec Linq To SQL et C#
Introduction :
Cet article permet de construire une couche d’accès aux données générique en utilisant LINQ To SQL. Ceci permettra par la suite d’effectuer les opérations basiques du CRUD. Nous créerons une classe nommée EntityCrud qui implémentera ces fonctionnalités.
Vous pourrez par la suite créer des Adapters pour chacune de vos classe dérivant ce cette classe.
Place à l’action !
Nous allons créer une simple solution contenant 2 projet : le programme et la couche d’accès aux données (DAL).
Ajouter un élément de type classe LINQ To SQL :
Puis ensuite ajouter les Tables à votre projet par le biais de l’explorateur de solution.
Code Projet MonProgramme.DAL
La classe EntityCrud contient tout le code nécessaire pour communiquer avec la base de donnée par le biais de LinqToSQL.
Voici la classe AdapterFactory :
using System;
using System.Collections;
using System.Collections.Specialized;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Data.Linq;
using System.Data.Linq.Mapping;
using System.Text;
using System.ComponentModel;
The next section contains the namespace and class declarations.
namespace MonProgramme.DAL
{
/// <summary>
/// Generic Interface to Database
/// using LINQ to SQL
/// </summary>
public class EntityCrud
{
Première fonction permettant de récuperer un objet par sa clé Primaire.
/// <summary>
/// Select by Primary Key Value
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="id">The PK value to search for</param>
/// <returns>Single matching PK to id</returns>
public static T SelectByPK<T>(String id) where T : class
{
try
{
using (NWindDataContext context = new
NWindDataContext())
{
// Récupère la table du type passé
var table = context.GetTable<T>();
// Récupère le mapping de l’objet avec la Base
MetaModel modelMap = table.Context.Mapping;
// Récupère les members de l’objet
ReadOnlyCollection<MetaDataMember> dataMembers
= modelMap.GetMetaType(typeof(T)).DataMembers;
// Cherche le nom du champ de la clé primaire
string pk =
(dataMembers.Single<MetaDataMember>(m =>
m.IsPrimaryKey)).Name;
// Retourne l’objet unique qui correspond à cette clé primaire
// passée en argument
return table.SingleOrDefault<T>(delegate(T t)
{
String memberId =
t.GetType().GetProperty(pk).GetValue(t,
null).ToString();
return memberId.ToString() == id.ToString();
}
);
}
}
catch (Exception)
{
throw;
}
}
Seconde méthode permettant de récupérer toutes les objets de la base.
/// <summary>
/// Select All by Type
/// </summary>
/// <typeparam name="T"></typeparam>
/// <returns>Matching table as typed list</returns>
public static IList<T> SelectAll<T>() where T : class
{
try
{
using (NWindDataContext context = new NWindDataContext())
{
// Récupère la table qui correspond au type
// et retourne tous les enregistrement sous forme de liste
var table = context.GetTable<T>().ToList<T>();
return table;
}
}
catch (Exception)
{
throw;
}
}
Méthode d’insertion de donnée dans la base.
/// <summary>
/// Insert an Object into a Table
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="item"></param>
public static void Insert<T>(T item) where T : class
{
try
{
// Récupère la table du type passé en argument
// Insert l’enregistrement et soumet les changements à la Base
using (NWindDataContext context = new
NWindDataContext())
{
// Récupère la table correspondante
var table = context.GetTable<T>();
// Passe l’objet à la method InsertOnSubmit
// et Soumet les changements
table.InsertOnSubmit(item);
context.SubmitChanges();
}
}
catch (Exception)
{
throw;
}
}
Méthode de mise à jour de donnée.
/// <summary>
/// Update an Existing Object
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="item">The object to update</param>
public static void Update<T>(T item) where T : class
{
try
{
// Crée une nouvelle instance de l’objet
Object newObj = Activator.CreateInstance(typeof(T),
new object[0]);
PropertyDescriptorCollection originalProps =
TypeDescriptor.GetProperties(item);
// Donne la valeur de la donnée passée en argument à l’objet
foreach (PropertyDescriptor currentProp in
originalProps)
{
if (currentProp.Attributes[typeof(
System.Data.Linq.Mapping.ColumnAttribute)] !=
null)
{
object val = currentProp.GetValue(item);
currentProp.SetValue(newObj, val);
}
}
// Lie l’objet à un nouveau context de donnée
// et soumet les changement à la Base.
using (NWindDataContext context = new
NWindDataContext())
{
var table = context.GetTable<T>();
table.Attach((T)newObj, true);
context.SubmitChanges();
}
}
catch (Exception)
{
throw;
}
}
Code de suppression d’un objet.
/// <summary>
/// Remove an object
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="item"></param>
public static void Remove<T>(T item) where T : class
{
try
{
// Crée une instance de l’objet avec le type passé en argument
Type tType = item.GetType();
Object newObj = Activator.CreateInstance(tType, new
object[0]);
// Récupère les proprieties de l’objet passé en argument
PropertyDescriptorCollection originalProps =
TypeDescriptor.GetProperties(item);
// Copie le contenue de la donnée passée en argument
// au nouveau objet du meme type
foreach (PropertyDescriptor currentProp in
originalProps)
{
if (currentProp.Attributes[typeof(
System.Data.Linq.Mapping.ColumnAttribute)] !=
null)
{
object val = currentProp.GetValue(item);
currentProp.SetValue(newObj, val);
}
}
//lie l’objet à la table, appel de la function deleteOnSubmit
// et soumet les changement à la base.
using (NWindDataContext context = new
NWindDataContext())
{
var table = context.GetTable<T>();
table.Attach((T)newObj, true);
table.DeleteOnSubmit((T)newObj);
context.SubmitChanges();
}
}
catch (Exception)
{
throw;
}
}
Utilisation :
Une fois l’EntityCrud créé vous pouvez l’utiliser comme dans les exemples suivant :
Exemple Insert :
try
{
Customer c = new Customer();
c.CustomerID = "AAAAA";
c.Address = "554 Westwind Avenue";
c.City = "Wichita";
c.CompanyName = "Holy Toledo Bibles";
c.ContactName = "Frederick Flintstone";
c.ContactTitle = "Boss";
c.Country = "USA";
c.Fax = "316-335-5933";
c.Phone = "316-225-4934";
c.PostalCode = "67214";
c.Region = "EA";
Order_Detail od = new Order_Detail();
od.Discount = .25f;
od.ProductID = 1;
od.Quantity = 25;
od.UnitPrice = 25.00M;
Order o = new Order();
o.Order_Details.Add(od);
o.Freight = 25.50M;
o.EmployeeID = 1;
o.CustomerID = "AAAAA";
c.Orders.Add(o);
EntityCrud.Insert<Customer>(c); //INSERT Customer mais aussi les autres champs qui lui sont associés (order, order_detail).
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
Les données seront toutes insérée en base : Le Customer, L’order et l’order_detail avec seulement cet appel : EntityCrud.Insert<Customer>(c);
Exemple Delete :
try
{
Customer doa = EntityCrud.SelectByPK<Customer>("AAAAA");
EntityCrud.Remove<Customer>(doa); //DELETE
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
Exemple Update :
try
{
var q = EntityCrud.SelectByPK<Customer>("AAAAA");
q.City = "Calgary";
q.Country = "Canada";
q.Address = "100 Longhorn Drive";
q.CompanyName = "Holy Moses Bibles";
q.Region = "EE";
q.ContactTitle = "Gopher";
q.ContactName = "Moxie Peroxide";
EntityCrud.Update<Customer>(q);//UPDATE
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
ec024619-f3b0-4964-8abb-6bea77775b95|0|.0
ADO.NET, ASP.NET AJAX, C#, WPF
linq, ado, sql, c#, dal