使用Spring整合Hibernate，并實現對數據表的增、刪、改、查的功能

2019-11-14 15:42:44

字體：大中小

來源：轉載

供稿：網友

1.1 問題

使用SPRing整合Hibernate，并實現資費表的增、刪、改、查。

1.2 方案

Spring整合Hibernate的步驟：

1.3 步驟

實現此案例需要按照如下步驟進行。

采用的環境是eclipse ，jdk 7.0 ，Tomcat7.0 ，Spring 3.2 ，Hibernate 3.2 。

步驟一：導包

創建WEB項目SpringHibernate，并導入數據庫驅動包、Hibernate開發包以及Spring開發包，完成后項目中包結構如下圖

然后，增加到類編譯中。

Hibernate 3.2 jar包下載： http://yunpan.cn/cmRG5gzdMtGMX 訪問密碼 3747

Spring 3.2 jar包下載： http://yunpan.cn/cdXTcJtZfJQQk 訪問密碼 6c96

MySQL jar包：http://yunpan.cn/cmv3BGe9CkUr3 訪問密碼 3601

步驟二：配置applicationContext.xml

引入Spring配置文件applicationContext.xml，放在src根路徑下。在該文件中配置數據源、sessionFactory、開啟組件掃描、聲明式事務，代碼如下

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"        xmlns:tx="http://www.springframework.org/schema/tx"         xmlns:aop="http://www.springframework.org/schema/aop"        xmlns:context="http://www.springframework.org/schema/context"         xmlns:jee="http://www.springframework.org/schema/jee"        xsi:schemaLocation="            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd            http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd">       <!-- 配置數據源 -->    <bean id="ds" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">                <!-- 配置連接參數 -->        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/VEVb"/>        <property name="driverClass" value="com.mysql.jdbc.Driver"/>        <property name="user" value="root"/>        <property name="passWord" value="123456"/>                <!-- 配置連接池 -->        <property name="initialPoolSize" value="3"/>        <property name="maxPoolSize" value="10"/>        <property name="minPoolSize" value="1"/>        <property name="acquireIncrement" value="3"/>        <property name="maxIdleTime" value="60"/>            </bean>        <!-- 配置SessionFactory -->    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">                <!-- 依賴數據源 -->        <property name="dataSource" ref="ds"/>        <!-- Hibernate框架相關配置 -->        <property name="hibernateProperties">            <props>                <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>                <prop key="hibernate.show_sql">true</prop>                <prop key="hibernate.formate_sql">true</prop>            </props>        </property>        <property name="mappingResources">            <list>                <value>com/souvc/entity/Cost.hbm.xml</value>            </list>        </property>    </bean>        <!-- 開啟注解掃描 -->    <context:component-scan base-package="com.souvc"/>        <!-- 聲明式事務管理,采用AOP形式切入 -->    <bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">        <property name="sessionFactory" ref="sessionFactory" />    </bean>        <tx:advice id="txAdvice" transaction-manager="txManager">        <tx:attributes>            <tx:method name="update*" propagation="REQUIRED" />            <tx:method name="delete*" propagation="REQUIRED" />            <tx:method name="add*" propagation="REQUIRED" />            <tx:method name="load*" read-only="true" />            <tx:method name="execute" propagation="REQUIRED" />        </tx:attributes>    </tx:advice>        <aop:config proxy-target-class="true">        <aop:advisor advice-ref="txAdvice"             pointcut="within(com.souvc.action.*)" />    </aop:config>    </beans>

步驟三：創建實體類和映射關系文件

創建com.souvc.entity包，并在包下創建資費實體類和映射關系文件，其中實體類Cost代碼如下

