NHibernate

1<?xml version='1.0' encoding='utf-8'?>
2<hibernate-configuration xmlns="urn:nhibernate-configuration-2.2">
3
4  <session-factory>
5    <property name="connection.provider">
6      NHibernate.Connection.DriverConnectionProvider, NHibernate
7    </property>
8    <property name="connection.connection_string_name">
9      ConnectionString
10    </property>
11    <property name="dialect">
12      NHibernate.Dialect.MySQLDialect
13    </property>
14    <property name="current_session_context_class">
15      web
16    </property>
17  </session-factory>  
18
19</hibernate-configuration>

1public class Account : Entity<int> {
2
3    public virtual string Email { get; protected set; }
4    public virtual string Password { get; protected set; }
5    public virtual string Name { get; set; }
6    public virtual string Surname { get; set; }
7
8    protected Account() { }
9
10    public Account(string email, string password) {
11        Email = email;
12        Password = password;
13    }
14
15    public virtual void NewPassword() {
16        Password = Guid.NewGuid().ToString().Substring(0, 5);
17    }
18}

1<?xml version="1.0" encoding="utf-8" ?>
2<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
3                   assembly="Dolrath"
4                   namespace="Dolrath.Domain.Entities">
5
6  <class name="Account" table="Accounts">
7    <id name="Id" type="Int32">
8      <generator class="hilo"/>
9    </id>
10
11    <property name="Email" type="string" length="100" not-null="true" />
12    <property name="Password" type="string" length="100" not-null="true" />
13    <property name="Name" type="string" length="100" not-null="false" />
14    <property name="Surname" type="string" length="100" not-null="false" />
15
16  </class>
17</hibernate-mapping>

1public sealed class SessionFactoryFactory {
2
3    private readonly ISessionFactory _sessionFactory;
4    public ISessionFactory CurrentSessionFactory { get { return _sessionFactory; } }
5
6    private static volatile SessionFactoryFactory _instance;
7    private static readonly object SyncRoot = new Object();
8
9    private SessionFactoryFactory() {
10        var cfg = new Configuration();
11        cfg.Configure();
12        cfg.AddAssembly(typeof(SessionFactoryFactory).Assembly);
13
14        _sessionFactory = cfg.BuildSessionFactory();
15    }
16
17    public static SessionFactoryFactory Instance {
18        get {
19            if (_instance == null) {
20                lock (SyncRoot) {
21                    if (_instance == null)
22                        _instance = new SessionFactoryFactory();
23                }
24            }
25
26            return _instance;
27        }
28    }
29}

1[AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
2public class TransactionPerRequestAttribute : ActionFilterAttribute {
3
4    private readonly IsolationLevel _isolationLevel;
5    private ISession _session;
6    private ITransaction _transaction;
7
8    public TransactionPerRequestAttribute(IsolationLevel isolationLevel = IsolationLevel.ReadUncommitted) {
9        _isolationLevel = isolationLevel;
10    }
11
12    public override void OnActionExecuting(ActionExecutingContext filterContext) {
13        _session = IoCContainer.Get<ISession>();
14        _transaction = _session.BeginTransaction(_isolationLevel);
15    }
16
17    public override void OnActionExecuted(ActionExecutedContext filterContext) {
18        if (filterContext.Exception == null)
19            _transaction.Commit();
20        else
21            _transaction.Rollback();
22    }
23}

1public class FilterConfig {
2
3    public static void RegisterGlobalFilters(GlobalFilterCollection filters) {
4        filters.Add(new HandleErrorAttribute());
5        filters.Add(new NHibernateSessionAttribute());
6    }
7}
8
9[AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
10public class NHibernateSessionAttribute : ActionFilterAttribute {
11
12    public override void OnActionExecuting(ActionExecutingContext filterContext) {
13        if (!CurrentSessionContext.HasBind(SessionFactoryFactory.Instance.CurrentSessionFactory)) {
14            CurrentSessionContext.Bind(IoCContainer.Get<ISession>());
15        }
16    }
17
18    public override void OnActionExecuted(ActionExecutedContext filterContext) {
19        var currentSession = CurrentSessionContext.Unbind(SessionFactoryFactory.Instance.CurrentSessionFactory);
20        if (currentSession == null) return;
21        currentSession.Close();
22        currentSession.Dispose();
23    }
24}

1public class AccountController : BaseController {
2
3    private readonly ISession _session;
4
5    public AccountController(ISession session) {
6        _session = session;
7    }
8
9    [HttpGet]
10    public ActionResult Create() {
11        return View();
12    }
13
14    [HttpPost]
15    [TransactionPerRequest]
16    public ActionResult Create(CreateViewModel viewModel) {
17        if (!ModelState.IsValid) return Error("Existem campos para preencher.", View(viewModel));
18
19        var account = new Account(viewModel.Email, viewModel.Password);
20        _session.Save(account);
21
22        return Information("Sua conta foi criada com sucesso.", RedirectToAction("Index", "Home"));
23    }
24}

1public class AccountGetByIdQuery : IQuery<Account> {
2
3    private readonly ISession _session;
4
5    public int Id { get; set; }
6
7    public AccountGetByIdQuery(ISession session) {
8        _session = session;
9    }
10
11    public Account GetResult() {
12        return _session.CreateCriteria<Account>()
13                        .Add(Restrictions.Eq("Id", Id))
14                        .UniqueResult<Account>();
15    }
16}

1public class AccountGetByEmailQuery : IQuery<Account> {
2
3    private readonly ISession _session;
4
5    public string Email { get; set; }
6
7    public AccountGetByEmailQuery(ISession session) {
8        _session = session;
9    }
10
11    public virtual Account GetResult() {
12        return _session.QueryOver<Account>()
13                        .Where(c => c.Email == Email)
14                        .SingleOrDefault<Account>();
15    }
16}

1public class ItemResultGetAllQuery : IQuery<IEnumerable<ItemResult>> {
2
3    private readonly ISession _session;
4
5    public ItemResultGetAllQuery(ISession session) {
6        _session = session;
7    }
8
9    public IEnumerable<ItemResult> GetResult() {
10        return _session.CreateSQLQuery("SELECT Id, Name, Type FROM Items")
11                        .SetResultTransformer(Transformers.AliasToBean<ItemResult>())
12                        .List<ItemResult>();
13    }
14}