这里,首先想说的是,现在的web应用,处理的数据对象,有结构化的,也有非结构化的。同时存在。但是在spring-boot操作数据库的时候,若是在properties文件中配置数据源的信息,通过默认配置加载数据源的话,往往只会启动一个。

 

我出于想弄清如何配置数据源的目的,在这里demo一个配置两个数据源的例子。分别是mysql和mongo。mysql的持久化采用的是mybatis。

 

mongo的操作比较简单,直接贴上配置数据库的代码:

spring-boot支持双数据源mysql+mongo
 1 package com.shihuc.dbconn.sourceconfig.mongo;
 2 
 3 import java.util.Arrays;
 4 
 5 import org.springframework.beans.factory.annotation.Value;
 6 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 7 import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration;
 8 import org.springframework.boot.autoconfigure.mongo.MongoDataAutoConfiguration;
 9 import org.springframework.context.annotation.Bean;
10 import org.springframework.context.annotation.ComponentScan;
11 import org.springframework.context.annotation.Configuration;
12 import org.springframework.data.mongodb.config.AbstractMongoConfiguration;
13 import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
14 
15 import com.mongodb.Mongo;
16 import com.mongodb.MongoClient;
17 import com.mongodb.MongoCredential;
18 import com.mongodb.ServerAddress;
19 import com.mongodb.WriteConcern;
20 
21 @Configuration
22 @EnableAutoConfiguration(exclude={MongoAutoConfiguration.class, MongoDataAutoConfiguration.class})
23 @ComponentScan
24 @EnableMongoRepositories
25 public class MongoDataSourceConfig extends AbstractMongoConfiguration{
26 
27     @Value("${mongo.database}")
28     private String dbname;
29     
30     @Value("${mongo.host}")
31     private String dbhost;
32     
33     @Value("${mongo.port}")
34     private String dbport;
35     
36     @Value("${mongo.username}")
37     private String username;
38     
39     @Value("${mongo.password}")
40     private String password;
41     
42     @Override
43     protected String getDatabaseName() {
44         return this.dbname;
45     }
46     
47     public MongoDataSourceConfig(){
48         if(null == dbport || "".equalsIgnoreCase(dbport.trim())){
49             dbport = "27017";
50         }
51     }
52 
53     @Override
54     @Bean(name = "mongods")
55     public Mongo mongo() throws Exception {
56         ServerAddress serverAdress = new  ServerAddress(dbhost, Integer.valueOf(dbport));        
57         MongoCredential credential = MongoCredential.createMongoCRCredential(username, dbname , password.toCharArray());
58         //Do not use new Mongo(), is deprecated.
59         Mongo mongo =  new MongoClient(serverAdress, Arrays.asList(credential));
60         mongo.setWriteConcern(WriteConcern.SAFE);
61         return mongo;
62     }
63 }
spring-boot支持双数据源mysql+mongo

mongo数据库配置继承AbstractMongoConfiguration,在这个过程中,会向spring容器注册一个mongoTemplate,这个很重要,后期操作mongo数据库时,主要靠它。

 

这里重点说下spring-boot和mybatis集成操作mysql的配置和注意事项。

spring-boot支持双数据源mysql+mongo
 1 package com.shihuc.dbconn.sourceconfig.mysql;
 2 
 3 import javax.sql.DataSource;
 4 
 5 import org.springframework.beans.factory.annotation.Value;
 6 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 7 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 8 import org.springframework.context.annotation.Bean;
 9 import org.springframework.context.annotation.Configuration;
10 import org.springframework.jdbc.datasource.DriverManagerDataSource;
11 
12 @Configuration
13 @EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})
14 public class MysqlDataSourceConfig {
15 
16     @Value("${mysql.driver}")
17     private String driver;
18 
19     @Value("${mysql.url}")
20     private String url;
21 
22     @Value("${mysql.username}")
23     private String username;
24 
25     @Value("${mysql.password}")
26     private String password;
27 
28     @Bean(name="mysqlds")
29     public DataSource mysql()
30     {
31         DriverManagerDataSource ds = new DriverManagerDataSource();
32         ds.setDriverClassName(driver);
33         ds.setUrl(url);
34         ds.setUsername(username);
35         ds.setPassword(password);
36         return ds;
37     }
38 }
spring-boot支持双数据源mysql+mongo

这个是datasource的配置,注意,类似mongo的配置,要将自动配置的类给exclude掉。让spring只处理我们希望的数据源。否则会受到classpath下的信息,干扰数据源的配置。

 

