分离sql

houko · houko · commit 1edb7d5a2af7 · 2016-11-16T11:33:07.000+08:00
diff --git a/multipleSource/src/main/java/info/xiaomo/multipleSource/controller/MultipleSourceController.java b/multipleSource/src/main/java/info/xiaomo/multipleSource/controller/MultipleSourceController.java
@@ -33,19 +33,19 @@ public class MultipleSourceController {
     public MultipleSourceController(@Qualifier("primaryJdbcTemplate") JdbcTemplate jdbcTemplate1, @Qualifier("secondaryJdbcTemplate") JdbcTemplate jdbcTemplate2) {
         this.jdbcTemplate1 = jdbcTemplate1;
         this.jdbcTemplate2 = jdbcTemplate2;
-        this.jdbcTemplate1.update("DELETE  FROM  user ");
-        this.jdbcTemplate2.update("DELETE  FROM  user ");
+        this.jdbcTemplate1.update(Sql.dropUser);
+        this.jdbcTemplate2.update(Sql.dropUser);
     }
 
 
     @RequestMapping("/")
     public Result index() {
         // 往第一个数据源中插入两条数据
-        jdbcTemplate1.update(Sql.addUser1, "xiaomo", 20);
-        jdbcTemplate2.update(Sql.addUser2, "xiaoming", 30);
+        jdbcTemplate1.update(Sql.addUser, "xiaomo", 20);
+        jdbcTemplate2.update(Sql.addUser, "xiaoming", 30);
 
-        int count1 = jdbcTemplate1.queryForObject(Sql.selectUser1, Integer.class);
-        int count2 = jdbcTemplate2.queryForObject(Sql.selectUser2, Integer.class);
+        int count1 = jdbcTemplate1.queryForObject(Sql.selectUser, Integer.class);
+        int count2 = jdbcTemplate2.queryForObject(Sql.selectUser, Integer.class);
         return new Result(new Object[]{count1, count2});
     }
 }
diff --git a/multipleSource/src/main/java/info/xiaomo/multipleSource/sql/Sql.java b/multipleSource/src/main/java/info/xiaomo/multipleSource/sql/Sql.java
@@ -17,10 +17,8 @@
 
 public class Sql {
 
-    public static String addUser1= "insert into user(name,age) values(?, ?)";
-    public static String addUser2= "insert into user(name,age) values(?, ?)";
-
-    public static String selectUser1 = "select count(1) from user";
-    public static String selectUser2 = "select count(1) from user";
+    public static String dropUser= "DELETE  FROM  user";
+    public static String addUser= "insert into user(name,age) values(?, ?)";
+    public static String selectUser = "select count(1) from user";
 
 }
