Spring+Hibernate双数据源测试Mysql集群读写分离（转自http://blog.csdn.net/hzw2312/article/details/9083519）

进行测试！环境就是SH框架、当然这只是一个简单的测试！

准备环境就是Spring框架跟Hibernate框架的整合！

然后在Spring配置文件中配置两个数据源、这里我采用的是从c3po数据源配置：

注：配置文件中的url里面要加"&"符号的话得这样写"&"

[html]view plaincopyprint?

<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<bean id="dataSourceR" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql:loadbalance://10.11.0.75,172.16.0.202:3306/DB_TEST7?roundRobinLoadBalance=true&characterEncoding=UTF-8"/>
<property name="user" value="TESTUSER"/>
<property name="password" value="TESTPWD"/>
<property name="maxPoolSize" value="20"/>
<property name="minPoolSize" value="1"/>
<property name="initialPoolSize" value="1"/>
<property name="maxIdleTime" value="20"/>
</bean>
<bean id="sessionFactoryR" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSourceR"/>
<property name="mappingResources">
<list>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="show_sql">true</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.jdbc.batch_size">20</prop>
</props>
</property>
</bean>
<bean id="transactionManagerR" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactoryR"/>
</bean>
<bean id="transactionInterceptorR" class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="transactionManagerR"/>
<property name="transactionAttributes">
<props>
<prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>
<bean id="daoR" class="com.boxun.test.dao.impl.daoR" >
<property name="sessionFactory">
<ref bean="sessionFactoryR" />
</property>
</bean>
<bean id="dataSourceW" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql:loadbalance://10.11.2.126:3306/DB_TEST7?roundRobinLoadBalance=true&characterEncoding=UTF-8"/>
<property name="user" value="TESTUSER"/>
<property name="password" value="TESTPWD"/>
<property name="maxPoolSize" value="20"/>
<property name="minPoolSize" value="1"/>
<property name="initialPoolSize" value="1"/>
<property name="maxIdleTime" value="20"/>
</bean>
<bean id="sessionFactoryW" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSourceW"/>
<property name="mappingResources">
<list>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="show_sql">true</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.jdbc.batch_size">20</prop>
</props>
</property>
</bean>
<bean id="transactionManagerW" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactoryW"/>
</bean>
<bean id="transactionInterceptorW" class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="transactionManagerW"/>
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<bean id="daoW" class="com.boxun.test.dao.impl.daoW" >
<property name="sessionFactory">
<ref bean="sessionFactoryW" />
</property>
</bean>
</beans>

读的Dao：

[java]view plaincopyprint?

public class daoR extends HibernateDaoSupport implements IdaoR{
private Query query = null;
public List find(String sql){
query = super.getSession().createSQLQuery(sql);
return query.list();
}
}

写的Dao：

[java]view plaincopyprint?

public class daoW extends HibernateDaoSupport implements IdaoW{
private Query query = null;
public void save(String sql){
Transaction t = super.getSession().beginTransaction();
query = super.getSession().createSQLQuery(sql);
query.executeUpdate();
t.commit();
}
}

测试main方法：

[java]view plaincopyprint?

public class Test {
public static void main(String[] args) {
ApplicationContext context=new FileSystemXmlApplicationContext("/WebRoot/WEB-INF/classes/applicationContext.xml");
IdaoR daor =(IdaoR) context.getBean("daoR");
IdaoW daow =(IdaoW) context.getBean("daoW");
daow.save("insert into city(sname) values('Spring双数据源')");
List list = daor.find("select * from city where sname = 'Spring双数据源'");
for (int i = 0; i < list.size(); i++) {
Object[] obj = (Object[])list.get(i);
System.out.println(obj[0]+" --- "+obj[1]);
}
}
}

输出：

[plain]view plaincopyprint?

log4j:WARN No appenders could be found for logger (org.springframework.context.support.FileSystemXmlApplicationContext).
log4j:WARN Please initialize the log4j system properly.
5 --- Spring双数据源

测试成功！！！

Spring+Hibernate双数据源测试Mysql集群读写分离（转自http://blog.csdn.net/hzw2312/article/details/9083519）相关推荐

使用mysql-proxy 快速实现mysql 集群读写分离
使用mysql-proxy 快速实现mysql 集群读写分离 2011-12-29 17:03 目前较为常见的mysql读写分离分为两种: 1. 基于程序代码内部实现:在代码中对select操作分发 ...
Mysql分析-profile详解（转http://blog.csdn.net/ty_hf/article/details/54895026）
一.前言当我们要对某一条sql的性能进行分析时,可以使用它. Profiling是从 mysql5.0.3版本以后才开放的. 启动profile之后,所有查询包括错误的语句都会记录在内. 关闭会话 ...
spring + hibernate + 双数据源动态（或手动）切换
1. 定时检查数据库连接是否可用(手动切换) 昨天生产库一台装有数据库的服务器关机了.虽然另一台服务器上还有服务,但是共用的一个数据库.所以...主服务器挂了另一台也没啥用. 所有为避免再次出 ...
浅谈高性能数据库集群——读写分离
作者陈彩华贝聊Java后端工程师文章转载交流请联系 caison@aliyun.com 复制代码最近学习了阿里资深技术专家李运华的架构设计关于读写分离的教程,颇有收获,总结一下. 本文主要介绍 ...
浅谈高性能数据库集群 —— 读写分离
1. 读写分离概述 2. 适用场景 3. 引入的系统复杂度问题最近学习了阿里资深技术专家李运华的架构设计关于读写分离的教程,颇有收获,总结一下. 本文主要介绍高性能数据库集群读写分离相关理论,基本架 ...
数据采集之解析Mysql的binlog日志发送至Kafka实时消费（转：https://blog.csdn.net/liguohuabigdata/article/details/79472777）
本文采用Maxwell来实现实时解析mysql的binlog日志发送至kafka 1.开启mysql binlog 环境中mysql是docker容器,所以需要进入容器修改mysql配置.docker ...
MySQL集群系列2：通过keepalived实现双主集群读写分离
在上一节基础上,通过添加keepalived实现读写分离. 首先关闭防火墙安装keepalived keepalived 2台机器都要安装 rpm -q openssl kernel-devel y ...
Spring Batch并发加分区加集群读写数据库的完美优化方案 (下）
今天我们会介绍如何使用Spring Batch的分片技术实现定时任务的集群处理. 背景介绍本篇文章为上一篇文章Spring Batch并发加分区读取数据库的完美优化方案的续集,上一篇文章我们介绍了通 ...
程序员修神之路--略懂数据库集群读写分离而已
" 灵魂拷问: 解决数据库读写瓶颈有哪些解决方案呢? 这些方案解决了什么问题呢? 这些方案有那些优势和劣势呢? 一个可以抵抗高并发流量系统的背后必定有一个高性能的数据库集群,就像每一个成功的 ...

Spring+Hibernate双数据源测试Mysql集群读写分离（转自http://blog.csdn.net/hzw2312/article/details/9083519）

Spring+Hibernate双数据源测试Mysql集群读写分离（转自http://blog.csdn.net/hzw2312/article/details/9083519）相关推荐

最新文章

热门文章