Spring学习_04_Spring和Hibernate整合数据源(DataSource)
2015-03-13 19:04
465 查看
首先,说明一下DataSource是什么?DataSoure中有一个getConnection()方法,说明DataSource管理着数据库的连接,所以一般将其称为连接池。DataSource是一个抽象类,具体有很多的实现。比如Spring中常用的DBCP,Hibernate中常用的C3PO,以及不太常用的proxool。
那么下面我们首先来将一个使用数据源的例子程序搭建起来。分为如下几步:
第一步:我们在beans.xml中配置好我们的数据源,也就是我们的连接池,然后配置好我们的sessionFactory,Hibernate中的sessionFactory管理者session。而一个sesseion我们可以把它当成我们连接数据库的一个Connection。
第五步:编写我们的Service层代码,代码如下:
第六步:测试方法:
第一:由于加入了Hibernate,所以要加入Hibernate的相关jar包,而且使用了spring和Hibernate的集成,所以,Spring中对于hibernate集成的支持包也需要加入,另外,这里使用了连接池,所以连接池的相关包也需要加入。
第二:这在beans.xml中使用PropertyPlaceholderConfigurer类来将数据库连接的配置移除到了一个properties文件中,可以实现更好的解耦和。
第三:这里我们在beans.xml中配置的sessionFactory的类是:org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean。但是我们在Dao实现类中打印出来的实现类却是:class org.hibernate.impl.SessionFactoryImpl。一个是Spring中的AnnotationSessionFactoryBean。一个却是Hibernate中的sessionFacotory。个人猜测这是因为Spring在内部做了一些转化,在其中加入了自己的一些逻辑。
第四:第四步中我们使用“Session session = sessionFactory.getCurrentSession();”会报错:org.hibernate.HibernateException: No Hibernate Session bound to thread, and configuration does not allow creation
of non-transactional one here。是因为这里我们没有还没有加入事物的控制。我们说过OpenSession()永远都是打开一个新的Session。所以这里我们使用openSession()的话不会有任何问题,可以正确的打开一个Session。但是使用getCurrentSession()。这个方法先会去当前的线程中查找绑定在上面的Session,如果没有,就去创造一个。而这里我们没有一个session绑定在当前线程上,但是我们因为没有配置事物,所以这里创造一个新的session也会出现问题。一般出现这个问题就只有两个原因:一个是没有配置事物,一个是配置了事物,但是配置出错。下面我们就来解决这个问题。(还有一种猜测:在单独用Hibernate的时候,我依稀记得使用两个方法的时候都是可以取得到session的。为什么这里就不是两个方法都可以呢?我才是因为我们配置了spring中的AnnotationSessionFactoryBean的缘故。也许它不允许我们这样做。)
下面我们就来解决这个问题。
为上面的例子程序加入事物的控制:
首先,我们要确定一下,事物是用来控制数据的完整性的,所以事物与数据库有这紧密的联系。我们首先要确定一点,由于一个事物有可能会涉及到多个表,所以我们的事物边界是一定不可以加入到DAO层,而必须要把我们的事物边界加入到我们的service层。下面为我们的例子加入一个记录日志的功能,每次加入一个user对象后,就要在日志表中去记录一下。下面我们一步一步去完善这个例子。
第一步:在beans.xml中加入事物标签,配置我们的事物。在上面的beans.xml中添加如下配置:
第二步:新建我们的日志类,日志表:
那么下面我们首先来将一个使用数据源的例子程序搭建起来。分为如下几步:
第一步:我们在beans.xml中配置好我们的数据源,也就是我们的连接池,然后配置好我们的sessionFactory,Hibernate中的sessionFactory管理者session。而一个sesseion我们可以把它当成我们连接数据库的一个Connection。
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="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/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"> <context:annotation-config/> <context:component-scan base-package="com.zxb"/> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <value>classpath:jdbc.properties</value> </property> </bean> <bean id="dataSource" destroy-method="close" class="org.apache.commons.dbcp.BasicDataSource"> <property name="driverClassName" value="${jdbc.driverClassName}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </bean> <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"> <property name="dataSource" ref="dataSource"></property> <property name="annotatedClasses"> <list> <value>com.zxb.model.User</value> </list> </property> <property name="hibernateProperties"> <props> <prop key="hibernate.dialect"> org.hibernate.dialect.MySQLDialect </prop> <prop key="hibernate.show_sql">true</prop> </props> </property> </bean> </beans>第二步:建立我们在数据库连接中使用的数据库连接属性文件:
jdbc.driverClassName=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/spring jdbc.username=root jdbc.password=root第三步:建立我们的实体类和对应的数据库表:这里只给出我们的实体类:
@Entity public class User { private int id; private String username; @Id @GeneratedValue public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } }第四步:写好我们的数据库Dao接口,Dao的实现类。这里只给出Dao的实现类代码:(这里的事物提交控制全部在实现类中实现的,如果有了事物控制的话,这个就不用我们自己写了。)
@Component("userDao") public class UserDAOImpl implements UserDAO { private SessionFactory sessionFactory; public SessionFactory getSessionFactory() { return sessionFactory; } @Resource public void setSessionFactory(SessionFactory sessionFactory) { this.sessionFactory = sessionFactory; } public void save(User user) { System.out.println("sessionFctory's class is: "+sessionFactory.getClass()); Session session = sessionFactory.openSession();//getCurrentSession(); session.beginTransaction(); session.save(user); session.getTransaction().commit(); } }
第五步:编写我们的Service层代码,代码如下:
@Service("userService") public class UserService { private UserDAO userDAO; public void add(User user) { userDAO.save(user); } public UserDAO getUserDAO() { return userDAO; } @Resource(name="userDao") public void setUserDAO(UserDAO userDAO) { this.userDAO = userDAO; } }
第六步:测试方法:
@Test public void testAdd() throws Exception { ApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml"); UserService service = (UserService)ctx.getBean("userService"); User u = new User(); u.setUsername("zxb"); service.add(u); }第七步:测试输出(数据已成功插入到数据中):
sessionFctory's class is: class org.hibernate.impl.SessionFactoryImpl关于这个案例的几点说明:
第一:由于加入了Hibernate,所以要加入Hibernate的相关jar包,而且使用了spring和Hibernate的集成,所以,Spring中对于hibernate集成的支持包也需要加入,另外,这里使用了连接池,所以连接池的相关包也需要加入。
第二:这在beans.xml中使用PropertyPlaceholderConfigurer类来将数据库连接的配置移除到了一个properties文件中,可以实现更好的解耦和。
第三:这里我们在beans.xml中配置的sessionFactory的类是:org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean。但是我们在Dao实现类中打印出来的实现类却是:class org.hibernate.impl.SessionFactoryImpl。一个是Spring中的AnnotationSessionFactoryBean。一个却是Hibernate中的sessionFacotory。个人猜测这是因为Spring在内部做了一些转化,在其中加入了自己的一些逻辑。
第四:第四步中我们使用“Session session = sessionFactory.getCurrentSession();”会报错:org.hibernate.HibernateException: No Hibernate Session bound to thread, and configuration does not allow creation
of non-transactional one here。是因为这里我们没有还没有加入事物的控制。我们说过OpenSession()永远都是打开一个新的Session。所以这里我们使用openSession()的话不会有任何问题,可以正确的打开一个Session。但是使用getCurrentSession()。这个方法先会去当前的线程中查找绑定在上面的Session,如果没有,就去创造一个。而这里我们没有一个session绑定在当前线程上,但是我们因为没有配置事物,所以这里创造一个新的session也会出现问题。一般出现这个问题就只有两个原因:一个是没有配置事物,一个是配置了事物,但是配置出错。下面我们就来解决这个问题。(还有一种猜测:在单独用Hibernate的时候,我依稀记得使用两个方法的时候都是可以取得到session的。为什么这里就不是两个方法都可以呢?我才是因为我们配置了spring中的AnnotationSessionFactoryBean的缘故。也许它不允许我们这样做。)
下面我们就来解决这个问题。
为上面的例子程序加入事物的控制:
首先,我们要确定一下,事物是用来控制数据的完整性的,所以事物与数据库有这紧密的联系。我们首先要确定一点,由于一个事物有可能会涉及到多个表,所以我们的事物边界是一定不可以加入到DAO层,而必须要把我们的事物边界加入到我们的service层。下面为我们的例子加入一个记录日志的功能,每次加入一个user对象后,就要在日志表中去记录一下。下面我们一步一步去完善这个例子。
第一步:在beans.xml中加入事物标签,配置我们的事物。在上面的beans.xml中添加如下配置:
xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd"> <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"> <property name="sessionFactory" ref=sessionFactory></property> </bean> <tx:annotation-driven transaction-manager="transactionManager"/>
第二步:新建我们的日志类,日志表:
@Entity @Table(name="msg") public class Msg { private int id; private String log; @Id @GeneratedValue @Column(name="id") public int getId() { return id; } public void setId(int id) { this.id = id; } @Column(name="msg") public String getLog() { return log; } public void setLog(String log) { this.log = log; } }第三步:新建日志类的Dao接口,Dao的实现类,注意,此时,由于我们加入了事物控制,所以Dao的实现类中事物的提交等代码都要注释掉。包括前面的User类的,事物的一切处理交由spring来管理。代码如下:
@Component("msgDao") public class MsgDAOImpl implements MsgDAO { private SessionFactory sessionFactory; public SessionFactory getSessionFactory() { return sessionFactory; } @Resource public void setSessionFactory(SessionFactory sessionFactory) { this.sessionFactory = sessionFactory; } public void save(Msg msg) { Session session = sessionFactory.getCurrentSession(); session.save(msg); } }第四步:编写我们的service方法,在我们保存user对象的时候,写入一条日志。改写其中的save(User user)方法如下:
@Service("userService") public class UserService { private UserDAO userDAO; private MsgDAO msgDao; @Transactional public void add(User user) { Msg msg = new Msg(); userDAO.save(user); msg.setLog("a user saved!"); msgDao.save(msg); } public UserDAO getUserDAO() { return userDAO; } @Resource(name="userDao") public void setUserDAO(UserDAO userDAO) { this.userDAO = userDAO; } public MsgDAO getMsgDao() { return msgDao; } @Resource(name="msgDao") public void setMsgDao(MsgDAO msgDao) { this.msgDao = msgDao; } }这里我们在save上面加了一条@Transactional来控制我们的数据库事物。这样就保证了如果在service的save方法执行中,如果这个过程中抛出了一个运行时异常,就会自动回滚。而且这里也使用的是getCurrentSession方法来取得数据库的连接。经过测试,一切正常。
相关文章推荐
- spring整合hibernate时,sessionFactory和datasource的关系?,数据源的作用?如果写了一个Dao类
- SSH整合学习笔记之spring与hibernate简单整合.doc
- 学习笔记-----------------struts2 hibernate3 spring2.5整合
- Spring3.3 整合 Hibernate3、MyBatis3.2 配置多数据源/动态切换数据源 方法
- 利用AbstractRoutingDataSource实现动态数据源切换 (Spring+Hibernate)
- 【hibernate+Spring学习】S2SH整合笔记--中文乱码
- Spring4学习笔记-Spring4整合Hibernate4
- 利用AbstractRoutingDataSource实现动态数据源切换 (Spring+Hibernate)
- Spring3.3 整合 Hibernate3、MyBatis3.2 配置多数据源/动态切换数据源 方法
- Spring 整合 hibernate的 applicationContext.xml 数据源配置
- SSH学习笔记之关于struts-spring-hibernate整合配置问
- Spring学习文档_管理数据源,以及配置Hibernate关系
- Spring和HIbernate整合配置数据源 出现 'java.lang.String'不能转换为java.lang.class
- Spring与Hibernate整合的HibernateDaoSupport应用中的“内存泄露”问题(学习心得)
- Spring+Hibernate如何配置数据源(Struts Spring Hibernate (SSH) 整合实例)
- Hibernate+Struts整合学习,后期再继续学习spring
- 【hibernate+Spring学习】S2SH整合笔记--中文乱码
- Spring3.3 整合 Hibernate3、MyBatis3.2 配置多数据源/动态切换数据源 方法
- 【SSH学习笔记】整合spring3-hibernate的小项目(二)
- Spring3.3 整合 Hibernate3、MyBatis3.2 配置多数据源/动态切换数据源 方法