dbcon.java

struts+spring+hibernate新闻管理

package org.qhit.common;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;

public class DBcon {
	Configuration cfg = null;
	SessionFactory sf = null;
	Session s = null;
	Transaction tx = null;
	
	public DBcon(){
		cfg = new Configuration().configure();
		sf = cfg.buildSessionFactory();
	}
	
	public boolean login(String un,String up){
		boolean b = false;
		ArrayList al = new ArrayList();
		s = sf.openSession();
		Query query = s.createQuery("from Userinfo as u where uname='"+un+"'and upass='"+up+"'");
		al = (ArrayList)query.list();
		if(al.size()>0) b=true;
		s.close();
		return b;
	}
	
	public ArrayList query(String hql){
		ArrayList al = new ArrayList();
		s = sf.openSession();
		Query query = s.createQuery(hql);
		al = (ArrayList)query.list();
			for(int i=0;i<al.size();i++){
				//System.out.println(((Userinfo)al.get(i)).getRoleinfo().getRname());
			}
		//s.close();
		return al;		
	}
	
	public ArrayList query_all(){
		return query("from Userinfo as u");
	}

	public ArrayList query_role(){
		return query("from Roleinfo as u");
	}	
	
	public void ins(Object obj){
		s = sf.openSession();
		tx = s.beginTransaction();
		s.save(obj);
		//tx.rollback();
		tx.commit();//事务的提交
		s.flush();  //刷新会话
	}
	
	public void update(Object obj){
		s = sf.openSession();
		tx = s.beginTransaction();
			try {
//				s.load(obj,new Integer(id));
				s.update(obj);
				tx.commit();//事务的提交
				s.flush();  //刷新会话
			} catch (HibernateException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
				s.close();
			}
//		s = sf.openSession();
//		s.update(obj);
		s.close();//sf.close();
	}
	
	public void delete(Object obj){
//  	  String   hql="delete from Userinfo where uid=44"; 
		s=sf.openSession();
		tx = s.beginTransaction();
//  	  s.createQuery(hql).executeUpdate();
		s.delete(obj);
		tx.commit();//事务的提交
		s.flush();  //刷新会话
		s.close();//sf.close();
	}	
	
	public static void main(String args[]){
		DBcon db=new DBcon();
		db.query_all();
	}
}