+ public static final String PROV_REQUIRE_SECURE = "PROV_REQUIRE_SECURE";\r
+ public static final String PROV_REQUIRE_CERT = "PROV_REQUIRE_CERT";\r
+ public static final String PROV_AUTH_ADDRESSES = "PROV_AUTH_ADDRESSES";\r
+ public static final String PROV_AUTH_SUBJECTS = "PROV_AUTH_SUBJECTS";\r
+ public static final String PROV_NAME = "PROV_NAME";\r
+ public static final String PROV_ACTIVE_NAME = "PROV_ACTIVE_NAME";\r
+ static final String PROV_DOMAIN = "PROV_DOMAIN";\r
+ public static final String PROV_MAXFEED_COUNT = "PROV_MAXFEED_COUNT";\r
+ public static final String PROV_MAXSUB_COUNT = "PROV_MAXSUB_COUNT";\r
+ public static final String PROV_POKETIMER1 = "PROV_POKETIMER1";\r
+ public static final String PROV_POKETIMER2 = "PROV_POKETIMER2";\r
+ public static final String PROV_SPECIAL_SUBNET = "PROV_SPECIAL_SUBNET";\r
+ public static final String PROV_LOG_RETENTION = "PROV_LOG_RETENTION";\r
+ public static final String DEFAULT_LOG_RETENTION = "DEFAULT_LOG_RETENTION";\r
+ public static final String NODES = "NODES";\r
+ public static final String ACTIVE_POD = "ACTIVE_POD";\r
+ public static final String STANDBY_POD = "STANDBY_POD";\r
+ public static final String LOGROLL_INTERVAL = "LOGROLL_INTERVAL";\r
+ public static final String DELIVERY_INIT_RETRY_INTERVAL = "DELIVERY_INIT_RETRY_INTERVAL";\r
+ public static final String DELIVERY_MAX_RETRY_INTERVAL = "DELIVERY_MAX_RETRY_INTERVAL";\r
+ public static final String DELIVERY_RETRY_RATIO = "DELIVERY_RETRY_RATIO";\r
+ public static final String DELIVERY_MAX_AGE = "DELIVERY_MAX_AGE";\r
+ public static final String THROTTLE_FILTER = "THROTTLE_FILTER";\r
+ public static final String STATIC_ROUTING_NODES = "STATIC_ROUTING_NODES";\r
+\r
+ private static EELFLogger intlogger = EELFManager.getInstance().getLogger("InternalLog");\r
+ private static final String SQLEXCEPTION = "SQLException: ";\r
+\r
+ private String keyname;\r
+ private String value;\r
+\r
+ public Parameters(String key, String val) {\r
+ this.keyname = key;\r
+ this.value = val;\r
+ }\r
+\r
+ public Parameters(ResultSet rs) throws SQLException {\r
+ this.keyname = rs.getString("KEYNAME");\r
+ this.value = rs.getString("VALUE");\r
+ }\r
+\r
+ /**\r
+ * Get all parameters in the DB as a Map.\r
+ *\r
+ * @return the Map of keynames/values from the DB.\r
+ */\r
+ public static Map<String, String> getParameters() {\r
+ Map<String, String> props = new HashMap<>();\r
+ for (Parameters p : getParameterCollection()) {\r
+ props.put(p.getKeyname(), p.getValue());\r
+ }\r
+ return props;\r
+ }\r
+\r
+ /**\r
+ * Method to get parameters.\r
+ * @return collection of parameters\r
+ */\r
+ public static Collection<Parameters> getParameterCollection() {\r
+ Collection<Parameters> coll = new ArrayList<>();\r
+ try (Connection conn = ProvDbUtils.getInstance().getConnection();\r
+ PreparedStatement ps = conn.prepareStatement("select * from PARAMETERS");\r
+ ResultSet rs = ps.executeQuery()) {\r
+ while (rs.next()) {\r
+ Parameters param = new Parameters(rs);\r
+ coll.add(param);\r
+ }\r
+ } catch (SQLException e) {\r
+ intlogger.error(SQLEXCEPTION + e.getMessage(), e);\r
+ }\r
+ return coll;\r
+ }\r
+\r
+ /**\r
+ * Get a specific parameter value from the DB.\r
+ *\r
+ * @param key the key to lookup\r
+ * @return the value, or null if non-existant\r
+ */\r
+ public static Parameters getParameter(String key) {\r
+ Parameters val = null;\r
+ try (Connection conn = ProvDbUtils.getInstance().getConnection();\r
+ PreparedStatement stmt = conn.prepareStatement(\r
+ "select KEYNAME, VALUE from PARAMETERS where KEYNAME = ?")) {\r
+ stmt.setString(1, key);\r
+ try (ResultSet rs = stmt.executeQuery()) {\r
+ if (rs.next()) {\r
+ val = new Parameters(rs);\r
+ }\r
+ }\r
+ } catch (SQLException e) {\r
+ intlogger.error(SQLEXCEPTION + e.getMessage(), e);\r
+ }\r
+ return val;\r
+ }\r
+\r
+ public String getKeyname() {\r
+ return keyname;\r
+ }\r
+\r
+ public String getValue() {\r
+ return value;\r
+ }\r
+\r
+ public void setValue(String value) {\r
+ this.value = value;\r
+ }\r
+\r
+ @Override\r
+ public JSONObject asJSONObject() {\r
+ JSONObject jo = new JSONObject();\r
+ jo.put("keyname", keyname);\r
+ jo.put("value", value);\r
+ return jo;\r
+ }\r
+\r
+ @Override\r
+ public boolean doInsert(Connection conn) {\r
+ boolean rv = true;\r
+ try (PreparedStatement ps = conn.prepareStatement("insert into PARAMETERS values (?, ?)")) {\r
+ ps.setString(1, getKeyname());\r
+ ps.setString(2, getValue());\r
+ ps.execute();\r
+ } catch (SQLException e) {\r
+ rv = false;\r
+ intlogger.warn("PROV0005 doInsert: " + e.getMessage(), e);\r
+ }\r
+ return rv;\r
+ }\r
+\r
+ @Override\r
+ public boolean doUpdate(Connection conn) {\r
+ boolean rv = true;\r
+ try (PreparedStatement ps = conn.prepareStatement("update PARAMETERS set VALUE = ? where KEYNAME = ?")) {\r
+ ps.setString(1, getValue());\r
+ ps.setString(2, getKeyname());\r
+ ps.executeUpdate();\r
+ } catch (SQLException e) {\r
+ rv = false;\r
+ intlogger.warn("PROV0006 doUpdate: " + e.getMessage(),e);\r
+ }\r
+ return rv;\r
+ }\r
+\r
+ @Override\r
+ public boolean doDelete(Connection conn) {\r
+ boolean rv = true;\r
+ try (PreparedStatement ps = conn.prepareStatement("delete from PARAMETERS where KEYNAME = ?")) {\r
+ ps.setString(1, getKeyname());\r
+ ps.execute();\r
+ } catch (SQLException e) {\r
+ rv = false;\r
+ intlogger.warn("PROV0007 doDelete: " + e.getMessage(), e);\r
+ }\r
+ return rv;\r
+ }\r