X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdatarouter.git;a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Fbeans%2FPubFailRecord.java;h=a38d8bd2a10a4b5e62bd218247f8a178332d1d0b;hp=de2ad731aaebca1bd6fbda712ee5c3212d205e20;hb=534c164c124950a2019acf71d253ac96be12c78c;hpb=e4b20cc6f7c31f48ddd0de5bcd054b09a35cd510 diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/PubFailRecord.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/PubFailRecord.java index de2ad731..a38d8bd2 100644 --- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/PubFailRecord.java +++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/PubFailRecord.java @@ -7,9 +7,9 @@ * * Licensed under the Apache License, Version 2.0 (the "License"); * * you may not use this file except in compliance with the License. * * You may obtain a copy of the License at - * * + * * * * http://www.apache.org/licenses/LICENSE-2.0 - * * + * * * * Unless required by applicable law or agreed to in writing, software * * distributed under the License is distributed on an "AS IS" BASIS, * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -24,62 +24,60 @@ package org.onap.dmaap.datarouter.provisioning.beans; import java.sql.PreparedStatement; -import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Types; import java.text.ParseException; /** * The representation of a Publish Failure (PBF) Record, as retrieved from the DB. + * * @author Robert Eby * @version $Id: PubFailRecord.java,v 1.1 2013/10/28 18:06:53 eby Exp $ */ public class PubFailRecord extends BaseLogRecord { - private long contentLengthReceived; - private String sourceIP; - private String user; - private String error; + private long contentLengthReceived; + private String sourceIP; + private String user; + private String error; + + public PubFailRecord(String[] pp) throws ParseException { + super(pp); + this.contentLengthReceived = Long.parseLong(pp[8]); + this.sourceIP = pp[9]; + this.user = pp[10]; + this.error = pp[11]; + } + + public long getContentLengthReceived() { + return contentLengthReceived; + } + + public String getSourceIP() { + return sourceIP; + } + + public String getUser() { + return user; + } + + public String getError() { + return error; + } - public PubFailRecord(String[] pp) throws ParseException { - super(pp); - this.contentLengthReceived = Long.parseLong(pp[8]); - this.sourceIP = pp[9]; - this.user = pp[10]; - this.error = pp[11]; - } - public PubFailRecord(ResultSet rs) throws SQLException { - super(rs); - // Note: because this record should be "rare" these fields are mapped to unconventional fields in the DB - this.contentLengthReceived = rs.getLong("CONTENT_LENGTH_2"); - this.sourceIP = rs.getString("REMOTE_ADDR"); - this.user = rs.getString("USER"); - this.error = rs.getString("FEED_FILEID"); - } - public long getContentLengthReceived() { - return contentLengthReceived; - } - public String getSourceIP() { - return sourceIP; - } - public String getUser() { - return user; - } - public String getError() { - return error; - } - @Override - public void load(PreparedStatement ps) throws SQLException { - ps.setString(1, "pbf"); // field 1: type - super.load(ps); // loads fields 2-8 - ps.setString( 9, getError()); - ps.setString(10, getSourceIP()); - ps.setString(11, getUser()); - ps.setNull (12, Types.INTEGER); - ps.setNull (13, Types.INTEGER); - ps.setNull (14, Types.VARCHAR); - ps.setNull (15, Types.INTEGER); - ps.setNull (16, Types.INTEGER); - ps.setNull (17, Types.VARCHAR); - ps.setLong (19, getContentLengthReceived()); - } + @Override + public void load(PreparedStatement ps) throws SQLException { + ps.setString(1, "pbf"); // field 1: type + super.load(ps); // loads fields 2-8 + ps.setString(9, getError()); + ps.setString(10, getSourceIP()); + ps.setString(11, getUser()); + ps.setNull(12, Types.INTEGER); + ps.setNull(13, Types.INTEGER); + ps.setNull(14, Types.VARCHAR); + ps.setNull(15, Types.INTEGER); + ps.setNull(16, Types.INTEGER); + ps.setNull(17, Types.VARCHAR); + ps.setLong(19, getContentLengthReceived()); + ps.setNull(20, Types.VARCHAR); + } }