clientdao.java

gensou.rar为某渔具厂的一个简单ERP系统。为比较基础的工程

package com.gensou.dao.sheji.client;

import java.util.ArrayList;
import java.util.List;

import org.hibernate.*;

import com.gensou.hibernate.model.Client;
import com.gensou.hibernate.util.HibernateSessionFactory;
import com.gensou.logic.sheji.client.AddClientService;
import com.gensou.logic.sheji.client.QueryClientService;
import com.gensou.logic.sheji.client.UpdateclientService;
import com.gensou.util.Pagination;

public class Clientdao {
 public boolean addclient(AddClientService addclient){
	boolean bo=false;
	Query query;
	List list;
	Session session=HibernateSessionFactory.getSession();
	Transaction tx=session.beginTransaction();
	Client client=new Client(); 
	String clientid=addclient.getClientId();
	
    query = (Query) session.createQuery("from Client where clientId=?");
    query.setString(0,clientid);
	list=query.list();
	if(!list.isEmpty()){
		return bo;
	}else{
		client.setClientId(clientid);
		client.setClientName(addclient.getClientName());
		client.setClientAddress(addclient.getClientAddress());
		client.setClientTel(addclient.getClientTel());
		client.setClientFax(addclient.getClientFax());
		client.setClientEmi(addclient.getClientEmi());
		client.setBeizhu(addclient.getBeizhu());
		client.setZhuangtai(addclient.getZhuangtai());
		session.save(client);
		session.flush();
		tx.commit();
		query = (Query) session.createQuery("from Client where clientId=?");
	    query.setString(0,clientid);
	    list=query.list();
	    if(!list.isEmpty()){
	    	session.flush();
	    	session.close();
	    	return bo=true;
	    }else{
	    	session.flush();
	    	session.close();
	    	return bo;
	    }
	}
	
 }
 public List queryclient(String clientName,int pag,int max){
	List client_info = new ArrayList();
	Session session=HibernateSessionFactory.getSession();
	Query query;
	String str;
	try{
		str=clientName;
		if(str==null||str.equals("")){
			
			query = (Query) session.createQuery("from Client");
			Pagination pagination=new Pagination();
			client_info=pagination.getNowlist(query,pag,max);
		    
		   
		    
		}else{
			String name="%"+clientName+"%";
			query = (Query) session.createQuery("from Client where clientName like ?");
		    query.setString(0,name);
		    client_info=query.list();
		}
	}catch(NullPointerException e){}
	session.flush();
	session.close();
	return client_info; 
 }
 public void deleteclient(String cid,String zhuangtai){
	 Session session=HibernateSessionFactory.getSession();
	 Transaction tx=session.beginTransaction();
	 try{
		 Integer id=Integer.parseInt(cid);
		 Client cl=(Client)session.load(Client.class, id);
		 cl.setZhuangtai(zhuangtai);
		 session.save(cl);
		 session.flush();
		 tx.commit();
	     session.close();
	 }catch(Exception e){
		 tx.rollback();
		 session.close();
	 }
 }
 public boolean updateclient(UpdateclientService updateclient){
	 boolean bo=false;
	 Session session=HibernateSessionFactory.getSession();
	 Transaction tx=session.beginTransaction();
	 Query query;
	 query = (Query) session.createQuery("from Client where clientName=?");
	 query.setString(0,updateclient.getClientName());
	 List list=query.list();
	 if(list.isEmpty()){
		 session.flush();
	     session.close();
		 return bo;
	 }
	 Client client=new Client(); 
	 try{
		 
		String cid=updateclient.getId();
		Integer id=Integer.parseInt(cid);
		client=(Client)session.load(Client.class, id);
		client.setClientName(updateclient.getClientName());
		client.setClientAddress(updateclient.getClientAddress());
		client.setClientTel(updateclient.getClientTel());
		client.setClientFax(updateclient.getClientFax());
		client.setClientEmi(updateclient.getClientEmi());
		client.setBeizhu(updateclient.getBeizhu());
		session.update(client);
		session.flush();
		tx.commit();
		bo=true;
    	session.close();
	 }catch(Exception e){
		 tx.rollback();
		 session.close();
		 return bo;
	 }
	 return bo; 
 }
}