private static long lastTime = 0L;
- private static class MirrorVectorHandler implements DBFieldHandler.SqlOp {
- public Object get(ResultSet rs, int index) throws Exception {
- String val = rs.getString(index);
- if (val == null) {
- return(null);
- }
- Set<ReplicationVector> rv = new HashSet<ReplicationVector>();
- for (String s: val.split(",")) {
- String[] f = s.split(";");
- if (f.length < 3) {
- continue;
- }
- rv.add(new ReplicationVector(DBFieldHandler.funesc(f[0]), DBFieldHandler.funesc(f[1]), DBFieldHandler.funesc(f[2])));
- }
- return(rv);
- }
- public void set(PreparedStatement ps, int index, Object val) throws Exception {
- if (val == null) {
- ps.setString(index, null);
- return;
- }
- Set xv = (Set)val;
- StringBuffer sb = new StringBuffer();
- String sep = "";
- for (Object o: xv) {
- ReplicationVector rv = (ReplicationVector)o;
- sb.append(sep).append(DBFieldHandler.fesc(rv.getFqtn())).append(';').append(DBFieldHandler.fesc(rv.getSourceCluster())).append(';').append(DBFieldHandler.fesc(rv.getTargetCluster()));
- sep = ",";
- }
- ps.setString(index, sb.toString());
- }
- }
- // modified version of MirrorVectorHandler for Topics
+
private static class MirrorTopicsHandler implements DBFieldHandler.SqlOp {
public Object get(ResultSet rs, int index) throws Exception {
String val = rs.getString(index);
}
List<String> rv = new ArrayList<String>();
for (String s: val.split(",")) {
- //String[] f = s.split(";");
- //if (f.length < 3) {
- // continue;
- //}
rv.add(new String(s));
}
return(rv);
}
@SuppressWarnings("unchecked")
List<String> xv = (List<String>)val;
- StringBuffer sb = new StringBuffer();
+ StringBuilder sb = new StringBuilder();
String sep = "";
for (Object o: xv) {
String rv = (String)o;
}
try {
dmaap = new DBSingleton<Dmaap>(Dmaap.class, "dmaap");
- dcaeLocations = new DBMap<DcaeLocation>(DcaeLocation.class, "dcae_location", "dcae_location_name");
- dr_nodes = new DBMap<DR_Node>(DR_Node.class, "dr_node", "fqdn");
- dr_pubs = new DBMap<DR_Pub>(DR_Pub.class, "dr_pub", "pub_id");
- dr_subs = new DBMap<DR_Sub>(DR_Sub.class, "dr_sub", "sub_id");
- mr_clients = new DBMap<MR_Client>(MR_Client.class, "mr_client", "mr_client_id");
- mr_clusters = new DBMap<MR_Cluster>(MR_Cluster.class, "mr_cluster", "dcae_location_name");
- feeds = new DBMap<Feed>(Feed.class, "feed", "feed_id");
+ dcaeLocations = new DBMap<>(DcaeLocation.class, "dcae_location", "dcae_location_name");
+ dr_nodes = new DBMap<>(DR_Node.class, "dr_node", "fqdn");
+ dr_pubs = new DBMap<>(DR_Pub.class, "dr_pub", "pub_id");
+ dr_subs = new DBMap<>(DR_Sub.class, "dr_sub", "sub_id");
+ mr_clients = new DBMap<>(MR_Client.class, "mr_client", "mr_client_id");
+ mr_clusters = new DBMap<>(MR_Cluster.class, "mr_cluster", "dcae_location_name");
+ feeds = new DBMap<>(Feed.class, "feed", "feed_id");
TableHandler.setSpecialCase("topic", "replication_case", new TopicReplicationTypeHandler());
- topics = new DBMap<Topic>(Topic.class, "topic", "fqtn");
- //TableHandler.setSpecialCase("mirror_maker", "vectors", new MirrorVectorHandler());
+ topics = new DBMap<>(Topic.class, "topic", "fqtn");
TableHandler.setSpecialCase("mirror_maker", "topics", new MirrorTopicsHandler());
- mirrors = new DBMap<MirrorMaker>(MirrorMaker.class, "mirror_maker", "mm_name");
+ mirrors = new DBMap<>(MirrorMaker.class, "mirror_maker", "mm_name");
} catch (Exception e) {
errorLogger.error("Error initializing database access " + e, e);
System.exit(1);
dmaap.setAccessKeyOwner(nd.getAccessKeyOwner());
}
};
- dcaeLocations = new HashMap<String, DcaeLocation>();
- dr_nodes = new HashMap<String, DR_Node>();
- dr_pubs = new HashMap<String, DR_Pub>();
- dr_subs = new HashMap<String, DR_Sub>();
- mr_clients = new HashMap<String, MR_Client>();
- mr_clusters = new HashMap<String, MR_Cluster>();
- feeds = new HashMap<String, Feed>();
- topics = new HashMap<String, Topic>();
- mirrors = new HashMap<String, MirrorMaker>();
+ dcaeLocations = new HashMap<>();
+ dr_nodes = new HashMap<>();
+ dr_pubs = new HashMap<>();
+ dr_subs = new HashMap<>();
+ mr_clients = new HashMap<>();
+ mr_clusters = new HashMap<>();
+ feeds = new HashMap<>();
+ topics = new HashMap<>();
+ mirrors = new HashMap<>();
}
dmaap.init(new Dmaap("0", "", "", "", "", "", "", ""));
// check for, and set up initial data, if it isn't already there
dmaap.update(dmx);
}
} catch (Exception e) {
+ errorLogger.error("Error", e);
errorLogger.error(DmaapbcLogMessageEnum.DB_UPDATE_ERROR, e.getMessage());
}
}
- public synchronized static String getNextClientId() {
+ public static synchronized String getNextClientId() {
long id = System.currentTimeMillis();
if ( id <= lastTime ) {