一、與資料庫的互動（增刪改查）

注意：1.寫hql語言是是對於物件操作，而不是表資料

            2.注意hibernate中的快取

1.Hibernate 查詢方式

Hibernate配備了一種非常強大的查詢語言，這種語言看上去很像SQL。但是不要被語法結構上的相似所迷惑，HQL(Hibernate querylauguage)被設計為完全面向物件的查詢。

HQL對關鍵字的大寫小並不區分，但是對查詢的物件就要區分大小寫，因為它是面向物件的查詢，所以查詢的是一個物件，而不是資料庫的表，在sql中如果要加條件的話就是列，而在HQL裡面條件就是物件的屬性，而且還要給物件起別名。

1.Hibernate

查詢HQL語句

限制查詢結果記錄數與起始記錄

Sessionsession=HibernateSessionFactory.getSession();

Queryquery=session.createQuery("fromCustomer");

query.setFirstResult(10); //設定查詢記錄開始位置，索引從0開始。

query.setMaxResults(10);//設定查詢返回的最大記錄個數。

Listlist=query.list();

注意：條件查詢

Sessionsession=HibernateSessionFactory.getSession();

Queryquery=session.createQuery("from Customer cus where cus.name='zhou'");
 

2、取表中部分列時

(1) 單一屬性查詢。還是返回一個集合，只不過集合中儲存的不是表的例項而是物件。

Sessionsession =null;

session= HibernateSessionFactory.getSession();

Listcnames = session.createQuery("select cname from Customer").list();

for(inti=0;i<cnames.size();i++) {

  String name = (String)cnames.get(i);

  System.out.println(name);

}
 

(2) 多個屬性的查詢,使用物件陣列。

Sessionsession =null;

session= HibernateSessionFactory.getSession();

//查詢多個屬性，其集合元素是物件陣列

//陣列元素的型別，跟實體類的屬性的型別相關

Liststudents = session.createQuery("select sno,sname from Students").list();

for(inti=0;i<students.size();i++) {

  Object[] obj = (Object[])students.get(i);

  System.out.println(obj[0] +", " + obj[1]);

}

 (3) 多個屬性的查詢,使用List集合裝部分列

Sessionsession = HibernateSessionFactory.getSession();

Queryquery = session.createQuery("select new list(cus.name,cus.phone) from Customer cus");

Listlist = query.list();

for(int i = 0; i < list.size(); i++) {

  List temp=(List)list.get(i);

  System.out.println(temp.get(0));  //0是索引

}

 (4) 使用Map集合裝部分列

Sessionsession = HibernateSessionFactory.getSession();

Queryquery = session.createQuery("select new map(cus.name,cus.phone) from Customer cus");

Listlist = query.list();

for(int i = 0; i < list.size(); i++) {

  Map temp=(Map)list.get(i);

  System.out.println(temp.get("1"));  //"1"是key
}

3、內連線

Queryquery=session.createQuery("select c.name, s.name fromStudent s join s.classes c").list();

for(Iterator iter = students.iterator();iter.hasNext();){

  Object[] obj = (Object[])iter.next();

  System.out.println(obj[0] +", " + obj[1]);

}

4、外連線

Queryquery=session.createQuery("select c.name, s.name fromStudent s join s.classes c").list();

for(Iterator iter = students.iterator();iter.hasNext();){

  Object[] obj = (Object[])iter.next();

  System.out.println(obj[0] +", " + obj[1]);

}</span>

5、帶引數的查詢

(1) ?作為引數 如"from Customer cus where cus.name=?";

     Session session = HibernateSessionFactory.getSession();

    Query query = session.createQuery("fromCustomer cuswhere cus.name=?");

     query.setParameter(0,"zhou");

     List list = query.list();

(2) 引數名稱  :name   如" from Customer cus where cus.name=:name";

Sessionsession = HibernateSessionFactory.getSession();

     Queryquery = session.createQuery("fromCustomer cuswhere cus.name=:name");

     query.setParameter("name","zhou");

     List list = query.list();
