Mensagens enviadas por: fviana

bom, a ideia de DAO é fazer o acesso aos dados, ou seja, execução dos sql's...

O ideal seria vc criar um BusinessDelegate e um BusinessObject.
O BusinessObject contendo as regras de negocio e acessando o DAO.
O BusinessDelegate sendo a ligação entre o Controller e o BusinessObject.

Ex:

valeu cara...
agora entendi o threadlocal...
ele garante uma session para cada requisição, colocando a session na thread para a requisicao criada pelo container.

ok, vou modificar no sistema. qualquer coisa, eu posto novamente

o meu codigo está correto? está dentro do padrao MVC? e do Struts?

usando threadlocal pode ocorrer erros nas transações. pense na seguinte situação:

user1 e user2

user1 acaba de entrar no sistema
user2 em seguida entra no sistema

user1 abre uma transação e faz um update a uma consulta, neste mesmo tempo o user2 faz um update (na mesma session e transaction), porém dá um erro no update e um rollback é chamado. quando o user1, que nada teria a ver com user2, for comitar no db, as atualizações dele não serão efetivadas por ter ocorrido um rollback em sua transaction.

estou partindo do pre suposto que as operações de user1 irão demorar um bom tempo e a de user2 são instantaneas, ou seja, a session e a transaçao serão a mesma.

será que é isso mesmo? se não for ajudem-me.

ok, mas veja bem.
a session e a transação será a mesma!?
ou seja, imagine que eu e você faça uma requisição ao mesmo tempo, será aberto uma sessão e transação compartilhada para nós dois, correto?

alem disso, o meu codigo está correto? está dentro do padrao MVC? e do Struts?

me ajuda pelo amor de deus!!!

manda um exemplo simples!

meu sistema faz o seguinte:
inclusão, edição, remoção, visualização e pesquisa de clientes

abaixo está todo o codigo dele. digam-me o que está bom e o que esta ruim, como adicionar threadlocal nele?

/*
 * classe que trata toda a persistencia
 */
public abstract class Persistencia {
	private Object beforeObject;
	private Session session;
	
	public Object getBeforeObject() {
		return beforeObject;
	}
	
	public void setBeforeObject(Object object) {
		this.beforeObject = object;
	}
	
	public String getId() {
		return "id"+getTabela();
	}
	
	public abstract Class getDAOClass();
	
	public String getTabela(){
		String ret = this.getDAOClass().getName();
		int fim = ret.lastIndexOf(".")+1;
		ret = ret.substring(fim, ret.length());
		log(" - "+ret);
		return ret;
	}
	
	public Object search(String id) throws Exception{
		return search("id"+getTabela(), id);
	}
	
	public Object search(String campo, String id) throws Exception{
		String tabela = getTabela();
		List list = execSQL("from "+tabela+" where "+campo+"='"+id+"'");
		if (list.size()>0)
			return list.get(0);
		else
			return null;
	}
	
	public List execSQL(String condicao) throws Exception{
		if (condicao == null || condicao.equals("")){
			Exception erro = new Exception(this.getClass().getName() + ".execSQL("+condicao+")");
			log(erro);
			throw erro;
		}
		
		Query qry = session.createQuery(condicao);
		List list = qry.list();
		return list;
	}
	
	public List select() throws Exception{
		return execSQL("from " + getTabela());
	}
	
	public List select(String condicao) throws Exception{
		return execSQL("from " + getTabela() + ((condicao==null || condicao.equals(""))? "" : " where " + condicao));
	}
	
	public void insert(Object obj) throws Exception{
		if (!isDAOClass(obj)){
			Exception erro = new Exception(this.getClass().getName() + ".insert("+obj.toString()+") - "+obj.getClass().getName());
			log(erro);
			throw erro;
		}
		
		session.save(obj);
		session.flush();
	}

public void update(Object obj) throws Exception{
		if (!isDAOClass(obj)){
			Exception erro = new Exception(this.getClass().getName() + ".insert("+obj.toString()+") - "+obj.getClass().getName());
			log(erro);
			throw erro;
		}
		
		session.update(obj);
		session.flush();
	}

public void delete(Object obj) throws Exception {
		if (!isDAOClass(obj)){
			Exception erro = new Exception(this.getClass().getName() + ".insert("+obj.toString()+") - "+obj.getClass().getName());
			log(erro);
			throw erro;
		}
		session.delete(obj);
		session.flush();
	}
	
