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 }

 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 }

 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 }

 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 }

 1 package com.shihuc.dbconn.pojo.mysql;
 2 
 3 import com.shihuc.dbconn.pojo.User;
 4 
 5 public class MysqlUser extends User{
 6 
 7     private static final long serialVersionUID = -6412107575129572581L;
 8 
 9     //这个id是数据库中通过设置auto_increment得到的主键值
10     private int id;
11 
12     public int getId() {
13         return id;
14     }
15 
16     public void setId(int id) {
17         this.id = id;
18     }
19     
20     public MysqlUser(){
21         
22     }
23     
24     public MysqlUser(String username, String job, int age, String hometown){
25         this.username = username;
26         this.job = job;
27         this.age = age;
28         this.hometown = hometown;
29     }
30     
31 }

 1 package com.shihuc.dbconn;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.context.ApplicationContext;
 6 import org.springframework.context.annotation.PropertySource;
 7 
 8 import com.shihuc.dbconn.pojo.mongo.MongoUser;
 9 import com.shihuc.dbconn.pojo.mysql.MysqlUser;
10 import com.shihuc.dbconn.service.mongo.MongoUserService;
11 import com.shihuc.dbconn.service.mysql.MysqlUserService;
12 
13 /**
14  * 
15  * @author  shihuc
16  * @date    Jan 29, 2016
17  * 
18  */
19 @SpringBootApplication
20 @PropertySource(value = "dbconn.properties")
21 public class DbConnApp 
22 {
23     
24        public static void main(String[] args) throws Throwable {
25           
26         SpringApplication app = new SpringApplication(DbConnApp.class);
27         
28         ApplicationContext ctx = app.run(args);        
29         
30         MysqlUserService mysqlUserService = (MysqlUserService)ctx.getBean("mysqlUserService");        
31 //        MysqlUser su = new MysqlUser("shihuc", "SW", 30 , "wuhan");
32 //        mysqlUserService.addUser(su);    
33         MysqlUser ue = mysqlUserService.getUser(1);
34         System.out.println("Mysql User: " + ue);        
35         
36         MongoUserService mongoUserService = (MongoUserService)ctx.getBean("mongoUserService");
37 //        MongoUser mu = new MongoUser("shihuc", "SW", 30 , "wuhan");
38 //        mongoUserService.addUser(mu);                
39         MongoUser um = mongoUserService.getUser("shihuc");
40         System.out.println("Mongo User: " + um);
41     }
42 }

 1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 2   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 3   <modelVersion>4.0.0</modelVersion>
 4 
 5   <groupId>com.shihuc</groupId>
 6   <artifactId>dbconn</artifactId>
 7   <version>0.0.1-SNAPSHOT</version>
 8   <packaging>jar</packaging>
 9 
10   <name>dbconn</name>
11   <url>http://maven.apache.org</url>
12 
13   <parent>
14         <groupId>org.springframework.boot</groupId>
15         <artifactId>spring-boot-starter-parent</artifactId>
16         <version>1.2.7.RELEASE</version>
17   </parent>
18   
19   <properties>
20     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
21   </properties>
22 
23   <dependencies>
24       <dependency>
25           <groupId>org.springframework.boot</groupId>
26         <artifactId>spring-boot-starter-jdbc</artifactId>        
27     </dependency>
28     <dependency>
29         <groupId>mysql</groupId>
30         <artifactId>mysql-connector-java</artifactId>
31         </dependency>
32     <dependency>
33         <groupId>org.mybatis</groupId>
34         <artifactId>mybatis</artifactId>
35         <version>3.2.3</version>
36     </dependency>
37     <dependency>
38         <groupId>org.mybatis</groupId>
39         <artifactId>mybatis-spring</artifactId>
40         <version>1.2.2</version>
41     </dependency>
42     <dependency>
43         <groupId>org.springframework.boot</groupId>
44         <artifactId>spring-boot-starter-data-mongodb</artifactId>
45     </dependency>
46   </dependencies>
47   
48   <build>
49     <plugins>
50         <plugin>
51             <groupId>org.springframework.boot</groupId>
52             <artifactId>spring-boot-maven-plugin</artifactId>
53         </plugin>
54     </plugins>
55   </build>
56 </project>