dbserver.java

struts hibernate初学者使用

package hibernate;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

import hibernate.Mybook;
import strutsForm.FindForm;

public class DBServer {

	public DBServer() {
		
	}
	public static List find(int count, String findname, String findemail){		
		int countAll;
		int pageCount;
		Session session=HibernateSessionFactory.currentSession();
		Transaction tx=session.beginTransaction();
		Query queryCount = session.createQuery("from Mybook c where c.name = '"+findname+"' or c.email = '"+findemail+"'");
		List list1 = queryCount.list();
		
		countAll = list1.size();
		if(countAll%5 == 0){
			pageCount = countAll/5;
		}else{
			pageCount = countAll/5 + 1;
		}
		if(countAll != 0){
			//Query query = session.createQuery("select c.id, c.name from Mybook c where c.id = "+1+"");
			Query query = session.createQuery("from Mybook book where book.name = '"+findname+"' or book.email = '"+findemail+"'");
			query.setFirstResult((count-1) * 5);
			query.setMaxResults(5);
			
			FindForm  findform = null;				
			List list = query.list();
			List<FindForm> formList = new ArrayList<FindForm>();
			for(int i = 0;i<list.size(); i++){
				findform = new FindForm();
				
				Mybook listMybook =  (Mybook) list.get(i);
				Integer id = listMybook.getId();
				String name = listMybook.getName();
				String email = listMybook.getEmail();
				String book_name = listMybook.getBook().getBook_name();
				
				findform.setId(id);
				findform.setName(name);
				findform.setEmail(email);
				findform.setBook_name(book_name);
				findform.setCountAll(countAll);
				findform.setPageCount(pageCount);
				//System.out.println("email" + email);
				formList.add(findform);
			}
			tx.commit();
			return formList;
		}else{
			List<FindForm> formList = new ArrayList<FindForm>();
			FindForm findform = new FindForm();
			findform.setCount(0);
			formList.add(findform);
			tx.commit();
			session.close();
			return formList;
		}
		
	}
	public static void selectMany(){
		Session session = HibernateSessionFactory.currentSession();
		Transaction tx = null;
		//try{
			tx = session.beginTransaction();
			Query query = session.createQuery("from Book b where b.id = "+1+"");
			List list = query.list();
			for(int i = 0; i<list.size(); i++){
				Book book = (Book) list.get(i);
				for(Iterator it = book.getMybook().iterator(); it.hasNext();){
					Mybook mybook = (Mybook) it.next();
					String name = mybook.getName();
					System.out.println(name);
				}
			}
		//}catch(Exception e){
		//	System.out.println(e);
		//}finally{
		//	session.close();
		//}
	}
	
	public static boolean insert(String name,String email){		
		Session session = HibernateSessionFactory.currentSession();
		Transaction tx = null;
		try{
			tx=session.beginTransaction();	
			
			//Book book = new Book();
			
			Mybook mybook = new Mybook();			
			mybook.setName(name);
			mybook.setEmail(email);
			
			//book.setMybook(mybook);
			//session.save(book);
			session.save(mybook);
			tx.commit();
			return true;
		}catch(Exception e){
			return false;
		}finally{
			session.close();
		}	
	}
	public static boolean update(String editId, String editName, String editEmail){		
		Session session = HibernateSessionFactory.currentSession();
		Transaction tx = null;
		try{
			tx=session.beginTransaction();
			Query query = session.createQuery("from Mybook c where c.id = "+editId+"");
			Mybook mybook = (Mybook) query.list().get(0);

			mybook.setName(editName);
			mybook.setEmail(editEmail);
			session.update(mybook);
			tx.commit();
			return true;
		}catch(Exception e){
			return false;
		}finally{
			session.close();
		}	
	}
	public static boolean delete(String editId){
		Session session = HibernateSessionFactory.currentSession();
		Transaction tx = null;
		try{
			tx = session.beginTransaction();
			Query query = session.createQuery("from Mybook c where c.id = "+editId+"");
			Mybook mybook = (Mybook) query.list().get(0);
			session.delete(mybook);
			tx.commit();
			return true;
		}catch(Exception e){
			return false;
		}finally{
			session.close();
		}
		
	}
}