many db source

zhuzhengping911 · zhuzhengping911 · commit c32faddb7956 · 2017-03-09T00:04:49.000+08:00
diff --git a/src/main/java/com/common/DBBeanConfig_ManyDB.java b/src/main/java/com/common/DBBeanConfig_ManyDB.java
@@ -0,0 +1,45 @@
+package com.common;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+import javax.sql.DataSource;
+
+/**
+ * Created by zhuzhengping on 2017/3/8.
+ */
+@Configuration
+@EnableTransactionManagement
+public class DBBeanConfig_ManyDB {
+
+    @Bean(name = "oneDataSource")
+    @Qualifier("oneDataSource")
+    @Primary
+    @ConfigurationProperties(prefix = "spring.datasource.one")
+    public DataSource oneDataSource(){
+        return DataSourceBuilder.create().build();
+    }
+
+    @Bean(name = "twoDataSource")
+    @Qualifier("twoDataSource")
+    @ConfigurationProperties(prefix = "spring.datasource.two")
+    public DataSource twoDataSource(){
+        return DataSourceBuilder.create().build();
+    }
+
+    @Bean(name = "oneJdbcTemplate")
+    public JdbcTemplate oneJdbcTemplate(@Qualifier("oneDataSource") DataSource dataSource){
+        return new JdbcTemplate(dataSource);
+    }
+
+    @Bean(name = "twoJdbcTemplate")
+    public JdbcTemplate twoJdbcTemplate(@Qualifier("twoDataSource") DataSource dataSource) {
+        return new JdbcTemplate(dataSource);
+    }
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
@@ -16,10 +16,17 @@ logging:
 #  type-aliases-package: com.compont
 spring:
   datasource:
-    url: jdbc:mysql://localhost:3306/blog
-    username: root
-    password: 123
-    driver-class-name: com.mysql.jdbc.Driver
+    one:
+      url: jdbc:mysql://localhost:3306/blog
+      username: root
+      password: 123
+      driver-class-name: com.mysql.jdbc.Driver
+#数据库连接2
+    two:
+      url: jdbc:mysql://localhost:3306/dbgirl
+      username: root
+      password: 123
+      driver-class-name: com.mysql.jdbc.Driver
 #hibernate映射配置
   jpa:
     properties:
diff --git a/src/test/java/com/example/JdbcManyDBTest.java b/src/test/java/com/example/JdbcManyDBTest.java
@@ -0,0 +1,31 @@
+package com.example;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import javax.annotation.Resource;
+
+/**
+ * Created by zhuzhengping on 2017/3/8.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest
+public class JdbcManyDBTest {
+
+    @Resource(name = "oneJdbcTemplate")
+    protected JdbcTemplate jdbcTemplate1;
+
+    @Resource(name = "twoJdbcTemplate")
+    protected JdbcTemplate jdbcTemplate2;
+
+    @Test
+    public void test(){
+        jdbcTemplate1.update("INSERT INTO tp_author(id,real_name,nick_name) VALUES (?,?,?)",3,"tt","tom");
+
+        jdbcTemplate1.update("INSERT INTO dbgirl.girl(id,age,cupsize) VALUES (?,?,?)",10,"88","tom");
+
+    }
+}