	public abstract boolean isDAOClass(Object obj);
	
	public Transaction initTransaction() throws Exception{
		return session.beginTransaction();
	}
	
	public Session getSession(){
		return session;
	}
	
	public void setSession(Session session){
		this.session = session;
	}
	
	// staticos
	private static Log log = LogFactory.getLog(Persistencia.class);
	private static SessionFactory sessionFactory = null;
	
	public static synchronized Session initSession() throws Exception{
		if (!isOpenFactory())
			openFactory();
		return sessionFactory.openSession();
	}
	
	public static synchronized void closeFactory() throws Exception{
		if (sessionFactory != null)
			sessionFactory.close();
		sessionFactory = null;
	}
	
	public static synchronized boolean isOpenFactory() throws Exception {
		return (sessionFactory != null);
	}
	
	public static synchronized void openFactory() throws Exception{
		String file = Utils.getKey("hibernate.file");
		sessionFactory = new Configuration().configure(file).buildSessionFactory();
	}
	
	private static synchronized void log(Exception e){
		log.debug("\n ERRO\n"+e);
	}
	
	private static synchronized void logLn(String msg){
		log.debug("\n"+msg);
	}
	
	private static synchronized void log(String msg){
		log.debug(msg);
	}
}

/*
 * form generico
 */
public class Form extends ActionForm {
	private String formAction;
	private String flag;
	private Session session;
	
	public Session getSession() {
		return session;
	}
	
	public void setSession(Session session) {
		this.session = session;
	}
	
	public String getFlag() {
		return flag;
	}
	
	public void setFlag(String flag) {
		this.flag = flag;
	}
	
	public String getFormAction() {
		return formAction;
	}
	
	public void setFormAction(String formAction) {
		this.formAction = formAction;
	}
	/*
	 * limpa os campos do form
	 */
	public void reset() throws Exception{
		
	}
	
	public void reset(HttpServletRequest request) throws Exception{
		reset();
	}
	/*
	 * valida os campos do form
	 */
	public ActionErrors validate(HttpServletRequest request) throws Exception{
		return validate();
	}
	
	public ActionErrors validate() throws Exception{
		return null;
	}
	/*
	 * inicia as configurações padrões do form
	 */
	public void init(HttpServletRequest request) throws Exception{
		init();
	}
	
	public void init() throws Exception{
		
	}
}

/*
 * form para manipulação de registros do DB
 */
public class DBForm extends Form {
	public final static String ACTION_NEW = "new";
	public final static String ACTION_EDIT = "edit";
	public final static String ACTION_DELETE = "delete";
	public final static String ACTION_VIEW = "view";

private Persistencia daoForm;
	private String postForward = "closereload";

public DBForm(Persistencia dao){
		daoForm = dao;
	}
	
	public String getPostForward() {
		return postForward;
	}
	
	public void setPostForward(String postForward) {
		this.postForward = postForward;
	}
	
	public Persistencia getDAO() throws Exception {
		return daoForm;
	}
	
	public void setSession(Session session) {
		super.setSession(session);
		if (daoForm != null)
			daoForm.setSession(session);
	}
	
	public void setDAO(Persistencia daoForm) {
		this.daoForm = daoForm;
	}
	/*
	 * seta as propriedades do objeto passado no parametro nas propriedades do formBean
	 */
	public void setObject(Object obj) throws Exception{
		
	}
	/*
	 * localiza ou cria um objeto setando nele as propriedades do formBean
	 */
	public Object getObject() throws Exception{
		return null;
	}
	/*
	 * localiza um objeto atraves da propriedade id do formBean
	 */
	public Object getObjectId() throws Exception{
		return daoForm.search(Utils.execMethod(this, "getid"+daoForm.getTabela()).toString()); // Utils.execMethod -> executa o metodo x do objeto y
	}
	
	public String onNew() throws Exception{
		Object obj = getObject();
		daoForm.insert(obj);
		return postForward;
	}
	
	public String onEdit() throws Exception{
		Object obj = getObject();
		daoForm.update(obj);
		return postForward;
	}
	
	public String onDelete() throws Exception{
		Object obj = getObjectId();
		daoForm.delete(obj);
		return postForward;
	}
	
