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/txhttp://www.springframework.org/schema/tx/spring-tx-2.5.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-2.5.xsdhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-2.5.xsdhttp://www.springframework.org/schema/jeehttp://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/cnblogs"/>
<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代码如下
packagecom.souvc.entity;importjava.util.Date;/*** 资费实体类*/publicclassCost {privateInteger id;//主键privateString name;//资费名称privateInteger baseDuration;//在线时长privateDouble baseCost;//基本费用privateDouble unitCost;//单位费用privateString status;//状态privateString descr;//资费说明privateDate createTime;//创建日期privateDate startTime;//启用日期privateString costType;//资费类型publicInteger getId() {returnid;
}publicvoidsetId(Integer id) {this.id =id;
}publicString getName() {returnname;
}publicvoidsetName(String name) {this.name =name;
}publicInteger getBaseDuration() {returnbaseDuration;
}publicvoidsetBaseDuration(Integer baseDuration) {this.baseDuration =baseDuration;
}publicDouble getBaseCost() {returnbaseCost;
}publicvoidsetBaseCost(Double baseCost) {this.baseCost =baseCost;
}publicDouble getUnitCost() {returnunitCost;
}publicvoidsetUnitCost(Double unitCost) {this.unitCost =unitCost;
}publicString getStatus() {returnstatus;
}publicvoidsetStatus(String status) {this.status =status;
}publicString getDescr() {returndescr;
}publicvoidsetDescr(String descr) {this.descr =descr;
}publicDate getCreateTime() {returncreateTime;
}publicDate getStartTime() {returnstartTime;
}publicvoidsetStartTime(Date startTime) {this.startTime =startTime;
}publicvoidsetCreateTime(Date createTime) {this.createTime =createTime;
}publicString getCostType() {returncostType;
}publicvoidsetCostType(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>
<!-- 配置实体类和表的关系 -->
<classname="com.souvc.entity.Cost" table="cost">
<!-- 配置主键属性和字段的关系 -->
<id name="id" type="java.lang.Integer" column="id">
<!-- 用来指明主键的生成方式 -->
<!-- <generatorclass="sequence"> <param name="sequence">emp_seq</param>
</generator> -->
<generatorclass="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接口，声明增、删、改、查的方法，代码如下
packagecom.souvc.dao;importjava.util.List;importcom.souvc.entity.Cost;publicinterfaceICostDao {
List<Cost>findAll();
Cost findById(intid);voidsave(Cost cost);voidupdate(Cost cost);voiddelete(intid);
}
创建DAO实现类CostDaoImpl，继承于HibernateDaoSupport，实现接口ICostDao。代码如下
packagecom.souvc.dao;importjava.util.List;importjavax.annotation.Resource;importorg.hibernate.SessionFactory;importorg.springframework.orm.hibernate3.support.HibernateDaoSupport;importorg.springframework.stereotype.Repository;importcom.souvc.entity.Cost;
@SuppressWarnings("unchecked")
@RepositorypublicclassCostDaoImplextendsHibernateDaoSupportimplementsICostDao {
@ResourcepublicvoidsetSF(SessionFactory sf) {super.setSessionFactory(sf);
}
@OverridepublicList<Cost>findAll() {
String hql= "from Cost";returngetHibernateTemplate().find(hql);
}
@OverridepublicCost findById(intid) {return(Cost) getHibernateTemplate().get(Cost.class, id);
}
@Overridepublicvoidsave(Cost cost) {
getHibernateTemplate().save(cost);
}
@Overridepublicvoidupdate(Cost cost) {
getHibernateTemplate().update(cost);
}
@Overridepublicvoiddelete(intid) {
Cost c=newCost();
c.setId(id);
getHibernateTemplate().delete(c);
}
}
步骤五：测试
在com.souvc.dao包下，创建JUNIT测试类TestDao，分别写出资费的增、删、改
查测试方法，并执行这些方法进行测试。代码如下
packagecom.souvc.dao;importjava.util.List;importorg.junit.Test;importorg.springframework.context.ApplicationContext;importorg.springframework.context.support.ClassPathXmlApplicationContext;importcom.souvc.entity.Cost;/***
* 类名: TestDao
* 描述: 测试类
* 开发人员： souvc
* 创建时间： 2015-9-6 下午1:01:44
* 发布版本：V3.0*/publicclassTestDao {privateString conf = "applicationContext.xml";/*** 方法名：test1
* 详述：查询所有
* 开发人员：souvc
* 创建时间：2015-9-6 下午12:59:30
* 说明参数含义
* 说明返回值含义
* 说明发生此异常的条件*/@Testpublicvoidtest1() {
ApplicationContext ctx=newClassPathXmlApplicationContext(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
* 说明参数含义
* 说明返回值含义
* 说明发生此异常的条件*/@Testpublicvoidtest2() {
ApplicationContext ctx=newClassPathXmlApplicationContext(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
* 说明参数含义
* 说明返回值含义
* 说明发生此异常的条件*/@Testpublicvoidtest3() {
ApplicationContext ctx=newClassPathXmlApplicationContext(conf);
ICostDao dao= (ICostDao) ctx.getBean("costDaoImpl");
Cost c=newCost();
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
* 说明参数含义
* 说明返回值含义
* 说明发生此异常的条件*/@Testpublicvoidtest4() {
ApplicationContext ctx=newClassPathXmlApplicationContext(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
* 说明参数含义
* 说明返回值含义
* 说明发生此异常的条件*/@Testpublicvoidtest5() {
ApplicationContext ctx=newClassPathXmlApplicationContext(conf);
ICostDao dao= (ICostDao) ctx.getBean("costDaoImpl");
dao.delete(1);
}
}
建表语句：
CREATE TABLE `cost` (
`id`int(10) NOT NULL auto_increment,
`name` varchar(50)defaultNULL,
`base_duration`int(11)defaultNULL,
`unit_cost`double(10,0)defaultNULL,
`status` varchar(10)defaultNULL,
`descr` varchar(20)defaultNULL,
`creatime` datedefaultNULL,
`startime` datedefaultNULL,
`cost_type` varchar(10)defaultNULL,
`base_cost`double(10,0)defaultNULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
以上的源码如下：
http://yunpan.cn/cmvceCwSyjbXi 访问密码 3930