Spring、OSGi整合Hibernate 一

         查询了很多网上的帖子，主流的整合方式大体为4种。前两种不必说了，没什么扩展性，不予考虑。第三种采用Eclipse-RegisterBuddy方式(官方的整合方式)和第四种则采用Eclipse插件的扩展点，这样种都不能脱离Equinox实现，最后还是决定用自己的一套方式。
        先来说说整合Hibernate的关键之处。其实用OSGi整合Hibernate很简单，但要通过Bundle方式做到可以扩展新的持久化层面的东西（比如添加新的表和操作）就比较费事了。因为Hibernate在初始化时根据注册的实体类创建SessionFactory，这样当有新的实体类添加进来时就要创建新的SessionFactory，这样系统中出现两个甚至多个SessionFatory会导致一系列的问题。显然整合Hibernate关键就是解决实体类注册与SessionFactory创建的问题。
        我的具体思路如下。
        首先将Hibernate单独多为一个Bundle（wanged_commons_hibernate）以便提供其他Bundle所需类包。
        然后建立一个用于提供实体注册接口的Bundle（wanged_core_persistent_entity_register），代码如下：
       建一个用来初始化SessionFactory和事务管理的Bundle（wanged_core_persistent），由于使用Spring提供的LocalSessionFactoryBean会有问题，所以我单独写了两个类。
类LocalSessionFactoryBean的代码： 类LocalDataSourceConnectionProvider的代码：

java 代码

 

1. package wanged.core.persistent;  
2.   
3. import java.sql.Connection;  
4. import java.sql.SQLException;  
5. import java.util.Properties;  
6.   
7. import javax.sql.DataSource;  
8.   
9. import org.hibernate.HibernateException;  
10. import org.hibernate.connection.ConnectionProvider;  
11. import org.hibernate.util.JDBCExceptionReporter;  
12.   
13. public class LocalDataSourceConnectionProvider implements ConnectionProvider {  
14.   
15.     private DataSource dataSource;  
16.   
17.     private DataSource dataSourceToUse;  
18.   
19.   
20.     public void configure(Properties props) throws HibernateException {  
21.         this.dataSource = LocalSessionFactoryBean.getConfigTimeDataSource();  
22.         if (this.dataSource == null) {  
23.             throw new HibernateException("No local DataSource found for configuration - " +  
24.                 "dataSource property must be set on LocalSessionFactoryBean");  
25.         }  
26.         this.dataSourceToUse = getDataSourceToUse(this.dataSource);  
27.     }  
28.   
29.     protected DataSource getDataSourceToUse(DataSource originalDataSource) {  
30.         return originalDataSource;  
31.     }  
32.   
33.     public DataSource getDataSource() {  
34.         return dataSource;  
35.     }  
36.   
37.     public Connection getConnection() throws SQLException {  
38.         try {  
39.             return this.dataSourceToUse.getConnection();  
40.         }  
41.         catch (SQLException ex) {  
42.             JDBCExceptionReporter.logExceptions(ex);  
43.             throw ex;  
44.         }  
45.     }  
46.   
47.     public void closeConnection(Connection con) throws SQLException {  
48.         try {  
49.             con.close();  
50.         }  
51.         catch (SQLException ex) {  
52.             JDBCExceptionReporter.logExceptions(ex);  
53.             throw ex;  
54.         }  
55.     }  
56.   
57.     public void close() {  
58.     }  
59.   
60.     public boolean supportsAggressiveRelease() {  
61.         return false;  
62.     }  
63.   
64. }  

如果你对比其与Spring提供的同名类中的代码，相差不大。
下面来看看配置文件，我把Bean的初始化放在bean.xml中：

xml 代码

 

1. <!-- 本地调试使用连接池-->  
2.   <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">  
3.     <property name="driverClassName" value="org.gjt.mm.mysql.Driver" />  
4.     <property name="url" value="jdbc:mysql://localhost:3306/cms" />  
5.     <property name="username" value="root" />  
6.     <property name="password" value="root" />  
7.     <property name="connectionProperties">  
8.       <props>  
9.         <prop key="useUnicode">true</prop>  
10.         <prop key="characterEncoding">GBK</prop>  
11.       </props>  
12.     </property>  
13.   </bean>  
14.    
15.   <!-- 服务实现类定义 -->  
16.   <bean id="sessionFactory" class="wanged.core.persistent.LocalSessionFactoryBean">  
17.     <property name="hibernateProperties">  
18.       <props>  
19.         <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>  
20.         <prop key="hibernate.show_sql">false</prop>  
21.         <prop key="hibernate.cache.use_query_cache">true</prop>  
22.         <prop key="hibernate.jdbc.batch_size">20</prop>  
23.       </props>  
24.     </property>  
25.     <property name="dataSource" ref="dataSource" />  
26.     <property name="entityRegister" ref="entityRegister" />  
27.   </bean>  
28.   
29.   <bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">  
30.     <property name="sessionFactory" ref="sessionFactory" />  
31.   </bean>  

而服务与引用的声明放在osgi-service.xml中：

xml 代码

 

1. <osgi:reference id="entityRegister"  interface="wanged.core.persistent.entity.EntityRegister" cardinality="1..n"/>    
2.   
3. <osgi:service interface="org.hibernate.SessionFactory" ref="sessionFactory" />    
4.   
5. <osgi:service interface="org.springframework.transaction.PlatformTransactionManager" ref="txManager" />    

这里的引用 "实体注册" 服务需要在我们的实体Bundle中实现，现在已经搭好了架子，下一步就需要创建自己的实体Bundle和数据库操作的Bundle。由于这个Blog保存时经常保存不住，需要重写，所以我尽可能的将其划分开来写。

 

有几个问题，想请教一下，当其他任何bundle实现了wanged.core.persistent.entity.EntityRegister接口之后，能否自动更新sessionFactory,而不重启整个应用，