	public String onNew(HttpServletRequest request) throws Exception{
		return onNew();
	}
	
	public String onEdit(HttpServletRequest request) throws Exception{
		return onEdit();
	}
	
	public String onDelete(HttpServletRequest request) throws Exception{
		return onDelete();
	}
	
	public boolean isNew() throws Exception{
		try{
			return getFormAction().equals(DBForm.ACTION_NEW);
		}catch(Exception e){
			return false;
		}
	}
	
	public boolean isEdit() throws Exception{
		try{
			return getFormAction().equals(DBForm.ACTION_EDIT);
		}catch(Exception e){
			return false;
		}
	}
	
	public boolean isDelete() throws Exception{
		try{
			return getFormAction().equals(DBForm.ACTION_DELETE);
		}catch(Exception e){
			return false;
		}
	}
	
	public boolean isView() throws Exception{
		try{
			return getFormAction().equals(DBForm.ACTION_VIEW);
		}catch(Exception e){
			return false;
		}
	}
}

/*
 * form de pesquisas generica
 */
public class PesquisaForm extends Form {
	private String sql;
	private String filtro;
	public String getFiltro() {
		return filtro;
	}
	public void setFiltro(String filtro) {
		this.filtro = filtro;
	}
	public String getSql() {
		return sql;
	}
	public void setSql(String sql) {
		this.sql = sql;
	}
}

/*
 * action generica que seta a session, valida transação e ocorrencia de erros
 */
public abstract class GenericAction extends Action {
	private Session session;
	
	public final ActionForward execute(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		ActionForward forward = null;
		Form formBean = (Form) form;
		try{
			session = (Session) request.getAttribute("sessionDB");
			formBean.setSession(session);
			forward = onExecute(mapping, formBean, request, response);
			request.setAttribute("transaction", "true");
			
		}catch(Exception e){
			request.setAttribute("transaction", "false");
			request.getSession().setAttribute("exception", e);
			forward = mapping.findForward("erro");
			
		}
		return forward;
	}
	
	public abstract ActionForward onExecute(ActionMapping mapping, Form form, HttpServletRequest request, HttpServletResponse response) throws Exception;
	
	public Session getSession() {
		return session;
	}

public void setSession(Session session) {
		this.session = session;
	}
}

/*
 * action responsavel por carregar um registro especificado em um formBeam - abre o form para view, edit e inset
 */
public abstract class FormAction extends GenericAction {
	public final ActionForward onExecute(ActionMapping mapping, Form form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		DBForm dbForm = (DBForm)form;
		String forward = "";
		Object obj = null;
		if (dbForm .isNew()){
			dbForm .init(request);
			dbForm .reset(request);
			obj = dbForm .getObject();
			forward = "form";
		}else
		if (dbForm .isEdit()){
			dbForm .init(request);
			obj = dbForm .getObjectId();
			dbForm .setObject(obj);
			forward = "form";
		}else
		if (dbForm .isView()){
			obj = dbForm .getObjectId();
			forward = "view";
		}
		request.getSession().setAttribute("registro"+dbForm.getDAO().getTabela(), obj); // seta o registro na session
		return mapping.findForward(forward);
	}
}

/*
 * action que efetiva as operações com o banco - insert, edit e delete
public abstract class PostAction extends GenericAction {
	public final ActionForward onExecute(ActionMapping mapping, Form form, HttpServletRequest request, HttpServletResponse response) throws Exception {
		DBForm dbForm = (DBForm)form;
		String forward = "";
		if (dbForm.isDelete()){
			forward = dbForm.onDelete(request);
		}else{
			ActionErrors erro = dbForm.validate(request);
			if (erro != null && !erro.isEmpty()){
				saveErrors(request, erro);
				return mapping.findForward("form");
			}
			if (dbForm.isNew()){
				forward = dbForm.onNew(request);
			}else
			if (dbForm.isEdit()){
				forward = dbForm.onEdit(request);
			}
		}
		return mapping.findForward(forward);
	}
}

/*
 * action que executa pesquisas
 */
