NHibernate quick start

<< NUNIT quick start | Home | NUnit + NHibernate >>

NHibernate quick start

- installare, se necessario, NH

- aggiungere il progetto Persistence alla solution

- aggiungere a Persistence il riferimento a NHibernate.dll e ai progetti della solution necessari (BusinessObjetcts, ...)

- aggiungere al file di configurazione del progetto che verrà avviato la sezione per NH:

- aggiungere a Persistence la classe SessionHelper, che si occuperà di istanziare le sessioni dalla factory

Esempio:

using System.Reflection;
using NHibernate;
using NHibernate.Cfg;

namespace Persistence
{
public class SessionHelper
{
private static ISessionFactory factory;

static SessionHelper()
{
Configuration cfg = new Configuration();
cfg.AddAssembly(Assembly.GetExecutingAssembly());
factory = cfg.BuildSessionFactory();
}

public static ISession GetSession()
{
return factory.OpenSession();
}

public static ISession GetSession(IInterceptor interceptor)
{
return factory.OpenSession(interceptor);
}

- aggiungere i file di mapping di NH col nome classe.hbm.xml; esempio:

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
assembly="BusinnessObjects"
namespace="BusinnessObjects">
<class name="Group" table="Groups" lazy="false">
<id name="Id">
<generator class="guid" />
</id>
<property name ="Name" />

</class>
</hibernate-mapping>

- ricordati di impostare i file di mapping come Embedded Resource

A questo punto è possibile usare la session per salvare/caricare oggetti:

ISession session = SessionHelper.GetSession();
using (session)
{
Group group = new Group();
group.Name = "gruppo test";
group.Id = new Guid();
session.SaveOrUpdate(group);
session.Flush();
}

Per migliorare l'architettura aggiungere provider e manager:

- aggiungere a Persistence la classe generica del ProviderNH; ad esempio:

using System;
using System.Collections.Generic;
using System.Reflection;
using NHibernate;
using NHibernate.Transform;

namespace Persistence
{
public class NHibernateProvider<T> : IDisposable
{
private ISession _session;
//public event EventHandler<BeforeCommitEventArgs> BeforeCommit;

protected ISession Session
{
get { return _session; }
set { _session = value; }
}

public NHibernateProvider()
{
Session = SessionHelper.GetSession();
}

public T LoadById(Int32 id)
{
return Session.Load<T>(id);
}

public T LoadById(String id)
{
return Session.Load<T>(id);
}

public IList<T> LoadAll()
{
return LoadAll(String.Empty, true);
}

public IList<T> LoadAll(String associationPath, Boolean lazy)
{
ICriteria criteria = Session.CreateCriteria(typeof(T));
if (lazy)
{
return criteria.List<T>();
}
else
{
return criteria.SetFetchMode(associationPath, FetchMode.Join)
.SetResultTransformer(new DistinctRootEntityResultTransformer()).List<T>();
}
}

public IList<T> LoadBy(String hql)
{
return Session.CreateQuery(hql).List<T>();
}

public void Save(T value)
{
ITransaction tx = Session.BeginTransaction();
Session.SaveOrUpdate(value);

//OnBeforeCommit(value);

try
{
tx.Commit(); // Fa commit e flush
}
catch (Exception ex)
{
tx.Rollback();
//Logger.Error(this, MethodInfo.GetCurrentMethod().Name, ex);
throw;
}
}

public void SaveNew(T value)
{
ITransaction tx = Session.BeginTransaction();
Session.Save(value);

//OnBeforeCommit(value);

try
{
tx.Commit(); // Fa commit e flush
}
catch (Exception ex)
{
tx.Rollback();
//Logger.Error(this, MethodInfo.GetCurrentMethod().Name, ex);
throw;
}
}

//private void OnBeforeCommit(T value)
//{
// if (BeforeCommit != null)
// BeforeCommit(this, new BeforeCommitEventArgs(value));
//}

public void Delete(T value)
{
Session.Delete(value);
Session.Flush();
}

public void Dispose()
{
Session.Close();
Session.Dispose();
}
}
}