JAVA框架之第一个Hibernate实际应用

作者: 程序o07 | 来源:发表于2018-07-13 13:33 被阅读98次

    一、在Java应用中使用Hibernate的步骤

    创建Hibernate的配置文件

    创建持久化类

    创建对象-关系映射文件

    通过Hibernate API编写访问数据库的代码

    二、Helloapp应用的结构

    三、Hibernate的配置文件(hibernate.properties)

    hibernate.dialect=org.hibernate.dialect.MySQLDialect

    hibernate.connection.driver_class=com.mysql.jdbc.Driver  hibernate.connection.url=jdbc:mysql://localhost:3306/SAMPLEDB 

    hibernate.connection.username=root  hibernate.connection.password=1234

    hibernate.show_sql=true

    Java初高级学习分享,共同学习才是最明智的选择,喜欢的话可以我的学习群64弍46衣3凌9,或加资料群69似64陆0吧3(进群备注平台名)

    四、创建持久化类Customer

    持久化类符合JavaBean的规范,包含一些属性,以及与之对应的getXXX()和setXXX()方法。

    持久化类有一个id属性,用来惟一标识Customer类的每个对象。在面向对象术语中,这个id属性被称为对象标识符(OID,Object Identifier),通常它都用整数表示

    Hibernate要求持久化类必须提供一个不带参数的默认构造方法

    package mypack;

    import java.io.Serializable;  import java.sql.Date;  

    import java.sql.Timestamp;

    public

    class Customer implements Serializable {

    private Long id;

    private String name;

    private String email;

    private String password;

    private

    int phone;

    private String address;

    private

    char sex;

    private

    boolean married;

    private String description;

    private

    byte[] image;

    private Date birthday;

    private Timestamp registeredTime;

    public Customer(){}

    public Long getId(){

    return id;

    }

    private

    void setId(Long id){

    this.id = id;

    }

    public String getName(){

    return name;

    }

    public

    void setName(String name){

    this.name=name;

    }

    public String getEmail(){

    return email;

    }

    public

    void setEmail(String email){

    this.email =email ;

    }

    public String getPassword(){

    return password;

    }

    public

    void setPassword(String password){

    this.password =password ;

    }

    public

    int getPhone(){

    return phone;

    }

    public

    void setPhone(int phone){

    this.phone =phone ;

    }

    public String getAddress(){

    return address;

    }

    public

    void setAddress(String address){

    this.address =address ;

    }

    public

    char getSex(){

    return sex;    }

    public

    void setSex(char sex){

    this.sex =sex ;    }

    public

    boolean isMarried(){

    return married;    }

    public

    void setMarried(boolean married){

    this.married =married ;    }

    public String getDescription(){

    return description;    }

    public

    void setDescription(String description){

    this.description =description ;    }

    public

    byte[] getImage() {

    return

    this.image;    }

    public

    void setImage(byte[] image) {

    this.image = image;    }

    public Date getBirthday() {

    return

    this.birthday;    }

    public

    void setBirthday(Date birthday) {

    this.birthday = birthday;    }

    public Timestamp getRegisteredTime() {

    return

    this.registeredTime;    }

    public

    void setRegisteredTime(Timestamp registeredTime) {

    this.registeredTime = registeredTime;    }

    }

    注意:

    getXXX()和setXXX()方法可以采用任意的访问级别,他的命名规则必须符合特定的命名规则,“get”和“set”后面紧跟属性的名字,并且属性名的首字母为大写,如name属性的get方法为getName()。

    如果持久化类的属性为boolean类型,那么它的get方法名可以用get做前缀也可以用is做前缀。

    五、创建数据库Schema

    drop database if exists SAMPLEDB;

    create database SAMPLEDB;  use SAMPLEDB;  

    create table CUSTOMERS (

      ID bigint not null primary key,    NAME varchar(15) not null,  

      EMAIL varchar(128) not null,    PASSWORD varchar(8) not null,   

      PHONE int ,      ADDRESS varchar(255),  

      SEX char(1) ,    IS_MARRIED bit,  

      DESCRIPTION text,    IMAGE blob,  

      BIRTHDAY date,  

      REGISTERED_TIME timestamp  

    六、创建对象-关系映射文件Customer.hbm.xml

    "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">

    元素映射OID

    子元素用来设定标识符生成器。Hibernate提供了提供了多种内置的实现。

    元素映射值类型属性

    name属性:指定持久化类的属性的名字。

    column属性:指定与类的属性映射的表的字段名。

    type属性:指定Hibernate映射类型。Hibernate映射类型是Java类型与SQL类型的桥梁。 

    采用XML文件来配置对象-关系映射的优点:

    Hibernate既不会***到上层域模型中,也不会***到下层数据模型中。

    软件开发人员可以独立设计域模型,不必强迫遵守任何规范。

    数据库设计人员可以独立设计数据模型,不必强迫遵守任何规范。

    对象-关系映射不依赖于任何程序代码,如果需要修改对象-关系映射,只需修改XML文件,不需要修改任何程序,提高了软件的灵活性,并且使维护更加方便。

    七、创建BusinessService类

    package mypack;

    import javax.servlet.*;

    import org.hibernate.*;  import org.hibernate.cfg.Configuration;  

    import java.io.*;  import java.sql.Date;  

    import java.sql.Timestamp;  import java.util.*;  

    public

    class BusinessService{

    public

    static SessionFactory sessionFactory;

    /** 初始化Hibernate,创建SessionFactory实例 */

    static{

    try{

    // 根据默认位置的Hibernate配置文件的配置信息,创建一个Configuration实例 

    Configuration config = new Configuration();

    //加载Customer类的对象-关系映射文件 

    config.addClass(Customer.class);

    // 创建SessionFactory实例 */ 

          sessionFactory = config.buildSessionFactory();      }catch(RuntimeException e){e.printStackTrace();throw e;}  

    }

    /** 查询所有的Customer对象,然后调用printCustomer()方法打印Customer对象信息 */

    public

    void findAllCustomers(ServletContext context,PrintWriter out) throws Exception{

    Session session = sessionFactory.openSession(); //创建一个会话 

    Transaction tx = null;

    try {        tx = session.beginTransaction(); //开始一个事务 

          Query query=session.createQuery("from Customer as c order by c.name asc");        List customers=query.list();  

    for (Iterator it = customers.iterator(); it.hasNext();) {           printCustomer(context,out,(Customer) it.next());

    }

    tx.commit(); //提交事务 

    }catch (RuntimeException e) {

    if (tx != null) {

             tx.rollback();        }  

    throw e;      } finally {

           session.close();      }  

    }

    /** 持久化一个Customer对象 */

    public

    void saveCustomer(Customer customer){

        Session session = sessionFactory.openSession();      Transaction tx = null;  

    try {        tx = session.beginTransaction();

          session.save(customer);        tx.commit();  

    }catch (RuntimeException e) {

    if (tx != null) {          tx.rollback();

    }

    throw e;

        } finally {        session.close();  

        }    }  

    /** 按照OID加载一个Customer对象,然后修改它的属性 */

    public

    void loadAndUpdateCustomer(Long customer_id,String address){      Session session = sessionFactory.openSession();

    Transaction tx = null;

    try {

    tx = session.beginTransaction();

          Customer c=(Customer)session.get(Customer.class,customer_id);        c.setAddress(address);  

    tx.commit();

    }catch (RuntimeException e) {

    if (tx != null) {

            tx.rollback();        }  

    throw e;      } finally {

          session.close();      }  

    }

    /**删除Customer对象 */

    public

    void deleteCustomer(Customer customer){

        Session session = sessionFactory.openSession();      Transaction tx = null;  

    try {        tx = session.beginTransaction();

          session.delete(customer);        tx.commit();  

    }catch (RuntimeException e) {

    if (tx != null) {          tx.rollback();

    }

    throw e;

        } finally {        session.close();  

        }    }  

    /** 选择向控制台还是Web网页输出Customer对象的信息 */

    private

    void printCustomer(ServletContext context,PrintWriter out,Customer customer)throws Exception{

    if(context!=null)

    printCustomerInWeb(context,out,customer);

    else

           printCustomer( out,customer);    }  

    /** 把Customer对象的信息输出到控制台,如DOS 控制台*/

    private

    void printCustomer(PrintWriter out,Customer customer)throws Exception{

    byte[] buffer=customer.getImage();

        FileOutputStream fout=new FileOutputStream("photo_copy.gif");      fout.write(buffer);  

    fout.close();

        out.println("------以下是"+customer.getName()+"的个人信息------");      out.println("ID: "+customer.getId());  

        out.println("口令: "+customer.getPassword());      out.println("E-Mail: "+customer.getEmail());  

        out.println("电话: "+customer.getPhone());      out.println("地址: "+customer.getAddress());  

        String sex=customer.getSex()=='M'? "男":"女";      out.println("性别: "+sex);  

        String marriedStatus=customer.isMarried()? "已婚":"未婚";      out.println("婚姻状况: "+marriedStatus);  

        out.println("生日: "+customer.getBirthday());      out.println("注册时间: "+customer.getRegisteredTime());  

    out.println("自我介绍: "+customer.getDescription());

    }

    /** 把Customer对象的信息输出到动态网页 */

    private

    void printCustomerInWeb(ServletContext context,PrintWriter out,Customer customer)throws Exception{

    //保存照片 

    byte[] buffer=customer.getImage();

        String path=context.getRealPath("/");      FileOutputStream fout=new FileOutputStream(path+"photo_copy.gif");  

        fout.write(buffer);      fout.close();  

    out.println("------以下是"+customer.getName()+"的个人信息------"+"
    ");

        out.println("ID: "+customer.getId()+"
    ");      out.println("口令: "+customer.getPassword()+"
    ");  

        out.println("E-Mail: "+customer.getEmail()+"
    ");      out.println("电话: "+customer.getPhone()+"
    ");  

        out.println("地址: "+customer.getAddress()+"
    ");      String sex=customer.getSex()=='M'? "男":"女";  

        out.println("性别: "+sex+"
    ");      String marriedStatus=customer.isMarried()? "已婚":"未婚";  

        out.println("婚姻状况: "+marriedStatus+"
    ");      out.println("生日: "+customer.getBirthday()+"
    ");  

        out.println("注册时间: "+customer.getRegisteredTime()+"
    ");      out.println("自我介绍: "+customer.getDescription()+"
    ");  

        out.println("

    ");    }  

    public

    void test(ServletContext context,PrintWriter out) throws Exception{

        Customer customer=new Customer();      customer.setName("Tom");  

        customer.setEmail("tom@yahoo.com");      customer.setPassword("1234");  

        customer.setPhone(55556666);      customer.setAddress("Shanghai");  

        customer.setSex('M');      customer.setDescription("I am very honest.");  

    //设置Customer对象的image属性,它是字节数组,存放photo.gif文件中的二进制数据 

    //photo.gif文件和BusinessService.class文件位于同一个目录下

    InputStream in=this.getClass().getResourceAsStream("photo.gif");

    byte[] buffer = new

    byte[in.available()];      in.read(buffer);

    customer.setImage(buffer);

    //设置Customer对象的birthday属性,它是java.sql.Date类型

    customer.setBirthday(Date.valueOf("1980-05-06"));

    saveCustomer(customer);

        findAllCustomers(context,out);      loadAndUpdateCustomer(customer.getId(),"Beijing");  

        findAllCustomers(context,out);      deleteCustomer(customer);  

    }

    public

    static

    void main(String args[]) throws Exception {

    new BusinessService().test(null,new PrintWriter(System.out,true));

        sessionFactory.close();    }  

    }

    saveCustomer()方法

    该方法调用Session的save()方法,把Customer对象持久化到数据库中。

    tx = session.beginTransaction();

    session.save(customer);

           tx.commit();

    当运行session.save()方法时,Hibernate执行以下SQL语句:

    insert into CUSTOMERS (ID, NAME, EMAIL, PASSWORD, PHONE, ADDRESS, SEX,

    IS_MARRIED,DESCRIPTION, IMAGE, BIRTHDAY, REGISTERED_TIME)

          values(1,'Tom','tom@yahoo.com','1234',55556666,'Shanghai','M',0,'I am very honest.', ☺,'1980-05-06',null)

    在test()方法中并没有设置Customer对象的id属性,Hibernate会根据映射文件的配置,采用increment标识符生成器自动以递增的方式为OID赋值。在Customer.hbm.xml文件中相关的映射代码如下:

    findAllCustomers()方法

    该方法通过Query接口查询所有的Customer对象。

    tx = session.beginTransaction(); //开始一个事务 

    Query query=session.createQuery("from Customer as c order by c.name asc");

    List customers=query.list();

    for (Iterator it = customers.iterator(); it.hasNext();) {

    printCustomer(context,out,(Customer) it.next());

    }

    tx.commit(); //提交事务

    Session的createQuery()方法的参数“from Customer as c order by c.name asc”使用的是Hibernate查询语言。运行Query.list()方法时, Hibernate执行以下SQL语句:

    select * from CUSTOMERS order by NAME asc;

    loadAndUpdateCustomer ()方法

    该方法调用Session的get()方法,加载Customer对象,然后再修改Customer对象的属性。

    tx = session.beginTransaction();

    Customer c=(Customer)session.get(Customer.class,customer_id);

    c.setAddress(address); //修改内存中Customer对象的address属性 

          tx.commit();

    以上代码先调用Session的get()方法,它按照参数指定的OID从数据库中检索出匹配的Customer对象,Hibernate会执行以下SQL语句:

    select * from CUSTOMERS where ID=1;

    loadAndUpdateCustomer()方法接着修改Customer对象的address属性。那么,Hibernate会不会同步更新自力式温度调节阀数据库中相应的CUSTOMERS表的记录呢?答案是肯定的。Hibernate采用脏检查机制,按照内存中的Customer对象的状态的变化,来同步更新数据库中相关的电动蝶阀数据,Hibernate会执行以下SQL语句:

    update CUSTOMERS set NAME="Tom",EMAIL="Tom@yahoo.com"…ADDRESS="Beijing"…

    where ID=1;

    尽管只有Customer对象的address属性发生了变化,但是Hibernate执行的update语句中会包含所有的字段。

    deleteCustomer()方法

    该方法调用Session的delete()方法,删除特定的Customer对象:

    tx = session.beginTransaction();

    session.delete(customer);

          tx.commit();

    运行session.delete()方法时,Hibernate根据Customer对象的OID,执行以下SQL delete语句:

    delete from CUSTOMERS where ID=1; 

    ❤提问/互动请留言,可直接在最底右下方"写留言即可"

    ❤Java初高级学习分享,共同学习才是最明智的选择,喜欢的话可以我的学习群64弍46衣3凌9,或加资料群69似64陆0吧3(进群备注平台名)

    ❤如果觉得写得不错请点击“订阅”,每天更新全新的内容!

    ❤你们的喜欢和关注就是我最大的动力支撑!!!

    相关文章

      网友评论

        本文标题:JAVA框架之第一个Hibernate实际应用

        本文链接:https://www.haomeiwen.com/subject/qjmjpftx.html