(3)條件查詢，使用 ？的方式傳遞引數
<p><span style="color:black;"> </span>Query <span style="color:black;">query</span><span style="color:black;"> = </span><span style="color:black;">session.createQuery</span><span style="color:black;">("SELECTs.id, s.name FROM Student s WHERE s.name </span><span style="color:#333399;">LIKE ?</span><span style="color:black;">");</span></p><p><span style="color:black;">  </span> <span style="color:black;">query</span><span style="color:#333399;">.setParameter</span><span style="color:black;">(0,“%</span><span style="color:black;">周</span><span style="color:black;">%”);//</span><span style="color:black;">傳遞引數引數的索引是從</span><span style="color:black;">0</span><span style="color:black;">開始的。  </span>如條件查詢，<span style="color:#333399;">使用</span><span style="color:#333399;">":</span><span style="color:#333399;">引數</span><span style="color:#333399;">"</span><span style="color:#333399;">名稱的方式傳遞引數</span></p><p><span style="color:black;">  </span>Query <span style="color:black;">query</span><span style="color:black;"> = </span><span style="color:black;">session.createQuery</span><span style="color:black;">("SELECTs.id, s.name FROM Student s WHERE s.name </span><span style="color:#333399;">LIKE </span><span style="color:#333399;">:</span><span style="color:#333399;">myname</span><span style="color:black;">");</span></p><p><span style="color:black;">  </span><span style="color:black;">query.setParameter</span><span style="color:black;">("</span><span style="color:black;">myname</span><span style="color:black;">","</span><span style="color:black;">張三</span><span style="color:black;">");//</span><span style="color:black;">傳遞引數</span></p><p><span style="color:black;">因為</span><span style="color:black;">setParameter</span><span style="color:black;">方法返回</span><span style="color:black;">Query</span><span style="color:black;">介面，所以可用省略方式來查詢</span></p><p><span style="color:black;">Liststudents = </span><span style="color:black;">session.createQuery</span><span style="color:black;">("SELECTs.id, s.name FROM Student s WHERE s.name </span><span style="color:#333399;">LIKE :</span><span style="color:#333399;">myname</span><span style="color:#333399;"> and s.id = :</span><span style="color:#333399;">myid</span><span style="color:black;">")</span></p><p><span style="color:black;">setParameter</span><span style="color:black;">("</span><span style="color:black;">myname</span><span style="color:black;">","%</span><span style="color:black;">周</span><span style="color:black;">%").</span><span style="color:black;">setParameter</span><span style="color:black;">("</span><span style="color:black;">myid</span><span style="color:black;">",15).list();</span></p>

6、嵌入原生sql測試

SQLQuerysqlQuery = session.createSQLQuery("select * from t_student");

  List students = sqlQuery.list();

  for (Iterator iter = students.iterator();iter.hasNext();){

  Object[] obj = (Object[])iter.next();

  System.out.println(obj[0] +", " + obj[1]);

  }

2.Hibernate增加、修改方式

拿到要修改的物件，呼叫session.saveOrUpdate();方法

public void addStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		Transaction tr=session.beginTransaction();
		try {
			session.saveOrUpdate(stud);//一個方法
//			session.update(stud);
		} catch (HibernateException e) {
			e.printStackTrace();
		}
		tr.commit();
}

2.Hibernate刪除方式

public void delStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		
		Transaction tr=session.beginTransaction();
		try {
			session.delete(stud);
			session.flush();
		} catch (Exception e) {
			System.out.println("回滾了");
//			tr.rollback();
		}
		tr.commit();//刪除沒有事務不行！
	}

注意要新增事務：不然增刪改用不了

二、關於hibernate事務的必須開啟的問題

當我們在寫簡單的增刪改的時候，發現如果不開啟事務，資料就不會向資料庫提交這是因為hibernate中的session物件是Connection物件的子類，對Connection的加強，