另外,就是mybatis的配置。由于spring-boot重点特色是纯java config,所以,这里也采用java配置和注解启用mybatis。

spring-boot支持双数据源mysql+mongo
 1 package com.shihuc.dbconn.sourceconfig.mysql;
 2 
 3 import javax.sql.DataSource;
 4 
 5 import org.apache.ibatis.session.SqlSessionFactory;
 6 import org.mybatis.spring.SqlSessionFactoryBean;
 7 import org.mybatis.spring.annotation.MapperScan;
 8 import org.springframework.beans.factory.annotation.Autowired;
 9 import org.springframework.beans.factory.annotation.Qualifier;
10 import org.springframework.context.annotation.Bean;
11 import org.springframework.context.annotation.Configuration;
12 
13 @Configuration
14 @MapperScan(basePackages = "com.shihuc.dbconn.dao.mysql")
15 public class MysqlMybatisConfig {
16     
17     @Autowired
18     @Qualifier("mysqlds")
19     private DataSource mysqlds;
20     
21     @Bean
22     public SqlSessionFactory sqlSessionFactoryBean() throws Exception {
23         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
24         sessionFactory.setDataSource(mysqlds);
25         return sessionFactory.getObject();
26     }
27 }
spring-boot支持双数据源mysql+mongo

这里,mapperscan主要是为配置JavaBean和持久化对象之间的映射关系设定根路径。在这个例子中,mapper部分,其实就是通过insert,delete,update,select等注解,结合具体的SQL语句实现ORM的关系。看看这里的代码:

spring-boot支持双数据源mysql+mongo
 1 package com.shihuc.dbconn.dao.mysql;
 2 
 3 import org.apache.ibatis.annotations.Insert;
 4 import org.apache.ibatis.annotations.Select;
 5 
 6 import com.shihuc.dbconn.pojo.mysql.MysqlUser;
 7 
 8 public interface IMysqlUser {
 9 
10     @Select("SELECT * FROM user WHERE id = #{userId}")
11     public MysqlUser getUser(int userId);
12 
13     @Insert("insert into user (username, job, age, hometown) values(#{username}, #{job}, #{age}, #{hometown})")
14     public int addUser(MysqlUser user);
15 }
spring-boot支持双数据源mysql+mongo

 

另外,配合这个IMysqlUser使用的MysqlUser的定义也很重要,主要是里面的constructor函数,通常,添加数据,比如上面的addUser操作,是要创建一个POJO的对象,为了方便,一般都会创建一个带参数的构造函数,注意,必须也同时创建一个无参数的构造函数,否则,在做查询操作,比如上面的getUser时,会出现下面的错误:

spring-boot支持双数据源mysql+mongo
 1   .   ____          _            __ _ _
 2  /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
 3 ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 4  \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
 5   '  |____| .__|_| |_|_| |_\__, | / / / /
 6  =========|_|==============|___/=/_/_/_/
 7  :: Spring Boot ::        (v1.2.7.RELEASE)
 8 
 9 2016-01-29 15:01:07.930  INFO 30880 --- [           main] com.shihuc.dbconn.DbConnApp              : Starting DbConnApp on CloudGame with PID 30880 (/home/webWps/dbconn/target/classes started by root in /home/webWps/dbconn)
