Hibernate 动态平添数据库（数据库信息不固定）

Hibernate 动态添加数据库（数据库信息不固定）
  上篇文章利用spring来连接多个数据库并进行切换数据源，此时，数据库的信息都已经固定，不能更改；在某些项目中，我们要在程序中，动态的添加数据库连接，数据库的信息不确定，需要程序给出。下面是用Hibernate动态连接数据库的实例（项目环境：SSH（利用Hibernate注解））前提是：两个数据库中的数据结构一致：
public class HibernateConfiguration extends AnnotationConfiguration {
public HibernateConfiguration() {
super();
}

public void reset() {
super.reset();
}

public HibernateConfiguration(String dialect, String driverClass,
String ipAddress, String port, String dataBaseName,
String username, String password) {
String connection_url = "";
if (dialect.indexOf("MySQL") > -1) {
connection_url = "jdbc:mysql://" + ipAddress + "/" + dataBaseName;
} else if (dialect.indexOf("SQLServer") > -1) {
connection_url = "jdbc:sqlserver://" + ipAddress + ":" + port
+ ";DataBaseName=" + dataBaseName;
} else if (dialect.indexOf("Oracle") > -1) {
connection_url = "jdbc:oracle:thin:@" + ipAddress + ":" + port
+ ":" + dataBaseName;
} else {
throw new HibernateException("The dialect was not allowed.==fd=="
+ dialect);
}

super.setProperty("hibernate.dialect", dialect);
super.setProperty("hibernate.connection.url", connection_url);
super.setProperty("hibernate.connection.driver_class", driverClass);
super.setProperty("hibernate.connection.username", username);
super.setProperty("hibernate.connection.password", password);
}

public HibernateConfiguration(String dialect, String driverClass,
String ipAddress, String port, String dataBaseName,
String username, String password, String schema, String catalog) {
String connection_url = "";
if (dialect.indexOf("MySQL") > -1) {
connection_url = "jdbc:mysql://" + ipAddress + "/" + dataBaseName;
} else if (dialect.indexOf("SQLServer") > -1) {
connection_url = "jdbc:sqlserver://" + ipAddress + ":" + port
+ ";DataBaseName=" + dataBaseName;
} else if (dialect.indexOf("Oracle") > -1) {
connection_url = "jdbc:oracle:thin:@" + ipAddress + ":" + port
+ ":" + dataBaseName;
} else {
throw new HibernateException("The dialect was not allowed.==fd=="
+ dialect);
}
super.setProperty("hibernate.dialect", dialect);
super.setProperty("hibernate.connection.url", connection_url);
super.setProperty("hibernate.connection.driver_class", driverClass);
super.setProperty("hibernate.connection.username", username);
super.setProperty("hibernate.connection.password", password);
super.setProperty("hibernate.default_schema", schema);
super.setProperty("hibernate.default_catalog", catalog);
super.setProperty("hibernate.show_sql", "true");
}
}

public class TempSessionFactory {
public static HibernateConfiguration configuration = new HibernateConfiguration();
public static SessionFactory sessionFactory;
public static void reflashSessionFactory(
HibernateConfiguration tempConfiguration) {
try {
if (tempConfiguration.getProperty("hibernate.dialect").equals(
configuration.getProperty("hibernate.dialect"))
&& tempConfiguration
.getProperty("hibernate.connection.url")
.equalsIgnoreCase(
configuration
.getProperty("hibernate.connection.url"))
&& tempConfiguration
.getProperty("hibernate.connection.username")
.equals(configuration
.getProperty("hibernate.connection.username"))
&& tempConfiguration
.getProperty("hibernate.connection.password")
.equals(configuration
.getProperty("hibernate.connection.password"))) {

System.out
.println("%%%% TempSessionFactory is created aready!!-fd %%%%");
} else {
configuration.reset();
configuration = tempConfiguration;
sessionFactory = configuration.buildSessionFactory();
System.out
.println("%%%% TempSessionFactory is reflashed here!!-fd %%%%");
}
} catch (Exception e) {
System.err.println("%%%% Error Reflashing TempSessionFactory %%%%");
e.printStackTrace();
}
}
public static Session getSession() {
return sessionFactory.openSession();
}
}

//执行
/***
* 动态连接一个数据库
*/
LgispTerminal ter=(LgispTerminal) this.lgispTerminalService.getById(1);
System.out.println("-----------------terIp="+ter.getTerminalIntip()+"-----------");
HibernateConfiguration dyConfiguration=new HibernateConfiguration("org.hibernate.dialect.MySQLDialect","com.mysql.jdbc.Driver",ter.getTerminalIntip(),"3306","lgisp","root","root");
dyConfiguration.addAnnotatedClass(LgispOrg.class);
TempSessionFactory.reflashSessionFactory(dyConfiguration);
Session session1=TempSessionFactory.getSession();
if(session1!=null){
List listq=session1.createSQLQuery("select * from lgisp_org").list();
                     System.out.println("---sql----listq.size="+listq.size()+"----------");
                     List hqlList=session1.createQuery(" from LgispOrg org").list();
                     System.out.println("---------hqlList.size()="+hqlList.size()+"----------");
                     Transaction tx=session1.beginTransaction();
LgispOrg org=(LgispOrg) session1.get(LgispOrg.class,33);
System.out.println("-----org00="+org.getOrgName()+"----------------");
org.setOrgName("hibernate Org Add");
// session1.delete(org);
session1.saveOrUpdate(org);
tx.commit();
session1.close();
}else{
System.out.println("------session 为空--------------");
}