Hibernate连接多个数据库

桃扇骨 2022-08-07 01:37 253阅读 0赞

看到网上的资料讲：Hibernate同一个项目，配置多个数据源的文章。因为自己对Hibernate的东西还比较感兴趣，所以收藏一下，以供自己以后用得到。

本文章资料转载于：http://blog.sina.com.cn/s/blog\_49bf8585010004m6.html   (支持原创)

一、             Hibernate访问数据库时加载的过程

对于大多数使用Hibernate的朋友来说，通常使用一下方式来获得Configuration实例： Configuration configure = new Configuration().configure();

在Hibernate中，Configuration是hibernate的入口。在实例化一个Configuration的时候，Hibernate会自动在环境变量（classpath）里面查找Hibernate配置文件hibernate.properties。如果该文件存在，则将该文件的内容加载到一个Properties的实例GLOBAL\_PROPERTIES里面，如果不存在，将打印信息　　hibernate.properties not found；

接下来Hibernate将所有系统环境变量（System.getProperties()）也添加到GLOBAL\_PROPERTIES里面。如果配置文件hibernate.properties存在，系统还会进一步验证这个文件配置的有效性，对于一些已经不支持的配置参数，系统将打印出警告信息。

默认状态下configure()方法会自动在环境变量（classpath）下面寻找Hibernate配置文件hibernate.cfg.xml，如果该文件不存在，系统会打印如下信息并抛出HibernateException异常: hibernate.cfg.xml not found；如果该文件存在，configure()方法会首先访问＜session-factory＞，并获取该元素name的属性，如果name的属性非空，将用这个配置的值来覆盖hibernate.properties的hibernate.session\_factory\_name的配置的值，从这里我们可以看出，hibernate.cfg.xml里面的配置信息可以覆盖hibernate.properties的配置信息。

接下来configure()方法访问＜session-factory＞的子元素，首先将使用所有的＜property＞元素配置的信息来覆盖hibernate.properties里面对应的配置信息。

然后configure()会依次访问以下几个元素的内容

＜mapping＞

＜jcs-class-cache＞

＜jcs-collection-cache＞

＜collection-cache＞

其中＜mapping＞是必不可少的，必须通过配置＜mapping＞，configure()才能访问到我们定义的java对象和关系数据库表的映射文件（hbm.xml），例如：

＜mapping resource="Cat.hbm.xml"/＞

这样configure()方法利用各种资源就创建了一个Configuration实例。对于整个项目来说，如果用一个本地线程来存放这个Configuration实例，那么整个项目只需要实例化一次Configuration对象（注：Configuration实例很花费时间），也就提高了项目的效率。

二、             Hibernate访问多个数据库的配置

**根据以上所述，configure()方法默认是通过访问hibernate.cfg.xml的＜mapping＞元素来加载我们提供的.hbm.xml文件。我们也可以直接指定hbm.xml文件，例如addClass()方法可以直接通过指定class来加载对应的映射文件，hibernate会将提供的class的全名（包括package）自动转化为文件路径，还可以用addFile方法直接指定映射文件。例如：Configuration configurate = new Configuration().addClass(“Book.class”);**

**Configuration configurate = new Configuration().addURL(Configuration.class.getResource ("/Book.hbm.xml"));**

**Configuration config = new Configuration().addFile("/Cat.hbm.xml");**

**这样，如果用xml配置来配置多个数据库的话，那就写多个配置文件。这里假设对应两个数据库（一个是MySQL，一个是SQLServer），我们可以把其xml文件定义为“mysql.cfg.xml”和“sqlserver.cfg.xml”。则用Configuration类获取SessionFactory的代码如下：**

**SessionFactory mysqlFactory = new Configuration().configure("/mysql.cfg.xml").buildSessionFactory();**

**SessionFactory sqlserverFactory = new Configuration().configure("sqlserver.cfg.xml ").buildSessionFactory();**

**同时连接两个数据库实例:**

**问题:连接mssql中的vedio 和bbs数据库**

**解决方案:**

**1.vedio.cfg.xml**

<?xml version='1.0' encoding='UTF-8'?>  
<!DOCTYPE hibernate-configuration PUBLIC  
 "-//Hibernate/Hibernate Configuration DTD 3.0//EN"  
 "[http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd][http_hibernate.sourceforge.net_hibernate-configuration-3.0.dtd]">

