userdao.java

这是充值消费系统

package com.my.dao;

import java.util.Date;
import java.util.List;
import java.util.Vector;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;


import com.my.hibernate.*;

public class UserDao {
	
	Session session;
	Transaction tx;
	Query query;
	User user;
	Vector v=new Vector();
	Object obj[]=null;
	public Vector User(){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str;
		str="from User";
		try{
			
			query=session.createQuery(str);
			List list=query.list();
			for(int i=0;i<list.size();i++){
				user=(User)list.get(i);
				v.add(user);
			}
			tx.commit();
			if(session.isOpen()){
				session.close();
				
			}
			return v;
		}catch(Exception ex){
			ex.printStackTrace();
			tx.rollback();
			return null;
		}
		
	}
	public boolean loginValidate(String username,String password){

		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str="from User as u where u.username=:username and u.password=:password";
		try{
			 query=session.createQuery(str);
			 query.setString("username", username);
			 query.setString("password",password);
			 List list=query.list();
			 if(list.size()>0){
				 return true;
			 }
			 tx.commit();	 
			if(session.isOpen()){
				session.close();
			}	 
				return false;
			}catch(Exception ex){
				ex.printStackTrace();
				tx.rollback();
				return false;
			}
	}
	public Vector getQueryResult(String username)
    {
  	 session=HibernateSessionFactory.getSession();
  	 tx=session.beginTransaction();
  	 String str="from User u where u.username=?";
  	 try{
  		 query=session.createQuery(str);
  		 query.setString(0, username);
  		 List list=query.list();
  		 for(int i=0;i<list.size();i++){
  			user=(User)list.get(i);
			v.add(user);
  		 }
           tx.commit();
           session.close();
           return v;
  	 }catch(HibernateException e){
  		 e.printStackTrace();
  		 tx.rollback();
  		 return null;
  	 
  	 }
  	 
    }
	public Vector id(String id)
    {
  	 session=HibernateSessionFactory.getSession();
  	 tx=session.beginTransaction();
  	 String str="from User u where u.UId=?";
  	 try{
  		 query=session.createQuery(str);
  		 query.setString(0, id);
  		 List list=query.list();
  		 for(int i=0;i<list.size();i++){
  			user=(User)list.get(i);
			v.add(user);
  		 }
           tx.commit();
           session.close();
           return v;
  	 }catch(HibernateException e){
  		 e.printStackTrace();
  		 tx.rollback();
  		 return null;
  	 
  	 }
  	 
    }
	public Vector chong(String id)
    {
  	 session=HibernateSessionFactory.getSession();
  	 tx=session.beginTransaction();
  	 String str="from User u where u.UId=?";
  	 try{
  		 query=session.createQuery(str);
  		 query.setString(0, id);
  		 List list=query.list();
  		 for(int i=0;i<list.size();i++){
  			user=(User)list.get(i);
			v.add(user);
  		 }
           tx.commit();
           session.close();
           return v;
  	 }catch(HibernateException e){
  		 e.printStackTrace();
  		 tx.rollback();
  		 return null;
  	 
  	 }
  	 
    }
	public void insert(User user){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			session.save(user);
			tx.commit();
			session.close();			
			
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
		
		
	}
	public void cinsert(CUser user){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			session.save(user);
			tx.commit();
			session.close();			
			
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
		
		
	}
	public void xinsert(XUser user){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			session.save(user);
			tx.commit();
			session.close();			
			
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
		
		
	}
	public void delete(String id){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			User user=(User)session.get(User.class, new Integer(Integer.parseInt(id)));
			session.delete(user);
			tx.commit();
			session.close();
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
	}
	public void update(User user,String id){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			User user1=(User)session.get(User.class, new Integer(Integer.parseInt(id)));
			
			user1.setPassword(user.getPassword());
			user1.setType(user.getType());
			
			session.update(user1);
			tx.commit();
			session.close();
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
		
	}
public void update1(User user,String id){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			User user1=(User)session.get(User.class, new Integer(Integer.parseInt(id)));
			
			user1.setEmoney(user.getEmoney());
			
			
			session.update(user1);
			tx.commit();
			session.close();
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
		
	}
	public Vector CUser(){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str;
		str="from User u,CUser c where u.UId=c.UId";
		try{
			
			query=session.createQuery(str);
			List list=query.list();
			for(int i=0;i<list.size();i++){
				obj=(Object[])list.get(i);
				v.add(obj);
			}
			tx.commit();
			if(session.isOpen()){
				session.close();
				
			}
			return v;
		}catch(Exception ex){
			ex.printStackTrace();
			tx.rollback();
			return null;
		}
		
	}
	public Vector XUser(){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str;
		str="from User u,XUser x where u.UId=x.UId";
		try{
			
			query=session.createQuery(str);
			List list=query.list();
			for(int i=0;i<list.size();i++){
				obj=(Object[])list.get(i);
				v.add(obj);
			}
			tx.commit();
			if(session.isOpen()){
				session.close();
				
			}
			return v;
		}catch(Exception ex){
			ex.printStackTrace();
			tx.rollback();
			return null;
		}
		
	}
	public void cdelete(String id){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			CUser cuser=(CUser)session.get(CUser.class, new Integer(Integer.parseInt(id)));
			session.delete(cuser);
			tx.commit();
			session.close();
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
	}
	public void xdelete(String id){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		try{
			XUser xuser=(XUser)session.get(XUser.class, new Integer(Integer.parseInt(id)));
			session.delete(xuser);
			tx.commit();
			session.close();
		}catch(HibernateException e){
			e.printStackTrace();
			tx.rollback();
		}
	}
	public Vector CUser(String date){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str;
		str="from User u,CUser c where u.UId=c.UId and c.CDate=?";
		try{
			
			query=session.createQuery(str);
			query.setString(0, date);
			List list=query.list();
			for(int i=0;i<list.size();i++){
				obj=(Object[])list.get(i);
				v.add(obj);
			}
			tx.commit();
			if(session.isOpen()){
				session.close();
				
			}
			return v;
		}catch(Exception ex){
			ex.printStackTrace();
			tx.rollback();
			return null;
		}
		
	}
	public Vector XUser(String time){
		
		session=HibernateSessionFactory.getSession();
		tx=session.beginTransaction();
		String str;
		str="from User u,XUser x where u.UId=x.UId and x.XTime=?";
		try{
			
			query=session.createQuery(str);
			query.setString(0, time);
			List list=query.list();
			for(int i=0;i<list.size();i++){
				obj=(Object[])list.get(i);
				v.add(obj);
			}
			tx.commit();
			if(session.isOpen()){
				session.close();
				
			}
			return v;
		}catch(Exception ex){
			ex.printStackTrace();
			tx.rollback();
			return null;
		}
		
	}
}