/* * Copyright 2004-2007 IDCA. All rights reserved. * * Redistribution and use in source and binary forms, with or without modification, are permitted provided that the * following conditions are met: * * 1. Redistributions of source code must retain the above copyright notice, this list of conditions and * the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions * and the following disclaimer in the documentation and/or other materials provided with the * distribution. * * THIS SOFTWARE IS PROVIDED BY IDCA AND CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL IDCA OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. * * The views and conclusions contained in the software and documentation are those of the authors and * should not be interpreted as representing official policies, either expressed or implied, of IDCA. */ package com.idcanet.vasc.impl.serv5; import java.util.List; import java.util.logging.Level; import com.idcanet.serv5.services.hibernate3.Hibernate3Factory; import com.idcanet.vasc.core.VascDataSource; import com.idcanet.xtes.xpql.query.Query; /** * * @author Willem Cazander * @version 1.0 Mar 21, 2007 */ public class Serv5HibernateVascDataSource implements VascDataSource { private String session = null; public Serv5HibernateVascDataSource() { } public Serv5HibernateVascDataSource(String session) { setSession(session); } public List executeQuery(Query query) throws Exception { try { /* Query q = Hibernate3Factory.getSession("flowstats").createQuery(query.toString()); q.setMaxResults(crudTable.getQueryLimit()); if(crudTable.getViewOnly()) { q.setReadOnly(true); } for(CrudParameterOption para:crudTable.getQueryParameterOptions().values()) { if(para.getValueHolder().getValue()==null) { logger.finer("Value is null of parameter: "+para.getName()); return; } try { Object value = para.getValueHolder().getValue(); logger.finer("Setting parameter: "+para.getName()+" with: "+value); if(para.getValueProperty()!=null) { q.setParameter(para.getName(),BeanUtils.getValue(value,BeanUtils.getPropertyDescriptor(value,para.getValueProperty()))); } else { q.setParameter(para.getName(),value); } } catch (Exception e) { logger.log(Level.WARNING,e.getMessage(),e); } } List data = q.list(); logger.info("Query returned: "+data.size()+" of: "+crudTable.getQueryName()); crudTable.getSelectionInList().setList(data); */ return null; } finally { Hibernate3Factory.getSession("flowstats").close(); // close session in threads } } public void persist(Object object) throws Exception { try { Hibernate3Factory.getSession(getSession()).persist(object); } finally { Hibernate3Factory.getSession(getSession()).close(); } } /** * @return the session */ public String getSession() { return session; } /** * @param session the session to set */ public void setSession(String session) { this.session = session; } }