Java_Web三大框架之Hibernate增删改查

下面介绍一下Hibernate的增删改查。

第一步：编写用户实体类以及User.hbm.xml映射

package com.msl.entity;

public class User {

    private int id;

    private String name;

    private String password;

    private String telephone;

    private String username;

    private String isadmin;

    public User() {

    }

    public int getId() {

        return id;

    }

    public void setId(int id) {

        this.id = id;

    }

    public String getName() {

        return name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public String getPassword() {

        return password;

    }

    public void setPassword(String password) {

        this.password = password;

    }

    public String getTelephone() {

        return telephone;

    }

    public void setTelephone(String telephone) {

        this.telephone = telephone;

    }

    public String getUsername() {

        return username;

    }

    public void setUsername(String username) {

        this.username = username;

    }

    public String getIsadmin() {

        return isadmin;

    }

    public void setIsadmin(String isadmin) {

        this.isadmin = isadmin;

    }

}

User.hbm.xml映射

<?xml version="1.0"?>

<!DOCTYPE hibernate-mapping PUBLIC

    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"

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

<hibernate-mapping

    package="com.msl.entity">

    <class name="User" table="Users"> <!-- 对持久化类User的映射配置 -->

        <!--

            Hibernate主键策略:

                1、increment：用于Long、Short或者Int类型生成唯一标识。在集群下不要使用该属性

                2、identity：由底层数据库生成该属性，前提是底层数据库支持自增字段类型

                3、sequence：根据底层数据库的序列生成主键，前提是底层数据库支持序列

                4、hilo：根据高/低算法生成，吧特定表的字段作为高位值来源，在默认情况下选用hibernate_unique_key表的next_hi字段

                5、native：

                6、assigned：

                7、select：

                8、foreign：

         -->

        <id name="id">

            <generator class="increment"/>

        </id>

        <!--

            name:持久化类属性的名称；以小写字母开头

            column:数据库字段名

            type:数据库字段类型

            length:数据库字段定义的长度

            not-null:给数据库字段是否可以为空，该属性为布尔变量

            unique:该数据库字段是否唯一，该属性为布尔变量

            lazy:是否延迟抓取，该属性为布尔变量

         -->

        <property name="name" not-null="true" />

        <property name="password" not-null="true"/>

        <property name="telephone" not-null="true"/>

        <property name="username" not-null="true"/>

        <property name="isadmin" not-null="true"/>

    </class>

</hibernate-mapping>

第二步：封装HibernateUtil类

package com.msl.HibernateUtil;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.cfg.Configuration;

public class HibernateUtil {

    private HibernateUtil(){

    };

    public static SessionFactory sessionFactory=null;

    static{

        //Hibernate初始化

        Configuration cf=new  Configuration();

        cf.configure();

        sessionFactory=cf.buildSessionFactory();//DriverManager.getConnection(url)

        //Session session = SessionFactory.openSession();//相当于得到Connection对象

    }

    public static Session getSession(){

        return  sessionFactory.openSession();

    }

    public static void closeSession(Session session){

        if(session!=null){

            session.close();

        }

    }

}

第三步：编写hibernate.cfg.xml映射

<!DOCTYPE hibernate-configuration PUBLIC

    "-//Hibernate/Hibernate Configuration DTD 3.0//EN"

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

<hibernate-configuration>

    <session-factory>

        <!-- 数据库方言 -->

        <!--

        MySQL: #hibernate.dialect org.hibernate.dialect.MySQLDialect

        Oracle:#hibernate.dialect org.hibernate.dialect.OracleDialect

        SQLServer:#hibernate.dialect org.hibernate.dialect.SQLServerDialect

         -->

        <property name="dialect">    <!-- Hibernate方言 -->

            org.hibernate.dialect.OracleDialect

        </property>

        <property name="hibernate.connection.url">    <!-- 数据库连接URL -->

            jdbc:oracle:thin:@localhost:1521:orcl

        </property>

        <property name="hibernate.connection.driver_class">    <!-- 数据库驱动 -->

            oracle.jdbc.driver.OracleDriver

        </property>

        <!-- 数据库连接用户名 -->

        <property name="hibernate.connection.username">epet</property>

        <!-- 数据库连接密码 -->

        <property name="hibernate.connection.password">123456</property>

        <property name="show_sql">true</property>    <!-- 打印SQL语句 -->

        <!-- 自动创建数据库表格 -->

        <!--

            #hibernate.hbm2ddl.auto create-drop

            #hibernate.hbm2ddl.auto create

            #hibernate.hbm2ddl.auto update

            #hibernate.hbm2ddl.auto validate

         -->

        <property name="hibernate.hbm2ddl.auto">update</property>

        <mapping resource="com/msl/entity/User.hbm.xml"/>    <!-- 配置映射信息 -->

    </session-factory>

</hibernate-configuration>

第四步：增删改查测试类：

package com.msl.test;

import org.hibernate.Session;

import org.hibernate.Transaction;

import com.msl.HibernateUtil.HibernateUtil;

import com.msl.entity.User;

/**

 * Hibernate保存数据

 * @author Administrator

 *

 */

public class test {

