Estou tentando fazer um update com NHibernate mas sempre me retorna um erro dizendo que existe duas sessões abertas: illegally attempted to associate a proxy with two open session
Como resolver isso ?
GenericDAO
public class GenericDAO<T> : IPersist<T> where T : class {
public void insert(T obj) {
ISession _session = DBConnect.openSession();
ITransaction _transaction = _session.BeginTransaction();
try {
_session.Save(obj);
_transaction.Commit();
}catch (Exception e) {
if (!_transaction.WasCommitted) {
_transaction.Rollback();
}
MessageBox.Show("Erro tentando salvar: " + e.Message, "Aviso",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
public void update(T obj) {
ISession _session = DBConnect.openSession();
ITransaction _transaction = _session.BeginTransaction();
try {
_session.Update(obj);
_transaction.Commit();
}catch (Exception e) {
if (!_transaction.WasCommitted) {
_transaction.Rollback();
}
MessageBox.Show("Erro tentando alterar: " + e.Message, "Aviso",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
public void delete(T obj) {
ISession _session = DBConnect.openSession();
ITransaction _transaction = _session.BeginTransaction();
try {
_session.Delete(obj);
_transaction.Commit();
}catch (Exception e) {
if (!_transaction.WasCommitted) {
_transaction.Rollback();
}
MessageBox.Show("Erro tentando deletar: " + e.Message, "Aviso",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
public T findObject(long id) {
ISession _session = DBConnect.openSession();
return _session.Load<T>(id);
}
public void saveOrUpdate(T obj) {
ISession _session = DBConnect.openSession();
ITransaction _transaction = _session.BeginTransaction();
try {
_session.SaveOrUpdate(obj);
_transaction.Commit();
}catch (Exception e) {
if (!_transaction.WasCommitted) {
_transaction.Rollback();
}
MessageBox.Show("Erro tentando salvar ou alterar: " + e.Message, "Aviso",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
}
Update
/** insere Perfil + Modulo */
private void insertPerfilModulo() {
PermissaoDAO dao = new PermissaoDAO();
Perfil perfil = (Perfil)cbxPerfilModulo.SelectedItem;
IList<Modulo> lista = getListaModulo();
foreach(Modulo m in lista){
Permissao permissao = new Permissao();
permissao.perfil = perfil;
permissao.modulo = m;
Boolean exist = dao.isExistPerfilAndModulo(permissao);
if (exist) {
Permissao p = dao.getPermissao(permissao.perfil, permissao.modulo);
dao.update(p);
}else {
dao.insert(permissao);
}
}
}
PermissaoDAO
public class PermissaoDAO : GenericDAO<Permissao> {
public IList<Permissao> findAll() {
ISession _session = DBConnect.openSession();
IList<Permissao> list = _session.CreateQuery("FROM Permissao p")
.List<Permissao>();
return list;
}
/** verifica se o perfil e o modulo estao adicionados */
public Boolean isExistPerfilAndModulo(Permissao permissao) {
ISession _session = DBConnect.openSession();
IList<Permissao> list = _session.CreateQuery("FROM Permissao p WHERE p.perfil = :p AND p.modulo = :m")
.SetParameter("p", permissao.perfil)
.SetParameter("m", permissao.modulo)
.List<Permissao>();
if (list.Count > 0) {
return true;
}
return false;
}
/** retorna a permissao */
public Permissao getPermissao(Permissao permissao) {
ISession _session = DBConnect.openSession();
IList<Permissao> list = _session.CreateQuery("FROM Permissao p WHERE p.perfil = :p AND p.modulo = :m").SetMaxResults(1)
.SetParameter("p", permissao.perfil)
.SetParameter("m", permissao.modulo)
.List<Permissao>();
return list[0];
}
}