public abstract class PesquisaAction extends GenericAction {

protected abstract Persistencia getDAO();

public final ActionForward onExecute(ActionMapping mapping, Form f, HttpServletRequest request, HttpServletResponse response) throws Exception {
		PesquisaForm form = (PesquisaForm)f;
		Persistencia dao = getDAO();
		dao.setSession(form.getSession());

String sql = "";
		if (form.getSql() != null && !form.getSql().equals(""))
			sql = form.getSql().toString();
		String sqlExec = sql.toString();
		if (sqlExec.equals(""))
			sqlExec = (form.getFiltro() != null && !form.getFiltro().equals("")) ? form.getFiltro() : "";
		else
			sqlExec += (form.getFiltro() != null && !form.getFiltro().equals("")) ? " and (" + form.getFiltro() + ")" : "";
		if (sqlExec.equals(""))
			request.getSession().setAttribute("resultado"+dao.getTabela(), dao.select());
		else
			request.getSession().setAttribute("resultado"+dao.getTabela(), dao.execSQL("from " + dao.getTabela() + " pesquisa where " + sqlExec));
		
		form.setFormAction(dao.getTabela());
		return mapping.findForward("pesquisa");
	}
}

// até aqui temos as classes genericas

/*
 * objeto de negocio - Setor
 */
public class Setor implements java.io.Serializable {
	private java.lang.Integer idSetor;
	private java.lang.String descricao;
	// ... geteres e seteres
}

public class SetorDAO extends Persistencia {
	public SetorDAO(){	
	}
	public SetorDAO(Session session){
		setSession(session);
	}
	public Class getDAOClass() {
		return Setor.class;
	}
	public boolean isDAOClass(Object obj){
		return (obj instanceof Setor);
	}
}

public class SetorForm extends DBForm {
	private String idSetor;
	private String descricao;

public SetorForm() {
		super(new SetorDAO());
	}
	public String getDescricao() {
		return descricao;
	}
	public void setDescricao(String descricao) {
		this.descricao = descricao;
	}
	public String getIdSetor() {
		return idSetor;
	}
	public void setIdSetor(String idSetor) {
		this.idSetor = idSetor;
	}
	
	public Object getObject() throws AppException {
		Setor setor = (Setor) getObjectId();
		if (setor == null){
			setor = new Setor();
			setor.setIdSetor( Integer.valueOf(idSetor) );
		}
		setor.setDescricao( descricao );
		return setor;
	}
	
	public void setObject(Object obj) throws AppException {
		Setor setor = (Setor) obj;
		descricao = setor.getDescricao();
		
		getDAO().setBeforeObject(Utils.clone(setor)); // faz um backup do objeto caso precise reaver os dados
	}
	
	public void reset() throws Exception {
		descricao = "";
		idSetor = "0";
	}
}

//.. há controles de acesso mas são dispensaveis
public class PesquisaSetorAction extends PesquisaAction {
	protected Persistencia getDAO() {
		return new SetorDAO();
	}
}

//.. há controles de acesso mas são dispensaveis
public class PostSetorAction extends PostAction {

}

//.. há controles de acesso mas são dispensaveis
public class FormSetorAction extends FormAction {
}

ele pode ate reaproveitar action mas formbean não, porque senão daria erros... pelo menos na teoria...

na verdade estava usando ThreadLocal mas nao funcionou legal por causa de session, objetos lazy e transactions...

hibernate é muito bom mas ate hoje nao consegui rodar 100% usando struts.

o pessoal fala que roda, mandam consultar a documentação do struts e hibernate mas nunca resolvo o problema.

não há exemplos, dicas e/ou tutoriais de struts e hibernate juntos, pelo menos eu ate hoje nao achei.

tenho uma aplicação em swing e nunca tive problemas, roda 100% mas quando a coisa é web, em especial struts, o trosso da zebra.

alguem tem um exemplo de struts e hibernate rodando juntos? ou será que tem outra solução melhor?

alguem pode me ajudar?

ola pessoal...

tenho uma webapp em struts.
uso hibernate para persistencia.

criei um filter que controla sessions e transactions com o banco de dados.

tudo funciona perfeitamente até um ponto.
se voces repararem, a cada request é criado uma session e uma transação com o banco de dados.
aconteceu por duas vezes um fato q eu nao entendi.

dois usuarios estavam trabalhando normalmente no sistema, e, em um instante, eles fizeram operações identicas, ou seja, ambos entraram no cadastro de cliente e cadastraram dois clientes diferentes mas quando foram salvar os dados no banco, foi salvo dois registros identicos, iguais porem com id diferente.