<hibernate-configuration>  
<session-factory name="bbs">  
   
 <property name="connection.username">sa</property>  
   
 **<property name="connection.url">  
  jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=vedio;    
 </property>**  
   
 <property name="dialect">  
  org.hibernate.dialect.SQLServerDialect  
 </property>  
   
 <property name="connection.password">sa</property>  
   
 <property name="connection.driver\_class">  
  com.microsoft.jdbc.sqlserver.SQLServerDriver  
 </property>  
   
 <property name="show\_sql">true</property>

<mapping resource="vedio/Managers.hbm.xml" />

</session-factory>  
</hibernate-configuration>

2.**bbs.cfg.xml**

<hibernate-configuration>  
<session-factory name="bbs">  
   
 <property name="connection.username">sa</property>  
   
 **<property name="connection.url">  
  jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=bbs;    
 </property>**  
   
 <property name="dialect">  
  org.hibernate.dialect.SQLServerDialect  
 </property>  
   
 <property name="connection.password">sa</property>  
   
 <property name="connection.driver\_class">  
  com.microsoft.jdbc.sqlserver.SQLServerDriver  
 </property>  
   
 <property name="show\_sql">true</property>

<mapping resource="bbs/Board.hbm.xml" />  
 <mapping resource="bbs/BBSUser.hbm.xml" />  
 <mapping resource="bbs/BBSManager.hbm.xml" />  
 <mapping resource="bbs/Image.hbm.xml" />  
 <mapping resource="bbs/Upfile.hbm.xml" />  
 <mapping resource="bbs/Post.hbm.xml" />  
 <mapping resource="bbs/BestPost.hbm.xml" />  
 <mapping resource="bbs/User.hbm.xml" />  
 <mapping resource="bbs/Groups.hbm.xml" />  
 <mapping resource="bbs/Help.hbm.xml" />  
 <mapping resource="bbs/Note.hbm.xml" />  
 <mapping resource="vedio/Managers.hbm.xml" />

</session-factory>  
</hibernate-configuration>

3.**VedioHibernateUTL.java**

package vedio;

import org.hibernate.\*;  
import org.hibernate.cfg.\*;

public class HibernateUtil \{  
   
 public static final SessionFactory sessionFactory;  
  static \{  
   try\{  
    **sessionFactory=new Configuration().configure("/vedio.cfg.xml").buildSessionFactory();**  
      
   \}catch(Throwable ex) \{  
      
    throw new ExceptionInInitializerError(ex);  
   \}  
  \}  
   
 public static final ThreadLocal<Session> session =new ThreadLocal<Session>();  
   
 //create session  
 public static Session currentSession() throws HibernateException \{  
  Session s= session.get();  
  if(s==null||!s.isOpen()) \{  
   s=sessionFactory.openSession();  
   session.set(s);  
  \}  
  return s;  
 \}  
   
 //close session  
 public static void closeSession() throws HibernateException \{  
  Session s=session.get();  
  session.set(null);  
  if(s!=null) \{  
   s.close();  
  \}  
    
 \}  
\}

4.**BbsHibernateUTL.java**

package bbs;

import org.hibernate.\*;  
import org.hibernate.cfg.\*;

public class HibernateUtil \{  
   
 public static final SessionFactory sessionFactory;  
  static \{  
   try\{  
    **sessionFactory=new Configuration().configure("/bbs.cfg.xml").buildSessionFactory();**  
      
   \}catch(Throwable ex) \{  
      
    throw new ExceptionInInitializerError(ex);  
   \}  
  \}  
   
 public static final ThreadLocal<Session> session =new ThreadLocal<Session>();  
   
 //create session  
 public static Session currentSession() throws HibernateException \{  
  Session s= session.get();  
  if(s==null||!s.isOpen()) \{  
   s=sessionFactory.openSession();  
   session.set(s);  
  \}  
  return s;  
 \}  
   
 //close session  
 public static void closeSession() throws HibernateException \{  
  Session s=session.get();  
  session.set(null);  
  if(s!=null) \{  
   s.close();  
  \}  
    
 \}  
\}

**然后写相应的 表名．hbm.xml文件**

**总结一下：一个数据源对应一个.cfg.xml文件,一个HibernateUTL.java,对应多个 表名.hbm.xml**

**如果你用spring，多数据库就更简单了，像这段代码可以完成所有配置：**

<beans>

<value>jdbc:mysql://localhost:3306/test</value>

</property>

<value>org.gjt.mm.mysql.Driver</value>

</property>

</property>

</property>

</bean>

</property>