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");
}

}

------------------------来自：向上交流社区----------------------------