而我們在看hibernate原始碼的時候發現Session物件中通過了代理，自動幫我們把setAtuoCommit(false),設定成不自動提交，所有我們在增刪改必須開啟事務，而且要提交，同時session還對rollback()進行了代理，所以在commit的時候是自動回滾

三、程式碼演示

package cn.hncu.demo.dao;

import java.util.List;

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

import cn.hncu.domain.Student;
import cn.hncu.hib.HibernateSessionFactory;

public class DemoDaoJdbc {
	public List<Student> queryAllStudent(){
		Session session=HibernateSessionFactory.getSession();
		//無論是Load 還是 Get 都會首先查詢快取（一級快取） 如果沒有，才會去資料庫查詢，呼叫Clear() 方法，可以強制清除Session快取
		session.clear();
		Query query=session.createQuery("from Student");
		List<Student> list=query.list();
		return list;
	}
	public void delStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		
		Transaction tr=session.beginTransaction();
		try {
			session.delete(stud);
			session.flush();
		} catch (Exception e) {
			System.out.println("回滾了");
//			tr.rollback();
		}
		tr.commit();//刪除沒有事務不行！
	}
	
	@Test
	public void t(){
		Student stud=new Student();
		stud.setStudId("S003");
		delStudent(stud);
		System.out.println(queryAllStudent());
	}

	public void addStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		Transaction tr=session.beginTransaction();
		try {
			session.saveOrUpdate(stud);
//			session.update(stud);
		} catch (HibernateException e) {
			e.printStackTrace();
		}
		tr.commit();
	}

	public Student queryAStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		String hql="from Student s where s.studId=?";
		Query query=session.createQuery(hql);
		query.setParameter(0, stud.getStudId());
		List<Student> list=query.list();
		if(list!=null&&list.size()>0){
			return list.get(0);
		}
		return null;
	}
	public List<Student> queryStudent(Student stud) {
		Session session=HibernateSessionFactory.getSession();
		String hql="from Student s where 1=1";
		if(stud.getStudId()!=null&&stud.getStudId().trim().length()>0){
			hql+=" and s.studId='"+stud.getStudId()+"'";
		}
		if(stud.getStudName()!=null&&stud.getStudName().trim().length()>0){
			hql+=" and s.studName='"+stud.getStudName()+"'";
		}
		if(stud.getStudAge()!=null){
			hql+=" and s.studAge="+stud.getStudAge();
		}
		if(stud.getDeptId()!=null&&stud.getDeptId().trim().length()>0){
			hql+="and s.deptId='"+stud.getDeptId()+"'";
		}
		Query query=session.createQuery(hql);
		List<Student> list=query.list();
		return list;
	}
}

HibernateSessionFactory

package cn.hncu.hib;

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

public class HibernateSessionFactory {
	private static final String CONFIG_FILENAME="/hibernate.cfg.xml";//檔名
	private static final ThreadLocal<Session> threadLocal=new ThreadLocal<Session>();//本地執行緒
	private static Configuration config=new Configuration();
	private static SessionFactory sessionFactory;//宣告一個SessionFactory物件
	static{
		try {
			config.configure(CONFIG_FILENAME);
			sessionFactory=config.buildSessionFactory();
		} catch (HibernateException e) {
			e.printStackTrace();
		}
	}
	public static SessionFactory getSessionFactory() {
		return sessionFactory;
	}
	public static Session getSession() throws HibernateException{
		Session session=threadLocal.get();
		if(session==null||!session.isOpen()){//如果這個連結沒開
			if (sessionFactory==null) {
				config.configure(CONFIG_FILENAME);
				sessionFactory = config.buildSessionFactory();
			}
			session=(sessionFactory!=null)?sessionFactory.openSession():null;//是否開放一個session
			threadLocal.set(session);//把session放入本地執行緒
		}
		return session;
	}
	
	//關閉連線
	public static void closeSession() throws HibernateException{
		Session session=threadLocal.get();
		threadLocal.remove();
		if(session!=null){
			session.close();
		}
		
	}

}