package com.souvc.entity;import java.util.Date;/** * 資費實體類 */public class Cost {    private Integer id;// 主鍵    private String name;// 資費名稱    private Integer baseDuration;// 在線時長    private Double baseCost;// 基本費用    private Double unitCost;// 單位費用    private String status;// 狀態    private String descr;// 資費說明    private Date createTime;// 創建日期    private Date startTime;// 啟用日期    private String costType;// 資費類型    public Integer getId() {        return id;    }    public void setId(Integer id) {        this.id = id;    }    public String getName() {        return name;    }    public void setName(String name) {        this.name = name;    }    public Integer getBaseDuration() {        return baseDuration;    }    public void setBaseDuration(Integer baseDuration) {        this.baseDuration = baseDuration;    }    public Double getBaseCost() {        return baseCost;    }    public void setBaseCost(Double baseCost) {        this.baseCost = baseCost;    }    public Double getUnitCost() {        return unitCost;    }    public void setUnitCost(Double unitCost) {        this.unitCost = unitCost;    }    public String getStatus() {        return status;    }    public void setStatus(String status) {        this.status = status;    }    public String getDescr() {        return descr;    }    public void setDescr(String descr) {        this.descr = descr;    }    public Date getCreateTime() {        return createTime;    }    public Date getStartTime() {        return startTime;    }    public void setStartTime(Date startTime) {        this.startTime = startTime;    }    public void setCreateTime(Date createTime) {        this.createTime = createTime;    }    public String getCostType() {        return costType;    }    public void setCostType(String costType) {        this.costType = costType;    }}

映射關系文件Cost.hbm.xml代碼如下

<?xml version="1.0" encoding="utf-8"?><!DOCTYPE hibernate-mapping PUBLIC        "-//Hibernate/Hibernate Mapping DTD 3.0//EN"        "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"><hibernate-mapping>    <!-- 配置實體類和表的關系 -->    <class name="com.souvc.entity.Cost" table="cost">        <!-- 配置主鍵屬性和字段的關系 -->        <id name="id" type="java.lang.Integer" column="id">            <!-- 用來指明主鍵的生成方式 -->            <!-- <generator class="sequence"> <param name="sequence">emp_seq</param>                 </generator> -->            <generator class="native">            </generator>        </id>        <!-- 配置實體類中屬性與表中字段的關系 -->        <property name="name" type="string" column="name" />        <property name="baseDuration" type="integer" column="base_duration" />        <property name="baseCost" type="double" column="base_cost" />        <property name="unitCost" type="double" column="unit_cost" />        <property name="status" type="string" column="status" />        <property name="descr" type="string" column="descr" />        <property name="createTime" type="date" column="creatime" />        <property name="startTime" type="date" column="startime" />        <property name="costType" type="string" column="cost_type" />    </class></hibernate-mapping>

在applicationContext.xml中注冊映射關系文件，代碼如下

 <property name="mappingResources">            <list>                <value>com/souvc/entity/Cost.hbm.xml</value>            </list>        </property>

步驟四：

創建包com.souvc.dao，并在包下創建資費DAO接口，聲明增、刪、改、查的方法，代碼如下

package com.souvc.dao;import java.util.List;import com.souvc.entity.Cost;public interface ICostDao {    List<Cost> findAll();    Cost findById(int id);    void save(Cost cost);    void update(Cost cost);    void delete(int id);}

創建DAO實現類CostDaoImpl，繼承于HibernateDaoSupport，實現接口ICostDao。代碼如下

package com.souvc.dao;import java.util.List;import javax.annotation.Resource;import org.hibernate.SessionFactory;import org.springframework.orm.hibernate3.support.HibernateDaoSupport;import org.springframework.stereotype.Repository;import com.souvc.entity.Cost;@SuppressWarnings("unchecked")@Repositorypublic class CostDaoImpl     extends HibernateDaoSupport implements ICostDao {        @Resource    public void setSF(SessionFactory sf) {        super.setSessionFactory(sf);    }        @Override    public List<Cost> findAll() {        String hql = "from Cost";        return getHibernateTemplate().find(hql);    }    @Override    public Cost findById(int id) {        return (Cost) getHibernateTemplate().get(Cost.class, id);    }    @Override    public void save(Cost cost) {        getHibernateTemplate().save(cost);    }    @Override    public void update(Cost cost) {        getHibernateTemplate().update(cost);    }    @Override    public void delete(int id) {        Cost c = new Cost();        c.setId(id);        getHibernateTemplate().delete(c);    }}

步驟五：測試

在com.souvc.dao包下，創建JUNIT測試類TestDao，分別寫出資費的增、刪、改

查測試方法，并執行這些方法進行測試。代碼如下

package com.souvc.dao;import java.util.List;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.souvc.entity.Cost;/** * * 類名: TestDao* 描述: 測試類* 開發人員： souvc* 創建時間：  2015-9-6 下午1:01:44* 發布版本：V3.0 */public class TestDao {    private String conf = "applicationContext.xml";    /**    * 方法名：test1    * 詳述：查詢所有    * 開發人員：souvc    * 創建時間：2015-9-6 下午12:59:30    * 說明參數含義    * 說明返回值含義    * 說明發生此異常的條件     */    @Test    public void test1() {        ApplicationContext ctx = new ClassPathXmlApplicationContext(conf);        ICostDao dao = (ICostDao) ctx.getBean("costDaoImpl");        List<Cost> list = dao.findAll();        for (Cost c : list) {            System.out.println(c.getId() + " " + c.getName());        }    }        /**    * 方法名：test2    * 詳述：通過id查詢    * 開發人員：souvc    * 創建時間：2015-9-6 下午1:00:07    * 說明參數含義    * 說明返回值含義    * 說明發生此異常的條件     */    @Test    public void test2() {        ApplicationContext ctx = new ClassPathXmlApplicationContext(conf);        ICostDao dao = (ICostDao) ctx.getBean("costDaoImpl");        Cost c = dao.findById(1);        System.out.println(c.getId() + " " + c.getName());    }    /**    * 方法名：test3    * 詳述：新增    * 開發人員：souvc    * 創建時間：2015-9-6 下午1:00:32    * 說明參數含義    * 說明返回值含義    * 說明發生此異常的條件     */    @Test    public void test3() {        ApplicationContext ctx = new ClassPathXmlApplicationContext(conf);        ICostDao dao = (ICostDao) ctx.getBean("costDaoImpl");        Cost c = new Cost();        c.setName("aaa");        c.setBaseDuration(20);        c.setBaseCost(2.0);        c.setUnitCost(0.2);        c.setCostType("1");        c.setStatus("0");        dao.save(c);    }    /**    * 方法名：test4    * 詳述：更新    * 開發人員：souvc    * 創建時間：2015-9-6 下午1:00:59    * 說明參數含義    * 說明返回值含義    * 說明發生此異常的條件     */    @Test    public void test4() {        ApplicationContext ctx = new ClassPathXmlApplicationContext(conf);        ICostDao dao = (ICostDao) ctx.getBean("costDaoImpl");        Cost c = dao.findById(1);        c.setName("bbb");        dao.update(c);    }    /**    * 方法名：test5    * 詳述：刪除    * 開發人員：liuhf    * 創建時間：2015-9-6 下午1:01:19    * 說明參數含義    * 說明返回值含義    * 說明發生此異常的條件     */    @Test    public void test5() {        ApplicationContext ctx = new ClassPathXmlApplicationContext(conf);        ICostDao dao = (ICostDao) ctx.getBean("costDaoImpl");        dao.delete(1);    }}

建表語句：

CREATE TABLE `cost` (  `id` int(10) NOT NULL auto_increment,  `name` varchar(50) default NULL,  `base_duration` int(11) default NULL,  `unit_cost` double(10,0) default NULL,  `status` varchar(10) default NULL,  `descr` varchar(20) default NULL,  `creatime` date default NULL,  `startime` date default NULL,  `cost_type` varchar(10) default NULL,  `base_cost` double(10,0) default NULL,  PRIMARY KEY  (`id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;