commondao.java

jfreechart 柱状图 均值图 和值图 实例

package zyyt.common;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.beanutils.BasicDynaBean;
import org.apache.commons.beanutils.RowSetDynaClass;
import org.apache.log4j.Logger;
import org.hibernate.Query;
import org.hibernate.Session;



public class CommonDAO {

	private static final Logger logger = Logger.getLogger(CommonDAO.class);
	
	public RowSetDynaClass findBySQL(String queryString, Object[] params) throws SQLException{
		if(true){
			System.out.println("findBySQL sql="
						+queryString);
		}
		Session session = HibernateSessionFactory.getSession();
		
		Connection conn = session.connection();
		RowSetDynaClass result = null;
		try {
			PreparedStatement ps = conn.prepareStatement(queryString);
			for (int i = 0; i < params.length; i++) {
				Object param = params[i];
				ps.setObject(i + 1, param);
			}
			ResultSet rs = ps.executeQuery();
			result = new RowSetDynaClass(rs);
			rs.close();
			ps.close();
			session.close();

		} catch (SQLException e) {
			throw e;
		}

		return result;
	}

	public boolean executeSQLStatement(String sqlStatement, Object[] params)
			throws SQLException {
		Session session = HibernateSessionFactory.getSession();
				
		Connection conn = session.connection();
		boolean result;
		PreparedStatement ps = null;
		try {
			ps = conn.prepareStatement(sqlStatement);
			for (int i = 0; i < params.length; i++) {
				Object param = params[i];
				ps.setObject(i + 1, param);
			}
			session.beginTransaction();
			result = ps.execute();
			session.beginTransaction().commit();
			ps.close();
			session.close();
			
		} catch (SQLException e) {
			logger.error("Method:executeSQLStatement(String sqlStatement, Object[] params)", e);
			session.beginTransaction().rollback();
			try {
				ps.close();
				session.close();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			throw new SQLException("Execute SQL Satatement Unsuccessfully!");
		}
		return result;
	}

	public boolean executeSQLStatement(String sqlStatement) throws SQLException {
		return executeSQLStatement(sqlStatement, new Object[] {});
	}

public RowSetDynaClass findBySQL(String queryString) throws Exception{
		return this.findBySQL(queryString, new String[] {});
	}


public static long getNextSqu(String seqname)
{
	Session session=null;
	Connection conn=null;
  long nextID = 0l;
  try
  {
    session = HibernateSessionFactory.getSession();
    conn = session.connection();
    String nextSQL = "select " + seqname + ".nextval from dual";
    PreparedStatement ps = conn.prepareStatement(nextSQL);
    ResultSet rs = ps.executeQuery();
    if (rs.next())
      nextID = rs.getLong(1);
      rs.close();
	}
  catch(Exception sqe)
  {
    sqe.printStackTrace();
  }finally{ 
		  try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} 
		  session.close();
	  }
  return nextID;
}
	

/*@SuppressWarnings("unchecked")
public List getAdminPage(String conditionsql1,int startRecord ,int endRecord)
	{
		List list1=null;
		List list2=new ArrayList();
		System.out.println("start--------->"+startRecord);
		System.out.println("end--------->"+endRecord);
		try {
			list1=this.findBySQL(conditionsql1+"").getRows();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		System.out.println("pagelistsize="+list1.size());
		for(int i=startRecord;i<list1.size()&& i<endRecord;i++){
			
				BasicDynaBean bean=(BasicDynaBean) list1.get(i);
				list2.add(bean);
			
		}
		return list2;
	}
public List getAdminPage1(String conditionsql1,int startRecord ,int endRecord)
{
	List list1=new ArrayList();
	List list2=new ArrayList();
	System.out.println("start--------->"+startRecord);
	System.out.println("end--------->"+endRecord);
	int numberRecord=endRecord-startRecord;
	try {
		//list1=this.findBySQL(conditionsql1+"").getRows();
		Session session = HibernateSessionFactory.getSession();
		Query query=session.createQuery(conditionsql1+"");
		query.setFirstResult(startRecord);
		query.setMaxResults(numberRecord);
		list1=query.list();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
	
	System.out.println("pagelistsize="+list1.size());
	for(int i=0;i<list1.size();i++){
		
		Calls bean=(Calls) list1.get(i);
		list2.add(bean);
		
	}
	return list2;
}*/
	
/*	public static void main(String []arg){
		CommonDAO abc = new CommonDAO();
		try {
			String	querysql =" select   a.level_id,a.level_desc,b.type_desc   ";
			querysql +=" from dim_ability_level a,dim_ability_type b     ";
			querysql +=" where a.type_id=b.type_id	 order by a.level_id   ";
				 
			List list  = abc.findBySQL(querysql).getRows();
			for (int i = 0; i < list.size(); i++) {
				BasicDynaBean bean = (BasicDynaBean) list.get(i);
				System.out.print(bean.get("level_id").toString()+"|");
				System.out.print(bean.get("level_desc").toString()+"|");
				System.out.println(bean.get("type_desc").toString());
			}
			System.out.println(abc.getNextSqu("function_id"));
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	*/
}