用 SSH 連線兩個資料庫
spring2+struts2+hibernate3實現連線兩個資料庫
jdbc.properties檔案,寫資料庫的連線資訊
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://127.0.0.1:3306/destoon?useUnicode=true&characterEncoding=utf-8
jdbc.username=root
jdbc.password=123456
sql.driverClassName=net.sourceforge.jtds.jdbc.Driver
sql.url=jdbc:jtds:sqlserver://127.0.0.1:1433/business
sql.username=sa
sql.password=sa
cpool.minPoolSize=1
cpool.maxPoolSize=5
cpool.maxIdleTime=7200
cpool.maxIdleTimeExcessConnections=18000
cpool.acquireIncrement=1
applicationContext.xml檔案配置兩個資料來源,兩個SessionFactory分別對應相應的資料來源
<description>Spring公共配置</description>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
<property name="ignoreResourceNotFound" value="true" />
<property name="locations">
<list>
<value>classpath*:/jdbc.properties</value>
</list>
</property>
</bean>
<bean id="sqlDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${sql.driverClassName}" />
<property name="jdbcUrl" value="${sql.url}" />
<property name="user" value="${sql.username}" />
<property name="password" value="${sql.password}" />
<property name="autoCommitOnClose" value="true"/>
<property name="initialPoolSize" value="${cpool.minPoolSize}"/>
<property name="minPoolSize" value="${cpool.minPoolSize}"/>
<property name="maxPoolSize" value="${cpool.maxPoolSize}"/>
<property name="maxIdleTime" value="${cpool.maxIdleTime}"/>
<property name="acquireIncrement" value="${cpool.acquireIncrement}"/>
<property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}"/>
</bean>
<!-- SqlServer Hibernate配置 -->
<bean id="sqlSessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="sqlDataSource" />
<property name="namingStrategy">
<bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
</property>
<!-- -->
<property name="mappingLocations">
<list>
<value>classpath*:/com/search/bean/*.hbm.xml</value>
</list>
</property>
<property name="hibernateProperties">
<value>
hibernate.dialect=org.hibernate.dialect.SQLServerDialect
hibernate.show_sql=true
hibernate.format_sql=false
hibernate.query.substitutions=true 1, false 0
hibernate.jdbc.batch_size=20
hibernate.cache.provider_class=org.hibernate.cache.EhCacheProvider
hibernate.cache.provider_configuration_file_resource_path=/ehcache-hibernate.xml
</value>
</property>
</bean>
<!-- Mysql資料來源配置-->
<bean id="mysqlDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driverClassName}" />
<property name="jdbcUrl" value="${jdbc.url}" />
<property name="user" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="autoCommitOnClose" value="true"/>
<property name="initialPoolSize" value="${cpool.minPoolSize}"/>
<property name="minPoolSize" value="${cpool.minPoolSize}"/>
<property name="maxPoolSize" value="${cpool.maxPoolSize}"/>
<property name="maxIdleTime" value="${cpool.maxIdleTime}"/>
<property name="acquireIncrement" value="${cpool.acquireIncrement}"/>
<property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}"/>
</bean>
<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="mysqlDataSource" />
<property name="namingStrategy">
<bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
</property>
<property name="mappingLocations">
<list>
<value>classpath*:/com/search/bean/*.hbm.xml</value>
</list>
</property>
<property name="hibernateProperties">
<value>
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
hibernate.show_sql=true
hibernate.format_sql=false
hibernate.query.substitutions=true 1, false 0
hibernate.jdbc.batch_size=20
hibernate.cache.provider_class=org.hibernate.cache.EhCacheProvider
hibernate.cache.provider_configuration_file_resource_path=/ehcache-hibernate.xml
</value>
</property>
</bean>
DAO類,提供兩個sessionFactory,根據資料庫關鍵字而連線不同的資料庫
@Repository
public abstract class BaseDaoImpl<T extends Serializable> implements BaseDao<T> {
protected Logger log = LoggerFactory.getLogger(getClass());
public static final String SQLSERVER="sqlserver";
public static final String MYSQL="mysql";
protected static SessionFactory sessionFactory;
@Autowired
@Resource(name="sessionFactory")
public void setSessionFactory(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
public Session getSession() {
return sessionFactory.getCurrentSession();
}
protected static SessionFactory sqlSessionFactory;
@Autowired
@Resource(name="sqlSessionFactory")
public void setSqlSessionFactory(SessionFactory sqlSessionFactory) {
this.sqlSessionFactory = sqlSessionFactory;
}
public Session getSqlSession(String database) {
if (database.equals(SQLSERVER)) {
return sqlSessionFactory.getCurrentSession();
}else if (database.equals(MYSQL)) {
return sessionFactory.getCurrentSession();
}
return null;
}
@SuppressWarnings("unchecked")
public List searchListBySQL(String sql,String database) {
return getSqlSession(database).createSQLQuery(sql).list();
}
}
DAO實現類
@Repository
public class ProductDaoImpl extends JeeCoreDaoImpl<Product> implements ProductDao {
public List getAllProducts(){
String hql="select * from table;
return searchListBySQL(hql,"mysql");
}
}
第二種方法
一、(在src下)寫兩個Hibernate.cfg.xml檔案:
hbn-mysql.cfg.xml和hbn-sqlserver.cfg.xml
二、分別解析上面的兩個.cfg.xml檔案建兩個sessionFactory,
三、使用session時哪個sessionFactory開啟的session就能訪問哪個資料庫。
詳細步驟:-----------------------------------------
一、(在src下)建兩個Hibernate.cfg.xml檔案
(1.)hbn-mysql.cfg.xml的內容:
- <?xml version='1.0' encoding='utf-8'?>
- <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD//EN"
- "http://hibernate.sourceforge.net/hibernate-configuration-2.0.dtd">
- <!--hibernate配置檔案,定義所使用的MySQL資料庫的配置資訊 -->
- <hibernate-configuration>
- <session-factory>
- <property name="myeclipse.connection.profile">mysql</property>
- <property name="connection.url">jdbc:mysql://localhost:3306/dataSource?characterEncoding=utf-8</property>
- <property name="connection.driver_class">com.mysql.jdbc.Driver</property><property name="connection.username">root</property>
- <property name="connection.password">password</property>
- <property name="dialect">org.hibernate.dialect.MySQLDialect</property>
- <mapping
- resource="com/fourstar/starTransport/daomain/orderIdStatus.hbm.xml" />
- <mapping
- resource="com/fourstar/starTransport/daomain/freightCompany.hbm.xml" />
- </session-factory>
- </hibernate-configuration>
(2.)hbn-sqlserver.cfg.xml的內容:
Java程式碼
- <?xml version="1.0"?>
- <!DOCTYPE hibernate-configuration PUBLIC
- "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
- "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
- <hibernate-configuration>
- <session-factory>
- <property name="show_sql">true</property>
- <property name="connection.driver_class">
- com.microsoft.sqlserver.jdbc.SQLServerDriver
- </property>
- <property name="connection.url">
- jdbc:sqlserver://192.168.2.16:1433; DatabaseName=DB
- </property>
- <property name="connection.username">root</property>
- <property name="connection.password">password</property>
- <property name="connection.isolation">2</property>
- <property name="dialect">
- org.hibernate.dialect.SQLServerDialect
- </property>
- <mapping
- resource="com/fourstar/starTransport/daomain/transactions.hbm.xml" />
- <mapping
- resource="com/fourstar/starTransport/daomain/transactionDetail.hbm.xml" />
- </session-factory>
- </hibernate-configuration>
二、建一個類(HbnUtil)用於連線資料庫(用於建立sessionFactory和openSession()靜態方法)
Java程式碼
- package com.fourstar.starTransport.dao.util;
- import org.hibernate.Session;
- import org.hibernate.SessionFactory;
- import org.hibernate.cfg.Configuration;
- public class HbnUtil {// 根據hibernate.cfg.xml建立一個靜態sessionFactory
- private static SessionFactory sf;
- private static SessionFactory MSsf;
- static {
- sf = new Configuration().configure("/hbn-sqlserver.cfg.xml")
- .buildSessionFactory();
- MSsf = new Configuration().configure("/hbn-mysql.cfg.xml")
- .buildSessionFactory();
- }
- /**根據DBName判斷呼叫哪個sessionFactory的openSession()方法*/
- public static Session getSessionByDB(String DBName) {
- Session s = null;
- if (DBName == "mysql") {
- if (!MSsf.isClosed())
- s = MSsf.openSession();
- } else if (DBName == "sqlserver") {
- if (!sf.isClosed())
- s = sf.openSession();
- } else {
- System.out.println("錯誤的 DBName!");
- }
- return s;
- }
- /**根據DBName判斷呼叫哪個sessionFactory的close()方法*/
- public static void closeSessionFactoryByDB(String DBName) {
- if (DBName == "mysql") {
- if (!MSsf.isClosed()) {
- MSsf.close();
- }
- } else if (DBName == "sqlserver") {
- if (!sf.isClosed()) {
- sf.close();
- }
- } else {
- System.out.println("錯誤的 DBName!");
- }
- }
- }
三、測試:使用getSessionByDB(String DBName)獲得不同資料庫的session
Java程式碼
- package com.fourstar.starTransport.dao.util;
- import org.hibernate.HibernateException;
- import org.hibernate.Query;
- import org.hibernate.Session;
- public class Test1{
- public static void main(String[] args) {
- String DBName = "mysql";
- // String DBName = "sqlservrer";
- Session s = HbnUtil.getSessionByDB(DBName);
- try {
- String sql = " from freightCompany";
- Query query = s.createQuery(sql);
- } catch (HibernateException e) {
- e.printStackTrace();
- }finally{
- s.close();
- HbnUtil.closeSessionFactoryByDB(DBName);
- }
- }
- }
————————————————————————————————————————
————————————————————————————————————————
做完這些之後我再介紹下hibernate連線兩個資料庫的原理:
——————————————————————————————————————
一、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存在,系統還會進一步驗證這個檔案配置的有效性,對於一些已經不支援的配置引數,系統將打印出警告資訊。
相關推薦
用 SSH 連線兩個資料庫
spring2+struts2+hibernate3實現連線兩個資料庫 jdbc.properties檔案,寫資料庫的連線資訊 jdbc.driverClassName=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://127.
ruby on rails同時連線兩個資料庫
使用 ruby on rails 做專案開發時,有時候需要同時連線兩個資料庫,沒有這樣做過的開發人員可能有點困難,其實方法很簡單,在這裡簡單介紹一下,希望能給大家帶來幫助。 本次使用的資料庫分別為 Mysql DB 和 Oracle DB (兩個資料庫可以為同
SpringMVC配置雙資料來源,一個java專案同時連線兩個資料庫
資料來源在配置檔案中的配置 [java] view plain copy print? <pre name=“code”class=“java”><?xml version=“1.0” encoding=“UTF-8”?> <beans xml
DbForge Data Compare for SQL Server入門教程:連線到資料庫、快速同步兩個資料庫
在連線到資料庫之前,必須建立伺服器連線。 要建立連線: 1. 在資料庫選單上,單擊新建連線。將開啟“ 資料庫連線屬性” 對話方塊。 2. 在“ 伺服器” 組合框中,單擊“ <瀏覽...>” 。將開啟“ 瀏覽伺服器” 視窗。 3. 在“ 本地伺服器” 選
如何使用springboot同時連線兩個不同的資料來源操縱資料庫
建立一個springboot專案,在pom.xml檔案中匯入一些基本的依賴並匯入需要連線的兩個資料庫postgresql,和sqlserver的依賴。在application-dev.properties配置檔案中配置兩個資料庫的連線資訊。
windows用ssh連線linux(資料庫)碰到的問題和解決方法
1.window下面用ssh連線linux 必須在linux中安裝ssh伺服器 安裝命令:sudo apt-get install openssh-server
SSM專案實現連線兩個mysql資料庫
最近做專案需要用到另一個數據庫的內容,多方查詢終於實現了功能。 我們都知道,在SSM框架中,我們在applicationContext.xml配置檔案中新增資料來源就可以實現資料庫增刪改查,但是隻能連線一個數據庫,這個時候我們就要從spring提供的原始碼下手看看有沒有有關
正則表示式中的邏輯運算子或(怎麼用邏輯運算子或連線兩個正則表示式)
今天使用正則表示式是遇到一個問題, 磨了半天, 發現犯了個低階錯誤, 因此記錄下來加深印象 問題描述: 我需要把 ^drawable(-[a-zA-Z0-9]+)*$ 和 ^mipmap(-[a-zA-Z0-9]+)*$ 這兩個正則表示式用或的關係連線起來 我嘗試了
用SSH時幾個增刪查改操作後跳轉不回列表頁面(原因在連線池)
一開始在配置hibernate.cfg.xml時我忘了註釋掉下面連線池的程式碼,所以在兩個任意增刪查改操作後便不能跳轉回頁面,註釋掉後就可以了。不過這些小細節以後要注意一下就好<property name="hibernate.connection.provider_c
Spring+Hibernate+Proxool兩個資料庫連線池配置
1,配置兩個proxool.xml檔案,proxool.first.xml配置 <proxool> <alias>Proxool.First</alias> <proxool> <ali
用python比較兩個文件中內容的不同之處, 並輸出行號和內容.
exist file diff pre ffline += == list cmp 代碼部分: ‘‘‘cmpfile.py - 比對兩個文件, 如果有不同之處, 打印內容和行號‘‘‘ import os class cmpFile: def __init__(
ssh的兩個小知識
試圖 display 處理 ble 執行 一分鐘 小知識 keep 服務 ssh的兩個小知識 1、 在ssh客戶端啟動遠程服務器的圖形界面程序。 如果你試圖在ssh客戶端運行遠程服務器的一個圖形界面程序,比如說執行firefox,此時可能會提示,can not conn
update連線兩個表
1、update 連線兩個表 UPDATE ask_way a SET way_addr = ( SELECT q.ans_txt FROM pos_ques q WHERE a.hos_id = q.hos_id AND a.w
mybatis連線兩個資料來源
1.db.properties配置檔案設定 driver:com.mysql.jdbc.Driverf_url:jdbc:mysql://**:3306/**?useUnicode=true&characterEncoding=UTF-8&am
mysql比對兩個資料庫表結構的方法
分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識,造福人民,實現我們中華民族偉大復興!  
當兩個資料庫找不到直接的唯一值
遇到問題: CRM資料庫和PMS資料庫找不到唯一值 具體情況: CRM新上的HAOKE產品線,需要找到在PMS中找到該hotel以前的產品線, 但是CRM上的酒店ID與PMS id 號不一致; 並且酒店名稱也不是完全相同的; CW號只能查現在的合同以及現在的產品線 所以不能用CW號。 但是就
如何在電腦上連線兩個 Bose 藍芽音箱
轉自 https://www.bose.cn/zh_cn/support/article/pairing-multiple-speakers-together.html 立體聲和派對模式 適用於: SoundLink Revolve
mysql update語句set中用and條件連線兩個操作
原來的資料如下 執行的SQL語句如下 update sys_area set create_by = '2' and update_by = '2' where id = '1'; 執行結果為 原因 正常情況update的set中應該用逗號(,)連線,但是上面用了邏
實現兩個資料庫之間的資料同步
不同伺服器資料庫之間的資料操作 --建立連結伺服器 exec sp_addlinkedserver 'ITSV ', ' ', 'SQLOLEDB ', '遠
SSH連線伺服器PG資料庫並提取資料
利用SSH連線伺服器並從伺服器上的PG資料庫提取資料,儲存為excel檔案。 Python程式碼如下: ## connectted to postgresql DB in the local PC import psycopg2 import paramiko from sshtunnel