ccii
- 浏览: 54867 次
- 性别:
- 来自: 成都
-
文章分类
最新评论
-
chiqinghaichi：
楼主好！菜鸟一枚，试了下你的程序，当访问 http://loc ...
SpringMVC -
随意而生：
复习复习 不错
SpringMVC -
ccii：
cylboke 写道他的意思是“orcle”写错了吧？我猜的！ ...
Oracle基本操作 -
happy200318：
给个赞，不错
SpringMVC -
cylboke：
他的意思是“orcle”写错了吧？我猜的！！！
Oracle基本操作
就Hibernate的持久层访问技术而言，Spring提供了如下三个工具类（或接口）来支持DAO组件的实现：HibernateDaoSupport，HibernateTemplate，HibernateCallback。
1.使用HibernateTemplate对象
1.1 定义实体
Person.java：
package test.domain;
public class Person {
private Integer id;
private String name;
private int age;
public Person() {
}
// 初始化全部属性的构造器
public Person(String name, int age) {
this.name = name;
this.age = age;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getId() {
return this.id;
}
public void setName(String name) {
this.name = name;
}
public String getName() {
return this.name;
}
public void setAge(int age) {
this.age = age;
}
public int getAge() {
return this.age;
}
}
1.2 增加映射Person.hbm.xml：
<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="test.domain">
<class name="Person" table="person_inf">
<id name="id" column="person_id" type="int">
<generator class="identity"/>
</id>
<property name="name" type="string"/>
<property name="age" type="int"/>
</class>
</hibernate-mapping>
1.3 定义DAO
PersonDao.java：
package test.dao;
import java.util.List;
import test.domain.*;
public interface PersonDao {
/**
* 加载Person实例
* @param id 需要加载的Person实例的主键值
* @return 返回加载的Person实例
*/
Person get(Integer id);
/**
* 保存Person实例
* @param person 需要保存的Person实例
* @return 刚刚保存的Person实例的标识属性值
*/
Integer save(Person person);
/**
* 修改Person实例
* @param person 需要修改的Person实例
*/
void update(Person person);
/**
* 删除Person实例
* @param id 需要删除的Person实例的标识属性值
*/
void delete(Integer id);
/**
* 删除Person实例
* @param person 需要删除的Person实例
*/
void delete(Person person);
/**
* 根据用户名查找Person
* @param name 查询的人名
* @return 指定用户名对应的全部Person
*/
List<Person> findByName(String name);
/**
* 查询全部Person实例
* @return 全部Person实例
*/
public List findAllPerson();
/**
* 查询数据表中Person实例的总数
* @return 数据表中Person实例的总数
*/
long getPersonNumber();
}
PersonDaoImpl.java：
package test.dao.impl;
import java.util.List;
import org.hibernate.SessionFactory;
import org.springframework.orm.hibernate3.HibernateTemplate;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl implements PersonDao {
// 定义一个HibernateTemplate对象，用于执行持久化操作
private HibernateTemplate ht = null;
// Hibernate持久化操作所需的SessionFactory
private SessionFactory sessionFactory;
public void setSessionFactory(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
private HibernateTemplate getHibernateTemplate() {
if (ht == null) {
ht = new HibernateTemplate(sessionFactory);
}
return ht;
}
public Person get(Integer id) {
return getHibernateTemplate().get(Person.class, id);
}
public Integer save(Person person) {
return (Integer) getHibernateTemplate().save(person);
}
public void update(Person person) {
getHibernateTemplate().update(person);
}
public void delete(Integer id) {
getHibernateTemplate().delete(get(id));
}
public void delete(Person person) {
getHibernateTemplate().delete(person);
}
public List<Person> findByName(String name) {
return (List<Person>) getHibernateTemplate().find(
"from Person p where p.name = ?", name);
}
public List findAllPerson() {
return (List<Person>) getHibernateTemplate().find("from Person");
}
public long getPersonNumber() {
return (Long) getHibernateTemplate().find(
"select count(*) from Person as p").get(0);
}
}
1.4 编写Spring配置文件bean.xml
当通过Hibernate进行持久层访问时，必须先获得SessionFactory对象，它是单个数据库映射关系编译后的内存镜像。一旦在Spring容器的IoC容器中配置了SessionFactory Bean，它将随应用的启动而加载，并可以充分利用IoC容器的功能，将SessionFactory Bean注入任何Bean，比如DAO组件。如下：
<?xml version="1.0" encoding="GBK"?>
<!-- Spring配置文件的根元素，使用spring-beans-3.0.xsd语义约束 -->
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<!-- 定义数据源Bean，使用C3P0数据源实现 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<!-- 指定连接数据库的驱动 -->
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<!-- 指定连接数据库的URL -->
<property name="jdbcUrl" value="jdbc:mysql://localhost/aaa"/>
<!-- 指定连接数据库的用户名 -->
<property name="user" value="root"/>
<!-- 指定连接数据库的密码 -->
<property name="password" value="root"/>
<!-- 指定连接数据库连接池的最大连接数 -->
<property name="maxPoolSize" value="40"/>
<!-- 指定连接数据库连接池的最小连接数 -->
<property name="minPoolSize" value="1"/>
<!-- 指定连接数据库连接池的初始化连接数 -->
<property name="initialPoolSize" value="1"/>
<!-- 指定连接数据库连接池的连接的最大空闲时间 -->
<property name="maxIdleTime" value="20"/>
</bean>
<!-- 定义Hibernate的SessionFactory -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<!-- 依赖注入数据源，注入正是上面定义的dataSource -->
<property name="dataSource" ref="dataSource"/>
<!-- mappingResouces属性用来列出全部映射文件 -->
<property name="mappingResources">
<list>
<!-- 以下用来列出Hibernate映射文件，可使用classpath*:/test/domain/*.xml统一引用 -->
<value>test/domain/Person.hbm.xml</value>
</list>
</property>
<!-- 定义Hibernate的SessionFactory的属性 -->
<property name="hibernateProperties">
<!-- 配置Hibernate属性 -->
<value>
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
hibernate.hbm2ddl.auto=update
hibernate.show_sql=true
hibernate.format_sql=true;
</value>
</property>
</bean>
<!-- 定义DAO Bean-->
<bean id="personDao"
class="test.dao.impl.PersonDaoImpl">
<!-- 注入持久化操作所需的SessionFactory -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
</beans>
1.5 测试
package test;
import org.springframework.context.*;
import org.springframework.context.support.*;
import test.dao.*;
import test.domain.*;
public class HibernateTest {
public static void main(String[] args) {
// 创建Spring容器
ApplicationContext ctx = new ClassPathXmlApplicationContext("bean.xml");
// 获取DAO组件
PersonDao pdao = (PersonDao) ctx.getBean("personDao");
// 循环插入10条记录
for (int i = 0; i < 10; i++) {
pdao.save(new Person(i + "", i + 10));
}
// 调用DAO组件的方法
System.out.println(pdao.getPersonNumber());
}
}
2.使用HibernateCallback实例
package test;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.hibernate.Session;
import org.hibernate.Query;
import org.hibernate.HibernateException;
import java.sql.SQLException;
import java.util.List;
public class YeekuHibernateDaoSupport extends HibernateDaoSupport {
/**
* 使用hql语句进行分页查询
*
* @param hql 需要查询的hql语句
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final int offset,
final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
List result = session.createQuery(hql).setFirstResult(offset)
.setMaxResults(pageSize).list();
return result;
}
});
return list;
}
/**
* 使用hql语句进行分页查询
* @param hql 需要查询的hql语句
* @param value 如果hql有一个参数需要传入，value就是传入hql语句的参数
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final Object value,
final int offset, final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
List result = session.createQuery(hql)
// 为hql语句传入参数
.setParameter(0, value).setFirstResult(offset)
.setMaxResults(pageSize).list();
return result;
}
});
return list;
}
/**
* 使用hql语句进行分页查询
* @param hql 需要查询的hql语句
* @param values 如果hql有多个个参数需要传入，values就是传入hql的参数数组
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final Object[] values,
final int offset, final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
Query query = session.createQuery(hql);
// 为hql语句传入参数
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
List result = query.setFirstResult(offset).setMaxResults(
pageSize).list();
return result;
}
});
return list;
}
}
3.使用HibernateDaoSupport工具类
PersonDaoImpl.java（其它代码同上面一样）
package test.dao.impl;
import java.util.List;
import org.springframework.orm.hibernate3.support.*;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl extends HibernateDaoSupport implements PersonDao {
/**
* 加载Person实例
* @param id 需要加载的Person实例的标识属性值
* @return 指定id对应的Person实例
*/
public Person get(Integer id) {
return getHibernateTemplate().get(Person.class, id);
}
/**
* 保存Person实例
* @param person 需要保存的Person实例
* @return 刚刚保存的Person实例的标识属性值
*/
public Integer save(Person person) {
return (Integer) getHibernateTemplate().save(person);
}
/**
* 修改Person实例
* @param person 需要修改的Person实例
*/
public void update(Person person) {
getHibernateTemplate().update(person);
}
/**
* 删除Person实例
* @param id 需要删除的Person实例的标识属性值
*/
public void delete(Integer id) {
getHibernateTemplate().delete(get(id));
}
/**
* 删除Person实例
* @param person 需要删除的Person实例
*/
public void delete(Person person) {
getHibernateTemplate().delete(person);
}
/**
* 根据用户名查找Person
* @param name 查询的人名
* @return 指定用户名对应的全部Person
*/
public List<Person> findByName(String name) {
return (List<Person>) getHibernateTemplate().find(
"from Person p where p.name = ?", name);
}
/**
* 查询全部Person实例
* @return 全部Person实例
*/
public List findAllPerson() {
return (List<Person>) getHibernateTemplate().find("from Person");
}
/**
* 查询数据表中Person实例的总数
* @return 数据表中Person实例的总数
*/
public long getPersonNumber() {
return (Long) getHibernateTemplate().find(
"select count(*) from Person as p").get(0);
}
}
4.使用声明式事务
<?xml version="1.0" encoding="GBK"?>
<!-- 指定Spring配置文件的Schema信息 -->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
<!-- 定义数据源Bean，使用C3P0数据源实现 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<!-- 指定连接数据库的驱动 -->
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<!-- 指定连接数据库的URL -->
<property name="jdbcUrl" value="jdbc:mysql://localhost/javaee"/>
<!-- 指定连接数据库的用户名 -->
<property name="user" value="root"/>
<!-- 指定连接数据库的密码 -->
<property name="password" value="32147"/>
<!-- 指定连接数据库连接池的最大连接数 -->
<property name="maxPoolSize" value="40"/>
<!-- 指定连接数据库连接池的最小连接数 -->
<property name="minPoolSize" value="1"/>
<!-- 指定连接数据库连接池的初始化连接数 -->
<property name="initialPoolSize" value="1"/>
<!-- 指定连接数据库连接池的连接的最大空闲时间 -->
<property name="maxIdleTime" value="20"/>
</bean>
<!-- 定义Hibernate的SessionFactory -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<!-- 依赖注入数据源，注入正是上面定义的dataSource -->
<property name="dataSource" ref="dataSource"/>
<!-- mappingResouces属性用来列出全部映射文件 -->
<property name="mappingResources">
<list>
<!-- 以下用来列出Hibernate映射文件 -->
<value>org/crazyit/app/domain/Person.hbm.xml</value>
</list>
</property>
<!-- 定义Hibernate的SessionFactory的属性 -->
<property name="hibernateProperties">
<!-- 配置Hibernate属性 -->
<value>
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
hibernate.hbm2ddl.auto=update
hibernate.show_sql=true
hibernate.format_sql=true;
</value>
</property>
</bean>
<!-- 定义DAO Bean-->
<bean id="personDao" class=
"org.crazyit.app.dao.impl.PersonDaoHibernate">
<!-- 注入持久化操作所需的SessionFactory -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
<!-- 配置一个业务逻辑组件 -->
<bean id="leeService" class=
"org.crazyit.app.service.impl.LeeServiceImpl">
<!-- 注入持久化访问所需的DAO组件 -->
<property name="personDao" ref="personDao"/>
</bean>
<!-- 配置Hibernate的局部事务管理器，使用HibernateTransactionManager类 -->
<!-- 该类实现PlatformTransactionManager接口，是针对Hibernate的特定实现-->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<!-- 配置HibernateTransactionManager时需要依注入SessionFactory的引用 -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
<!-- 配置事务增强处理,指定事务管理器 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<!-- 用于配置详细的事务语义 -->
<tx:attributes>
<!-- 所有以'get'开头的方法是read-only的 -->
<tx:method name="get*" read-only="true"/>
<!-- 其他方法使用默认的事务设置 -->
<tx:method name="*"/>
</tx:attributes>
</tx:advice>
<aop:config>
<!-- 配置一个切入点 -->
<aop:pointcut id="leePointcut"
expression="bean(leeService)"/>
<!-- 指定在leePointcut切入点应用txAdvice事务增强处理，即在leeService里所有的方法织入事务控制 -->
<aop:advisor advice-ref="txAdvice"
pointcut-ref="leePointcut"/>
</aop:config>
</beans>
1.使用HibernateTemplate对象
1.1 定义实体
Person.java：
package test.domain;
public class Person {
private Integer id;
private String name;
private int age;
public Person() {
}
// 初始化全部属性的构造器
public Person(String name, int age) {
this.name = name;
this.age = age;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getId() {
return this.id;
}
public void setName(String name) {
this.name = name;
}
public String getName() {
return this.name;
}
public void setAge(int age) {
this.age = age;
}
public int getAge() {
return this.age;
}
}
1.2 增加映射Person.hbm.xml：
<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="test.domain">
<class name="Person" table="person_inf">
<id name="id" column="person_id" type="int">
<generator class="identity"/>
</id>
<property name="name" type="string"/>
<property name="age" type="int"/>
</class>
</hibernate-mapping>
1.3 定义DAO
PersonDao.java：
package test.dao;
import java.util.List;
import test.domain.*;
public interface PersonDao {
/**
* 加载Person实例
* @param id 需要加载的Person实例的主键值
* @return 返回加载的Person实例
*/
Person get(Integer id);
/**
* 保存Person实例
* @param person 需要保存的Person实例
* @return 刚刚保存的Person实例的标识属性值
*/
Integer save(Person person);
/**
* 修改Person实例
* @param person 需要修改的Person实例
*/
void update(Person person);
/**
* 删除Person实例
* @param id 需要删除的Person实例的标识属性值
*/
void delete(Integer id);
/**
* 删除Person实例
* @param person 需要删除的Person实例
*/
void delete(Person person);
/**
* 根据用户名查找Person
* @param name 查询的人名
* @return 指定用户名对应的全部Person
*/
List<Person> findByName(String name);
/**
* 查询全部Person实例
* @return 全部Person实例
*/
public List findAllPerson();
/**
* 查询数据表中Person实例的总数
* @return 数据表中Person实例的总数
*/
long getPersonNumber();
}
PersonDaoImpl.java：
package test.dao.impl;
import java.util.List;
import org.hibernate.SessionFactory;
import org.springframework.orm.hibernate3.HibernateTemplate;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl implements PersonDao {
// 定义一个HibernateTemplate对象，用于执行持久化操作
private HibernateTemplate ht = null;
// Hibernate持久化操作所需的SessionFactory
private SessionFactory sessionFactory;
public void setSessionFactory(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
private HibernateTemplate getHibernateTemplate() {
if (ht == null) {
ht = new HibernateTemplate(sessionFactory);
}
return ht;
}
public Person get(Integer id) {
return getHibernateTemplate().get(Person.class, id);
}
public Integer save(Person person) {
return (Integer) getHibernateTemplate().save(person);
}
public void update(Person person) {
getHibernateTemplate().update(person);
}
public void delete(Integer id) {
getHibernateTemplate().delete(get(id));
}
public void delete(Person person) {
getHibernateTemplate().delete(person);
}
public List<Person> findByName(String name) {
return (List<Person>) getHibernateTemplate().find(
"from Person p where p.name = ?", name);
}
public List findAllPerson() {
return (List<Person>) getHibernateTemplate().find("from Person");
}
public long getPersonNumber() {
return (Long) getHibernateTemplate().find(
"select count(*) from Person as p").get(0);
}
}
1.4 编写Spring配置文件bean.xml
当通过Hibernate进行持久层访问时，必须先获得SessionFactory对象，它是单个数据库映射关系编译后的内存镜像。一旦在Spring容器的IoC容器中配置了SessionFactory Bean，它将随应用的启动而加载，并可以充分利用IoC容器的功能，将SessionFactory Bean注入任何Bean，比如DAO组件。如下：
<?xml version="1.0" encoding="GBK"?>
<!-- Spring配置文件的根元素，使用spring-beans-3.0.xsd语义约束 -->
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<!-- 定义数据源Bean，使用C3P0数据源实现 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<!-- 指定连接数据库的驱动 -->
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<!-- 指定连接数据库的URL -->
<property name="jdbcUrl" value="jdbc:mysql://localhost/aaa"/>
<!-- 指定连接数据库的用户名 -->
<property name="user" value="root"/>
<!-- 指定连接数据库的密码 -->
<property name="password" value="root"/>
<!-- 指定连接数据库连接池的最大连接数 -->
<property name="maxPoolSize" value="40"/>
<!-- 指定连接数据库连接池的最小连接数 -->
<property name="minPoolSize" value="1"/>
<!-- 指定连接数据库连接池的初始化连接数 -->
<property name="initialPoolSize" value="1"/>
<!-- 指定连接数据库连接池的连接的最大空闲时间 -->
<property name="maxIdleTime" value="20"/>
</bean>
<!-- 定义Hibernate的SessionFactory -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<!-- 依赖注入数据源，注入正是上面定义的dataSource -->
<property name="dataSource" ref="dataSource"/>
<!-- mappingResouces属性用来列出全部映射文件 -->
<property name="mappingResources">
<list>
<!-- 以下用来列出Hibernate映射文件，可使用classpath*:/test/domain/*.xml统一引用 -->
<value>test/domain/Person.hbm.xml</value>
</list>
</property>
<!-- 定义Hibernate的SessionFactory的属性 -->
<property name="hibernateProperties">
<!-- 配置Hibernate属性 -->
<value>
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
hibernate.hbm2ddl.auto=update
hibernate.show_sql=true
hibernate.format_sql=true;
</value>
</property>
</bean>
<!-- 定义DAO Bean-->
<bean id="personDao"
class="test.dao.impl.PersonDaoImpl">
<!-- 注入持久化操作所需的SessionFactory -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
</beans>
1.5 测试
package test;
import org.springframework.context.*;
import org.springframework.context.support.*;
import test.dao.*;
import test.domain.*;
public class HibernateTest {
public static void main(String[] args) {
// 创建Spring容器
ApplicationContext ctx = new ClassPathXmlApplicationContext("bean.xml");
// 获取DAO组件
PersonDao pdao = (PersonDao) ctx.getBean("personDao");
// 循环插入10条记录
for (int i = 0; i < 10; i++) {
pdao.save(new Person(i + "", i + 10));
}
// 调用DAO组件的方法
System.out.println(pdao.getPersonNumber());
}
}
2.使用HibernateCallback实例
package test;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.hibernate.Session;
import org.hibernate.Query;
import org.hibernate.HibernateException;
import java.sql.SQLException;
import java.util.List;
public class YeekuHibernateDaoSupport extends HibernateDaoSupport {
/**
* 使用hql语句进行分页查询
*
* @param hql 需要查询的hql语句
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final int offset,
final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
List result = session.createQuery(hql).setFirstResult(offset)
.setMaxResults(pageSize).list();
return result;
}
});
return list;
}
/**
* 使用hql语句进行分页查询
* @param hql 需要查询的hql语句
* @param value 如果hql有一个参数需要传入，value就是传入hql语句的参数
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final Object value,
final int offset, final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
List result = session.createQuery(hql)
// 为hql语句传入参数
.setParameter(0, value).setFirstResult(offset)
.setMaxResults(pageSize).list();
return result;
}
});
return list;
}
/**
* 使用hql语句进行分页查询
* @param hql 需要查询的hql语句
* @param values 如果hql有多个个参数需要传入，values就是传入hql的参数数组
* @param offset 第一条记录索引
* @param pageSize 每页需要显示的记录数
* @return 当前页的所有记录
*/
public List findByPage(final String hql, final Object[] values,
final int offset, final int pageSize) {
// 通过一个HibernateCallback对象来执行查询
List list = getHibernateTemplate().executeFind(new HibernateCallback() {
// 实现HibernateCallback接口必须实现的方法
public Object doInHibernate(Session session)
throws HibernateException, SQLException {
// 执行Hibernate分页查询
Query query = session.createQuery(hql);
// 为hql语句传入参数
for (int i = 0; i < values.length; i++) {
query.setParameter(i, values[i]);
}
List result = query.setFirstResult(offset).setMaxResults(
pageSize).list();
return result;
}
});
return list;
}
}
3.使用HibernateDaoSupport工具类
PersonDaoImpl.java（其它代码同上面一样）
package test.dao.impl;
import java.util.List;
import org.springframework.orm.hibernate3.support.*;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl extends HibernateDaoSupport implements PersonDao {
/**
* 加载Person实例
* @param id 需要加载的Person实例的标识属性值
* @return 指定id对应的Person实例
*/
public Person get(Integer id) {
return getHibernateTemplate().get(Person.class, id);
}
/**
* 保存Person实例
* @param person 需要保存的Person实例
* @return 刚刚保存的Person实例的标识属性值
*/
public Integer save(Person person) {
return (Integer) getHibernateTemplate().save(person);
}
/**
* 修改Person实例
* @param person 需要修改的Person实例
*/
public void update(Person person) {
getHibernateTemplate().update(person);
}
/**
* 删除Person实例
* @param id 需要删除的Person实例的标识属性值
*/
public void delete(Integer id) {
getHibernateTemplate().delete(get(id));
}
/**
* 删除Person实例
* @param person 需要删除的Person实例
*/
public void delete(Person person) {
getHibernateTemplate().delete(person);
}
/**
* 根据用户名查找Person
* @param name 查询的人名
* @return 指定用户名对应的全部Person
*/
public List<Person> findByName(String name) {
return (List<Person>) getHibernateTemplate().find(
"from Person p where p.name = ?", name);
}
/**
* 查询全部Person实例
* @return 全部Person实例
*/
public List findAllPerson() {
return (List<Person>) getHibernateTemplate().find("from Person");
}
/**
* 查询数据表中Person实例的总数
* @return 数据表中Person实例的总数
*/
public long getPersonNumber() {
return (Long) getHibernateTemplate().find(
"select count(*) from Person as p").get(0);
}
}
4.使用声明式事务
<?xml version="1.0" encoding="GBK"?>
<!-- 指定Spring配置文件的Schema信息 -->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
<!-- 定义数据源Bean，使用C3P0数据源实现 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<!-- 指定连接数据库的驱动 -->
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<!-- 指定连接数据库的URL -->
<property name="jdbcUrl" value="jdbc:mysql://localhost/javaee"/>
<!-- 指定连接数据库的用户名 -->
<property name="user" value="root"/>
<!-- 指定连接数据库的密码 -->
<property name="password" value="32147"/>
<!-- 指定连接数据库连接池的最大连接数 -->
<property name="maxPoolSize" value="40"/>
<!-- 指定连接数据库连接池的最小连接数 -->
<property name="minPoolSize" value="1"/>
<!-- 指定连接数据库连接池的初始化连接数 -->
<property name="initialPoolSize" value="1"/>
<!-- 指定连接数据库连接池的连接的最大空闲时间 -->
<property name="maxIdleTime" value="20"/>
</bean>
<!-- 定义Hibernate的SessionFactory -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<!-- 依赖注入数据源，注入正是上面定义的dataSource -->
<property name="dataSource" ref="dataSource"/>
<!-- mappingResouces属性用来列出全部映射文件 -->
<property name="mappingResources">
<list>
<!-- 以下用来列出Hibernate映射文件 -->
<value>org/crazyit/app/domain/Person.hbm.xml</value>
</list>
</property>
<!-- 定义Hibernate的SessionFactory的属性 -->
<property name="hibernateProperties">
<!-- 配置Hibernate属性 -->
<value>
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
hibernate.hbm2ddl.auto=update
hibernate.show_sql=true
hibernate.format_sql=true;
</value>
</property>
</bean>
<!-- 定义DAO Bean-->
<bean id="personDao" class=
"org.crazyit.app.dao.impl.PersonDaoHibernate">
<!-- 注入持久化操作所需的SessionFactory -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
<!-- 配置一个业务逻辑组件 -->
<bean id="leeService" class=
"org.crazyit.app.service.impl.LeeServiceImpl">
<!-- 注入持久化访问所需的DAO组件 -->
<property name="personDao" ref="personDao"/>
</bean>
<!-- 配置Hibernate的局部事务管理器，使用HibernateTransactionManager类 -->
<!-- 该类实现PlatformTransactionManager接口，是针对Hibernate的特定实现-->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<!-- 配置HibernateTransactionManager时需要依注入SessionFactory的引用 -->
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
<!-- 配置事务增强处理,指定事务管理器 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<!-- 用于配置详细的事务语义 -->
<tx:attributes>
<!-- 所有以'get'开头的方法是read-only的 -->
<tx:method name="get*" read-only="true"/>
<!-- 其他方法使用默认的事务设置 -->
<tx:method name="*"/>
</tx:attributes>
</tx:advice>
<aop:config>
<!-- 配置一个切入点 -->
<aop:pointcut id="leePointcut"
expression="bean(leeService)"/>
<!-- 指定在leePointcut切入点应用txAdvice事务增强处理，即在leeService里所有的方法织入事务控制 -->
<aop:advisor advice-ref="txAdvice"
pointcut-ref="leePointcut"/>
</aop:config>
</beans>
分享到：
发表评论
-
SpringMVC
2014-10-20 23:03 3815一、Spring概述 1. 简介 Spring MVC ... -
Spring整合MyBatis
2014-05-15 00:43 3189首先介绍一下整合中用到的几个类 1）org.mybatis ... -
Spring整合Struts2
2014-03-11 00:08 4141.启动Spring容器 对于使用Spring的Web应用 ... -
Spring的事务管理
2014-03-10 23:34 439一、概述 Spring的事务管理不需要与任何特定的事务AP ... -
Spring
2014-03-10 21:40 1091一、Spring基础 1. Spring简介 Spring ...
相关推荐
ssh整合，针对spring整合hibernate代码，示例代码，教程。
spring整合hibernate实现事务处理 1.spring整合hibernate实现事务处理-注解方式 2.spring整合hibernate实现事务处理-XML方式
Spring整合hibernate(2)之基于HibernateTemplate的整合,jar需要自己添加！
Spring整合Hibernate的所有jar包，辛苦整理两个小时，给大家分享出来。 一共27个包
这是使用spring整合hibernate、struts时所要用到的核心jar包，洗完对大家有帮助
spring整合hibernate所用相关jar包，适合初学者
spring整合hibernate的所需jar包,很全的！
Spring整合Hibernate配置测试示例
这里的jar包只是说Spring自带的关于Hibernate的jar包，即这四个jar包： hibernate3.jar， hibernate-annotations.jar， hibernate-entitymanager.jar hibernate-commons-annotations.jar 因为我原来下载了一个，但是...
spring整合Hibernate学习笔记.docx spring整合Hibernate学习笔记.docx
在创建ssh或sh项目中必不可少的jar包引入，提供项目的依赖。
Spring+hibernate整合源代码 结束Sping+hibernate 的使用方法 包括演示示例
javaweb通过Spring整合Hibernate和Struts2实现简单的登录
Spring整合hibernate的实例
Spring框架整合Hibernate框架,为大家提供一个学习案例.
spring整合hibernate与struts2所需jar包
spring-hibernate.jar
6.5 Spring整合Hibernate 6.6 Spring提供的DAO支持 6.5.2 管理Hibernate的SessionFactory 6.5.3 使用HibernateTemplate 6.5.4 使用HibernateCallBack 6.5.6 使用IoC容器组装各种组件 6.5.7启动web容器读取xml配置...
spring整合hibernate hao