Bom Dia,
Já tiver que criar um conversor de dados, ontem precisamos migrar
dados de uma estrutra para outra, nesse processo havia uma tabela de
movimentações de estoque, com pouco mais de 130 mil registros, para
importar uma movimentação era necessário primeiramente importar todos
os demais relacionamentos e depois as movimentações com suas devidas
regras de negocio. Como o processo era demorado e utilizar o metodo
session.SaveOrUpdate(entity); gera um cache e estoura a memória então
foi criado um "SalvaSemCache" exemplo:
//Salvar normal
public override T Salva(T entity)
{
//Recupera a sessao corrente
//Poderia se usado dessa forma, mas na declaração será
chamado apenas uma vez a propriedade
NHibernateHttpModule.CurrentSession;
//o using é usado para uma transação atomica caso ocorra
um erro toda a transação será dada rollback.
//using (RepositorioSession)
var session = this.RepositorioSession;
//Inicia uma transação
using (var transacao = session.BeginTransaction())
{
try
{
//Persiste a entidade
session.SaveOrUpdate(entity);
//Comita a transação
transacao.Commit();
}
catch (Exception)
{
//Em caso de erro realiza um Rollback na transação
transacao.Rollback();
throw;
}
}
return entity;
}
//Limpando o "cache"
public override T SalvaSemCache(T entity)
{
//Recupera a sessao corrente
//Poderia se usado dessa forma, mas na declaração será
chamado apenas uma vez a propriedade
NHibernateHttpModule.CurrentSession;
//o using é usado para uma transação atomica caso ocorra
um erro toda a transação será dada rollback.
//using (RepositorioSession)
using (var session = this.RepositorioSession)
{
//Inicia uma transação
using (var transacao = session.BeginTransaction())
{
try
{
//Persiste a entidade
session.SaveOrUpdate(entity);
//Comita a transação
transacao.Commit();
}
catch (Exception)
{
//Em caso de erro realiza um Rollback na
transação
transacao.Rollback();
throw;
}
}
session.Flush();
session.Clear();
}
return entity;
}
=========================================================================== ==
==> ... Lembrando que também foi utilizado um insert direto
a grande diferença entre o insert e o "SalvaSemCache" é os
relacionamentos
quando vc tem um Entidade.Entidade o SalvarSemCache faz o trabalho de
salvar
toda a estrutura, já o insert não salva os relacionamentos!!
=========================================================================== ==
public override T Insert(T entity)
{
using (var session =
ConfigFactory.Instance.SessionFactory.OpenStatelessSession())
{
using (var transacao = session.BeginTransaction())
{
try
{
session.Insert(entity);
transacao.Commit();
}
catch
{
transacao.Rollback();
throw;
}
}
}
return entity;
}
Em resumo utilizei o SalvarSemCache para as regras de negocios após
ter inserido todos os registros em banco com o Insert o resultado foi
de um processamento de 10horas com "estou de memória" para um
processamento de 3 horas com 100% de integridade das movimentações.
Bom espero ter ajudado.
At.
Rafael Da Silva