    public static void main(String[] args) {

        User user=new User();

        user.setName("dsd");

        user.setPassword("123456");

        user.setTelephone("1234567890");

        user.setUsername("小明");

        user.setIsadmin("2");

        Session session=HibernateUtil.getSession();

        //进行事务处理

        Transaction transaction=session.beginTransaction();

        try{

            //对数据保存至数据库

            session.save(user);

            //提交事务

            transaction.commit();

        }catch(Exception e){

            e.printStackTrace();

            //如果出现异常，事务回滚

            transaction.rollback();

        }finally{

            HibernateUtil.closeSession(session);

        }

    }

}

package com.msl.test;

import org.hibernate.Session;

import org.hibernate.Transaction;

import com.msl.HibernateUtil.HibernateUtil;

import com.msl.entity.User;

/**

 * Hibernate更新数据

 * @author Administrator

 *

 */

public class test1 {

//    /**

//     * update 更新数据

//     * @param args

//     */

//    public static void main(String[] args) {

//        User user=new User();

//        user.setId(2);

//        user.setName("dsd");

//        user.setPassword("123456");

//        user.setTelephone("1234567890");

//        user.setUsername("小明");

//        user.setIsadmin("1");

//

//        Session session=HibernateUtil.getSession();

//

//        //进行事务处理

//        Transaction transaction=session.beginTransaction();

//        try{

//            //对数据保存至数据库

//            session.update(user);

//            //提交事务

//            transaction.commit();

//        }catch(Exception e){

//            e.printStackTrace();

//            //如果出现异常，事务回滚

//            transaction.rollback();

//        }finally{

//            HibernateUtil.closeSession(session);

//        }

//    }

    public static void main(String[] args) {

        Session session=null;

        Transaction transaction=null;

        try{

            session=HibernateUtil.getSession();

            transaction=session.beginTransaction();

            User user=(User)session.get(User.class, new Integer("1"));

            user.setIsadmin("2");

            session.flush();

            transaction.commit();

        }catch(Exception e){

            System.out.println("更新失败");

            e.printStackTrace();

            transaction.rollback();

        }finally{

            HibernateUtil.closeSession(session);

        }

    }

}

package com.msl.test;

import org.hibernate.Session;

import org.hibernate.Transaction;

import com.msl.HibernateUtil.HibernateUtil;

import com.msl.entity.User;

/**

 * Hibernate查询数据

 * @author Administrator

 *

 */

public class test2 {

//    /**

//     * 查询 方法 get()

//     * @param args

//     */

//    public static void main(String[] args) {

//        Session session=HibernateUtil.getSession();

//        //进行事务处理

//        Transaction transaction=session.beginTransaction();

//        try{

//            User user=(User)session.get(User.class, new Integer("2"));

//            System.out.println("id:"+user.getId());

//            System.out.println(user.getName());

//            System.out.println(user.getPassword());

//            System.out.println(user.getTelephone());

//            System.out.println(user.getUsername());

//            System.out.println(user.getIsadmin());

//            //提交事务

//            transaction.commit();

//        }catch(Exception e){

//            e.printStackTrace();

//            //如果出现异常，事务回滚

//            transaction.rollback();

//        }finally{

//            HibernateUtil.closeSession(session);

//        }

//

//    }

//    /**

//     * 查询 方法load() 1

//     * @param args

//     */

//    public static void main(String[] args) {

//        Session session=HibernateUtil.getSession();

//        //进行事务处理

//        Transaction transaction=session.beginTransaction();

//        try{

//            User user=(User)session.load(User.class, new Integer("2"));

//            System.out.println("id:"+user.getId());

//            System.out.println(user.getName());

//            System.out.println(user.getPassword());

//            System.out.println(user.getTelephone());

//            System.out.println(user.getUsername());

//            System.out.println(user.getIsadmin());

//            //提交事务

//            transaction.commit();

//        }catch(Exception e){

//            e.printStackTrace();

//            //如果出现异常，事务回滚

//            transaction.rollback();

//        }finally{

//            HibernateUtil.closeSession(session);

//        }

//

//    }

    /**

     * 查询 方法load() 1

     * @param args

     */

    public static void main(String[] args) {

        User user=new User();

        Session session=HibernateUtil.getSession();

        //进行事务处理

        Transaction transaction=session.beginTransaction();

        try{

            session.load(user,new Integer("2"));

            System.out.println("id:"+user.getId());

            System.out.println(user.getName());

            System.out.println(user.getPassword());

            System.out.println(user.getTelephone());

            System.out.println(user.getUsername());

            System.out.println(user.getIsadmin());

            //提交事务

            transaction.commit();

        }catch(Exception e){

            e.printStackTrace();

            //如果出现异常，事务回滚

            transaction.rollback();

        }finally{

            HibernateUtil.closeSession(session);

        }

    }

}

package com.msl.test;

import org.hibernate.Session;

import org.hibernate.Transaction;

import com.msl.HibernateUtil.HibernateUtil;

import com.msl.entity.User;

/**

 * 删除数据

 * @author Administrator

 *

 */

public class test3 {

    public static void main(String[] args) {

        Session session=HibernateUtil.getSession();

        //进行事务处理

        Transaction transaction=session.beginTransaction();

        try{

            User user=(User)session.load(User.class, new Integer("2"));

            session.delete(user);

            session.flush();

            //提交事务

            transaction.commit();

        }catch(Exception e){

            System.out.println("删除失败");

            e.printStackTrace();

            //如果出现异常，事务回滚

            transaction.rollback();

        }finally{

            HibernateUtil.closeSession(session);

        }

    }

}