Hibernate基本数据操作方法

 

package hibernatetest;

import net.sf.hibernate.*;
import net.sf.hibernate.cfg.Configuration;
import derek.hibernate.test.Admin;
import java.util.Iterator;
import java.util.List;
import java.sql.*;

public class TestConTest  {
  Session session = null;

  protected void setUp(){

    try {
      Configuration config = new Configuration().configure();
      SessionFactory sessionFactory = config.buildSessionFactory();
      System.out.println(config.getProperty("connection.url"));
      session = sessionFactory.openSession();
    }
    catch (HibernateException ex1) {ex1.printStackTrace();}
  }

//数据插入
  public void testInsert(){
    
    Admin admin = new Admin();
    admin.setName("Hiber");
    admin.setPasswd("gen");
    System.out.println(admin.getName());
    System.out.println(admin.getPasswd());
    try {
      Transaction ts = session.beginTransaction();
      session.save(admin);
      session.flush();
      ts.commit();
    }
    catch (HibernateException ex) {ex.printStackTrace(); }
  }

//Query方法查询数据
  public void testQuery(){
      try {
       Query q = session.createQuery("from Admin where id=?");
       q.setInteger(0,2);//这里的?跟JDBC的PreparedStatement方法的差不多，只不过这里的是以0开始，jdbc的是1开始。
       System.out.println("Query方法查询数据");
       //q.setFirstResult(2);//查询结果从第几行开始列出数据
       //q.setMaxResults(10);//取多少条数据，就跟SQL SERVER的TOP方法和MYSQL的LIMIT方法一样的意思。
       // ScrollableResults sc=q.scroll();//得到一个ScrollableResults,可滚动的，如果你的数据库支持游标自由移动的话可以加上，也就是说可以判断查询结果有没有值，或者移动到下一行记录等等.
       Iterator it = q.iterate();
       while(it.hasNext()){
         Admin admin = (Admin)it.next();
         System.out.println(admin.getId());
         System.out.println(admin.getName());
         System.out.println(admin.getPasswd());
       }
       session.flush();
      }
      catch (HibernateException ex) {ex.printStackTrace();}
//      finally{
//      try {
//        session.close();
//      }
//      catch (HibernateException ex1) {ex1.printStackTrace();}
//      }
  }

  /**
   * Hibernate3.0中已经废弃了find()和iterate()方法
   */
  
  //find方法查询数据
  public void testFind(){
    try {
      List lt = session.find("from Admin");
      System.out.println("find方法查询数据");
      Iterator it = lt.iterator();
      while(it.hasNext()){
        Admin admin = (Admin)it.next();
        System.out.println(admin.getId());
        System.out.println(admin.getName());
        System.out.println(admin.getPasswd());
      }
      session.flush();
    }
    catch (HibernateException ex) {ex.printStackTrace();}
//    finally{
//    try {
//      session.close();
//    }
//    catch (HibernateException ex1) {ex1.printStackTrace();}
//    }
  }

  //iterate方法查询数据
  public void testIterator(){
    try {
      Iterator it = session.iterate("from Admin");
      while(it.hasNext()){
        Admin admin = (Admin)it.next();
        System.out.println(admin.getId());
        System.out.println(admin.getName());
        System.out.println(admin.getPasswd());
        session.flush();
        
      }
    }
    catch (HibernateException ex) {ex.printStackTrace();}
//    finally{
//        try {
//           session.close();
//            }catch (HibernateException ex1) {ex1.printStackTrace();}
//        }
  }

 //修改数据
 public void testModify(){
  try {
    Connection con = session.connection();//得到数据库连接
    Query q = session.createQuery("from Admin where id = 2");
    Iterator it = q.iterate();
    Transaction ts = session.beginTransaction();
    if(it.hasNext()){
    Admin admin = (Admin)it.next();
    admin.setName("dada");
    session.update(admin);
    session.evict(admin);//调用Session的evict()方法立即释放它的内存
    session.flush();
    ts.commit();
    }
  }
  catch (HibernateException ex) {ex.printStackTrace();}
//  finally{
//        try {
//           session.close();
//            }catch (HibernateException ex1) {ex1.printStackTrace();}
//        }
 }

 /**
  * delete()方法执行首先是执行select语句把符合条件的记录载入内存中，
  * 然后做逐一删除即有多少条符合条件的记录就执行多少次删除命令 
  */
 
 //删除数据
 public void testDelete(){
  try {
    int i = session.delete("from Admin where id = 2");
    Transaction ts = session.beginTransaction();
    System.out.println("删除数据状态 "+i);
    session.flush();
  }
  catch (HibernateException ex) {ex.printStackTrace();}
//  finally{
//      try {
//         session.close();
//          }catch (HibernateException ex1) {ex1.printStackTrace();}
//      }

 }
 public static void main(String arg[]){
    TestConTest tt = new TestConTest();
    tt.setUp();
    tt.testInsert();
    //tt.testDelete();
    //tt.testModify();
    tt.testIterator();
 }
}