1. mysql 数据库映射:
A.driverClassName=com.mysql.jdbc.Driver
A.url=jdbc:mysql://172.20.7.51:3308/blog
A.username=trappuser
A.password=Opera1!
B.driverClassName=com.mysql.jdbc.Driver
B.url=jdbc:mysql://localhost:3306/wedding
B.username=root
B.password=opera
上面定义的A、B为两个mysql instance的缩写。
2. 存储过程与mysql instance的映射关系:
SP_Get_User=A
GetStocks=B
定义两个模拟存储过程,第一个数据库“SP_Get_User“是在数据库A下面,第二个数据库”GetStocks“是在数据库B下面。
3. 建立自定义的sessionFactory
3.1 xml配置的datasource及sessionFactory如下:
<bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="dataSource">
<property name="driverClassName" value="${database.driverClassName}"/>
<property name="url" value="${database.url}"/>
<property name="username" value="${database.username}"/>
<property name="password" value="${database.password}"/>
</bean>
<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
<property name="packagesToScan" value="com.xx.assetcommander">
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
</props>
</property>
</bean>
此处我们定义的sessionFactory的类型为LocalSessionFactoryBean,它是一个工厂对象,与我们再需要的 SessionFactory不是一回事,我们需要的sessionfactory是org.hibernate.SessionFactory,这个对象可以被第一个sessionFactory的getObject()方法生成。
3.2 由于我们连接的是多个mysql instance, 不方便在xml中配置多个datasource和多个sessionFactory,故可以通过纯java的形式开发,可以使用map来存储存储过程与mysql database的关系,将存储过程的名字和数据库建议关系,这样通过存储过程的名称就能得到数据库的缩写名,通过数据库的缩写名能够找到对应的mysql instance,使用纯java开发的过程类似于xml配置,如下:
ds.setDriverClassName(getDriver())
ds.setUrl(getUrl())
ds.setUsername(getUsername())
ds.setPassword(getPassword())
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean()
sessionFactory.setDataSource(ds)
sessionFactory.setPackagesToScan("com.xx.assetcommander")
Properties params = new Properties()
params.setProperty("hibernate.dialect",
"org.hibernate.dialect.MySQLDialect")
params.setProperty("hibernate.show_sql", "true")
sessionFactory.setHibernateProperties(params)
当我们获得可以使用的LocalSessionFactoryBean时候,在调用getObject()获得SessionFactory之前,必须要调用afterPropertiesSet()方法,否则得到的sessionFactory为空。
public Session getDsBySp(String spName) throws IOException {
//get the corresponding mysql database shortname by sp name
String dbName = getDbForSP(str)
//get the corresponding mysql instance connection by mysql database shortname
LocalSessionFactoryBean fB = getDsByDb(dbName)
// don't forget this line or null will be returned when you call getObject() method.
fB.afterPropertiesSet()
return fB.getObject().openSession()
}
注:在tomcat启动时,如果没有配置任何datasource,会出现如下错误:
org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type [javax.persistence.EntityManagerFactory] is defined
故需要配置默认的datasource.
这种方式需要做到不同的数据库instance直接业务的完全独立,不可以出现跨数据库的表join,否则处理难度会增加。
还有就是对于多数据库直接的事务管理如何去处理?
由于业务需要连接多个数据源,在进行配置的过程中遇到了一些坑,在此做一下记录和分享。jdbc.properties文件中多个数据源的基本信息:
在applicationContext.xml文件中对数据源进行配置:
在applicationContext.xml文件中配置mybatisSqlSessionFactoryBean:
在applicationContext.xml文件中配置SqlSessionTemplate:
在applicationContext.xml文件中配置mybatis mapper接口,扫描所有dao:
如果是按照以上的配置的,应该是可以成功的。
org.apache.ibatis.binding.BindingException: Invalid bound statement (not found)错误
具体报错信息:
可以看出有2个会发生该异常的情况:
mappedStatements为{} (跟踪debug发现,我出现这里为空)
containsKey(statementName),没有找到
mappedStatements为空的原因是由于在spring容器启动时,会解析spring配置文件,这时将去加载资源文件,解析并以key,value的形式缓存在mappedStatements中。而在实际情况下,发现打包时*Mapper.xml并没有自动复制到class输出目录的mapper类包下。从而导致mappedStatements为空。
Mapper interface和xml文件的定义对应不上,需要检查包名,namespace,函数名称等能否对应上。
按以下步骤一一执行:
1、检查xml文件所在的package名称是否和interface对应的package名称一一对应
2、检查xml文件的namespace是否和xml文件的package名称一一对应
3、检查函数名称能否对应上
4、去掉xml文件中的中文注释
5、随意在xml文件中加一个空格或者空行然后保存
6、路径问题
在使用IDEA开发时,如果打包时*Mapper.xml没有自动复制到class输出目录的mapper类包下,则需要在pom文件中添加mybatis加载配置文件的配置!
如下:
通过在pom文件中添加mybatis加载配置文件,完美解决遇到的问题了。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)