10 2016-01-29 15:01:07.997  INFO 30880 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@a85aa40: startup date [Fri Jan 29 15:01:07 CST 2016]; root of context hierarchy
11 2016-01-29 15:01:09.887  INFO 30880 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'mysqlDataSourceConfig' of type [class com.shihuc.dbconn.sourceconfig.mysql.MysqlDataSourceConfig$$EnhancerBySpringCGLIB$$63c6820a] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
12 2016-01-29 15:01:09.915  INFO 30880 --- [           main] o.s.j.d.DriverManagerDataSource          : Loaded JDBC driver: com.mysql.jdbc.Driver
13 2016-01-29 15:01:09.923  INFO 30880 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'mysqlds' of type [class org.springframework.jdbc.datasource.DriverManagerDataSource] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
14 2016-01-29 15:01:09.926  INFO 30880 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'mysqlMybatisConfig' of type [class com.shihuc.dbconn.sourceconfig.mysql.MysqlMybatisConfig$$EnhancerBySpringCGLIB$$bbfde9e4] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
15 2016-01-29 15:01:09.991  INFO 30880 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'sqlSessionFactoryBean' of type [class org.apache.ibatis.session.defaults.DefaultSqlSessionFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
16 2016-01-29 15:01:10.040  INFO 30880 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'IMysqlUser' of type [class org.mybatis.spring.mapper.MapperFactoryBean] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
17 2016-01-29 15:01:10.876  INFO 30880 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
18 2016-01-29 15:01:10.888  INFO 30880 --- [           main] com.shihuc.dbconn.DbConnApp              : Started DbConnApp in 3.274 seconds (JVM running for 3.561)
19 Exception in thread "main" org.mybatis.spring.MyBatisSystemException: nested exception is org.apache.ibatis.reflection.ReflectionException: Error instantiating class com.shihuc.dbconn.pojo.mysql.MysqlUser with invalid types () or values (). Cause: java.lang.NoSuchMethodException: com.shihuc.dbconn.pojo.mysql.MysqlUser.<init>()
20     at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:75)
21     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:371)
22     at com.sun.proxy.$Proxy26.selectOne(Unknown Source)
23     at org.mybatis.spring.SqlSessionTemplate.selectOne(SqlSessionTemplate.java:163)
24     at org.apache.ibatis.binding.MapperMethod.execute(MapperMethod.java:63)
25     at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:43)
26     at com.sun.proxy.$Proxy34.getUser(Unknown Source)
27     at com.shihuc.dbconn.service.mysql.MysqlUserService.getUser(MysqlUserService.java:20)
28     at com.shihuc.dbconn.DbConnApp.main(DbConnApp.java:34)
29 Caused by: org.apache.ibatis.reflection.ReflectionException: Error instantiating class com.shihuc.dbconn.pojo.mysql.MysqlUser with invalid types () or values (). Cause: java.lang.NoSuchMethodException: com.shihuc.dbconn.pojo.mysql.MysqlUser.<init>()
30     at org.apache.ibatis.reflection.factory.DefaultObjectFactory.instantiateClass(DefaultObjectFactory.java:83)
31     at org.apache.ibatis.reflection.factory.DefaultObjectFactory.create(DefaultObjectFactory.java:45)
32     at org.apache.ibatis.reflection.factory.DefaultObjectFactory.create(DefaultObjectFactory.java:38)
33     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.createResultObject(DefaultResultSetHandler.java:530)
34     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.createResultObject(DefaultResultSetHandler.java:509)
35     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.getRowValue(DefaultResultSetHandler.java:329)
36     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleRowValuesForSimpleResultMap(DefaultResultSetHandler.java:289)
37     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleRowValues(DefaultResultSetHandler.java:264)
38     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleResultSet(DefaultResultSetHandler.java:234)
39     at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleResultSets(DefaultResultSetHandler.java:152)
40     at org.apache.ibatis.executor.statement.PreparedStatementHandler.query(PreparedStatementHandler.java:57)
41     at org.apache.ibatis.executor.statement.RoutingStatementHandler.query(RoutingStatementHandler.java:70)
42     at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:57)
43     at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:259)
44     at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:132)
45     at org.apache.ibatis.executor.CachingExecutor.query(CachingExecutor.java:105)
46     at org.apache.ibatis.executor.CachingExecutor.query(CachingExecutor.java:81)
47     at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:104)
48     at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:98)
49     at org.apache.ibatis.session.defaults.DefaultSqlSession.selectOne(DefaultSqlSession.java:62)
50     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
51     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
52     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
53     at java.lang.reflect.Method.invoke(Method.java:606)
54     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:358)
55     ... 7 more
56 Caused by: java.lang.NoSuchMethodException: com.shihuc.dbconn.pojo.mysql.MysqlUser.<init>()
57     at java.lang.Class.getConstructor0(Class.java:2892)
58     at java.lang.Class.getDeclaredConstructor(Class.java:2058)
59     at org.apache.ibatis.reflection.factory.DefaultObjectFactory.instantiateClass(DefaultObjectFactory.java:57)
60     ... 31 more
61 2016-01-29 15:01:11.139  INFO 30880 --- [       Thread-1] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@a85aa40: startup date [Fri Jan 29 15:01:07 CST 2016]; root of context hierarchy
62 2016-01-29 15:01:11.142  INFO 30880 --- [       Thread-1] o.s.j.e.a.AnnotationMBeanExporter        : Unregistering JMX-exposed beans on shutdown
spring-boot支持双数据源mysql+mongo
View Code

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-09-15
  • 2022-01-15
  • 2021-06-19
  • 2021-10-05
猜你喜欢
  • 2022-12-23
  • 2021-07-02
  • 2021-10-28
  • 2021-10-03
相关资源
相似解决方案