feature: A user-friendly config management page for apollo portal

apollo-portal/src/main/java/com/ctrip/framework/apollo/portal/controller/ServerConfigController.java

@@ -21,13 +21,21 @@
 import com.ctrip.framework.apollo.portal.entity.po.ServerConfig;
 import com.ctrip.framework.apollo.portal.repository.ServerConfigRepository;
 import com.ctrip.framework.apollo.portal.spi.UserInfoHolder;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Objects;
 import javax.validation.Valid;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -39,7 +47,8 @@ public class ServerConfigController {
   private final ServerConfigRepository serverConfigRepository;
   private final UserInfoHolder userInfoHolder;
 
-  public ServerConfigController(final ServerConfigRepository serverConfigRepository, final UserInfoHolder userInfoHolder) {
+  public ServerConfigController(final ServerConfigRepository serverConfigRepository,
+      final UserInfoHolder userInfoHolder) {
     this.serverConfigRepository = serverConfigRepository;
     this.userInfoHolder = userInfoHolder;
   }
@@ -63,10 +72,123 @@ public ServerConfig createOrUpdate(@Valid @RequestBody ServerConfig serverConfig
     return serverConfigRepository.save(storedConfig);
   }
 
+  @PostMapping("/server/config/addConfigService")
+  public void addConfigService(@Valid @RequestBody ServerConfig serverConfig) throws SQLException {
+    String modifiedBy = userInfoHolder.getUser().getUserId();
+
+    Connection conn = getConn();
+    PreparedStatement pst = (PreparedStatement) conn.prepareStatement(
+        "select * from serverconfig where serverconfig.Key='" + serverConfig.getKey() + "'");
+    ResultSet rs = pst.executeQuery();
+
+    if (rs.next()) {
+      pst = (PreparedStatement) conn.prepareStatement(
+          "update serverconfig set Value='" + serverConfig.getValue() + "',Comment='"
+              + serverConfig.getComment() + "' where serverconfig.Key='" + serverConfig.getKey()
+              + "'");
+
+      pst.executeUpdate();
+    } else {
+      pst = (PreparedStatement) conn.prepareStatement(
+          "insert into serverconfig(Id,serverconfig.Key,Value,Comment,DataChange_CreatedBy,DataChange_LastModifiedBy) values (null,'"
+              + serverConfig.getKey() +
+              "','" + serverConfig.getValue() + "','" + serverConfig.getComment() + "','"
+              + modifiedBy + "','')");
+      pst.executeUpdate();
+    }
+  }
+
+  /**
+   * 获取所有PortalDB的配置信息
+   *
+   * @return
+   */
+  @PreAuthorize(value = "@permissionValidator.isSuperAdmin()")
+  @GetMapping("/server/config/findAll")
+  public List<ServerConfig> findAllServerConfig(
+      @RequestParam(value = "offset", defaultValue = "0") int offset,
+      @RequestParam(value = "limit", defaultValue = "10") int limit) {
+
+    Iterable<ServerConfig> all = serverConfigRepository.findAll();
+
+    List<ServerConfig> serverConfigs = new ArrayList<>();
+
+    for (ServerConfig item : all) {
+      serverConfigs.add(item);
+    }
+
+    try {
+      return serverConfigs.subList((offset - 1) * limit,
+          offset * limit > serverConfigs.size() ? serverConfigs.size() : offset * limit);
+    } catch (Exception ex) {
+      return new ArrayList<>();
+    }
+  }
+
+  @GetMapping("/server/config/findAllConfigService")
+  public List<ServerConfig> findAllConfigService(
+      @RequestParam(value = "offset", defaultValue = "0") int offset,
+      @RequestParam(value = "limit", defaultValue = "10") int limit) {
+    Connection conn = getConn();
+    List<ServerConfig> serverConfigs = new ArrayList<>();
+    String sql = "select * FROM serverconfig where 1=1 limit " + (offset - 1) * limit + "," + limit;
+    try {
+      PreparedStatement pst = (PreparedStatement) conn.prepareStatement(sql);
+
+      ResultSet rs = pst.executeQuery();
+
+      while (rs.next()) {
+        String key = rs.getString("Key");
+        String value = rs.getString("Value");
+        String comment = rs.getString("Comment");
+
+        ServerConfig config = new ServerConfig();
+        config.setKey(key);
+        config.setValue(value);
+        config.setComment(comment);
+
+        serverConfigs.add(config);
+      }
+    } catch (SQLException e) {
+      return null;
+    }
+
+    return serverConfigs;
+  }
+
   @PreAuthorize(value = "@permissionValidator.isSuperAdmin()")
   @GetMapping("/server/config/{key:.+}")
   public ServerConfig loadServerConfig(@PathVariable String key) {
     return serverConfigRepository.findByKey(key);
   }
 
+  public Connection getConn() {
+    // 数据库连接对象
+    Connection conn = null;
+
+    // 数据库链接地址
+    String dbUrl = "jdbc:mysql://localhost:3306/apolloconfigdb?characterEncoding=utf-8";
+
+    // 用户名
+    String dbUserName = "root";
+
+    // 密码
+    String dbPassword = "123456";
+
+    // 数据库驱动类
+    String jdbcName = "com.mysql.jdbc.Driver";
+
+    try {
+      // 加载数据库驱动类
+      Class.forName(jdbcName);
+      conn = DriverManager.getConnection(dbUrl, dbUserName, dbPassword);
+    } catch (ClassNotFoundException e) {
+      e.printStackTrace();
+    } catch (SQLException e) {
+      e.printStackTrace();
+    }
+
+    return conn;
+  }
+
 }