é como se a session estivesse fora de sincronismo, mas teoricamente so daria erro se fosse a mesma session, o que não é.

para cada request há uma nova session, que ao final do request é fechado.

será que alguem pode me ajudar?

sim, está correto...
chain.doFilter é o antes e o depois do request (action e jsp).

ok, mas ja tem 2 dias e ninguem falou nada.
em outros topicos percebe-se que as respostas são bem rápidas.

deixa pra lá...

em relação ao pool, não usei...
sei poco sobre pool...
se puder, me explique como é, como funciona e como implementar?

vlw!

alguem usa hibernate neste mundo???

realmente o problema é a conecção que está fechando por timeout.

como faço para ver se a conecção está fechada?
e como reabrir a conecção???

acho que sei o que está acontecendo.

fiz algumas alterações...
usei filtros http://www.guj.com.br/java.tutorial.artigo.11.1.guj para servlets e adicionei um closeSession() para que as sessoes abertas fossem fechadas.

mesmo assim dá um erro apos muito tempo sem atividade.

o problema parece que é na conecção...
após um tempo, a conection com o bd é fechada, ai quando vou iniciar uma session dá este erro:

java.sql.SQLException: No operations allowed after connection closed.
	at com.mysql.jdbc.Connection.checkClosed(Connection.java:2647)
	at com.mysql.jdbc.Connection.rollback(Connection.java:1410)
	at org.hibernate.transaction.JDBCTransaction.rollback(JDBCTransaction.java:134)
	at org.noip.fabiobh.db.Persistencia.rollback(Persistencia.java:240)
	at org.noip.fabiobh.control.action.GenericAction.execute(GenericAction.java:54)
	at org.apache.struts.action.RequestProcessor.processActionPerform(RequestProcessor.java:484)
	at org.apache.struts.action.RequestProcessor.process(RequestProcessor.java:274)
	at org.apache.struts.action.ActionServlet.process(ActionServlet.java:1482)
	at org.apache.struts.action.ActionServlet.doGet(ActionServlet.java:507)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:689)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:802)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:237)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:157)
	at org.displaytag.filter.ResponseOverrideFilter.doFilter(ResponseOverrideFilter.java:125)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:186)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:157)
	at org.noip.fabiobh.db.SessionFilter.doFilter(SessionFilter.java:43)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:186)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:157)
	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:214)
	at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
	at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
	at org.apache.catalina.core.StandardContextValve.invokeInternal(StandardContextValve.java:198)
	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:152)
	at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
	at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
	at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:117)
	at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:102)
	at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
	at org.apache.catalina.core.StandardValveContext.invokeNext(StandardValveContext.java:104)
	at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:520)
	at org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:929)
	at org.apache.coyote.tomcat5.CoyoteAdapter.service(CoyoteAdapter.java:160)
	at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:799)
	at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:705)
	at org.apache.tomcat.util.net.TcpWorkerThread.runIt(PoolTcpEndpoint.java:577)
	at org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:683)
	at java.lang.Thread.run(Thread.java:534)

ninguem sabe hibernate aqui não???

pessoal, to com um problema que não estou conseguindo resolver.

tenho uma appweb com hibernate.
há uma action generica com todos os controles genericos: controle de acesso, beans, transações, exceptions...

sempre quando a action generica é executada, a ultima session do hibernate é fechada. Alem disso abro uma transação (e session) e a fecho ao final da execução da action. Porem existe objetos (lazy do hibernate) que são carregados durante a execução do JSP, o que não me permite fechar a session ao final da action e sim no inicio da proxima action (ou a ultima session).

está correto o que eu fiz?

aparentemente está tudo ok.
starto o servidor e uso normalmente, sem problemas...
o que está acontecendo é que após um bom periodo sem uso, acontece um monte de erros no hibernate. parece que é um timeout. Talvez seja na ultima session que foi fechada ou então na SessionFactory que foi perdida.

um dos erros:
org.hibernate.exception.GenericJDBCException: could not execute query

voce não pode colocar uma taglib dentro de uma propriedade de outra taglib. não desta forma

tente colocar o valor usando jsp:

Notícias, artigos e o maior fórum brasileiro sobre Java