X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Fcom%2Fatt%2Fresearch%2Fdatarouter%2Fprovisioning%2Fbeans%2FLogRecord.java;fp=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Fcom%2Fatt%2Fresearch%2Fdatarouter%2Fprovisioning%2Fbeans%2FLogRecord.java;h=1ddc509483583f739925631ec11640bb7fc380eb;hb=aaf2df8b908fcb48043d2cd51803d8fd99f18b43;hp=0000000000000000000000000000000000000000;hpb=6ec9a9ce6c1062efa99da501fe8c6ea116aebf6f;p=dmaap%2Fdatarouter.git diff --git a/datarouter-prov/src/main/java/com/att/research/datarouter/provisioning/beans/LogRecord.java b/datarouter-prov/src/main/java/com/att/research/datarouter/provisioning/beans/LogRecord.java new file mode 100644 index 00000000..1ddc5094 --- /dev/null +++ b/datarouter-prov/src/main/java/com/att/research/datarouter/provisioning/beans/LogRecord.java @@ -0,0 +1,235 @@ +/******************************************************************************* + * ============LICENSE_START================================================== + * * org.onap.dmaap + * * =========================================================================== + * * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * * =========================================================================== + * * 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. + * * See the License for the specific language governing permissions and + * * limitations under the License. + * * ============LICENSE_END==================================================== + * * + * * ECOMP is a trademark and service mark of AT&T Intellectual Property. + * * + ******************************************************************************/ + + +package com.att.research.datarouter.provisioning.beans; + +import java.io.IOException; +import java.io.OutputStream; +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.sql.Statement; +import java.sql.Types; +import java.text.ParseException; +import java.util.Iterator; + +import com.att.research.datarouter.provisioning.utils.DB; +import com.att.research.datarouter.provisioning.utils.RLEBitSet; + +/** + * The representation of a Log Record, as retrieved from the DB. Since this record format is only used + * to replicate between provisioning servers, it is very bare-bones; e.g. there are no field setters and only 1 getter. + * @author Robert Eby + * @version $Id: LogRecord.java,v 1.7 2014/03/12 19:45:41 eby Exp $ + */ +public class LogRecord extends BaseLogRecord { + /** + * Print all log records whose RECORD_IDs are in the bit set provided. + * @param os the {@link OutputStream} to print the records on + * @param bs the {@link RLEBitSet} listing the record IDs to print + * @throws IOException + */ + public static void printLogRecords(OutputStream os, RLEBitSet bs) throws IOException { + final String sql = "select * from LOG_RECORDS where RECORD_ID >= ? AND RECORD_ID <= ?"; + DB db = new DB(); + Connection conn = null; + try { + conn = db.getConnection(); + Statement stmt = conn.createStatement(); + Iterator iter = bs.getRangeIterator(); + PreparedStatement ps = conn.prepareStatement(sql); + while (iter.hasNext()) { + Long[] n = iter.next(); + ps.setLong(1, n[0]); + ps.setLong(2, n[1]); + ResultSet rs = ps.executeQuery(); + while (rs.next()) { + LogRecord lr = new LogRecord(rs); + os.write(lr.toString().getBytes()); + } + rs.close(); + ps.clearParameters(); + } + ps.close(); + stmt.close(); + } catch (SQLException e) { + e.printStackTrace(); + } finally { + if (conn != null) + db.release(conn); + } + } + + private final String type; + private final String feedFileid; + private final String remoteAddr; + private final String user; + private final int status; + private final int subid; + private final String fileid; + private final int result; + private final int attempts; + private final String reason; + private final long record_id; + private final long clength2; + + public LogRecord(ResultSet rs) throws SQLException { + super(rs); + this.type = rs.getString("TYPE"); + this.feedFileid = rs.getString("FEED_FILEID"); + this.remoteAddr = rs.getString("REMOTE_ADDR"); + this.user = rs.getString("USER"); + this.status = rs.getInt("STATUS"); + + this.subid = rs.getInt("DELIVERY_SUBID"); + this.fileid = rs.getString("DELIVERY_FILEID"); + this.result = rs.getInt("RESULT"); + + this.attempts = rs.getInt("ATTEMPTS"); + this.reason = rs.getString("REASON"); + + this.record_id = rs.getLong("RECORD_ID"); + this.clength2 = rs.getLong("CONTENT_LENGTH_2"); + } + public LogRecord(String[] pp) throws ParseException { + super(pp); + this.type = pp[8]; + this.feedFileid = pp[9]; + this.remoteAddr = pp[10]; + this.user = pp[11]; + this.status = Integer.parseInt(pp[12]); + + this.subid = Integer.parseInt(pp[13]); + this.fileid = pp[14]; + this.result = Integer.parseInt(pp[15]); + + this.attempts = Integer.parseInt(pp[16]); + this.reason = pp[17]; + + this.record_id = Long.parseLong(pp[18]); + this.clength2 = (pp.length == 20) ? Long.parseLong(pp[19]) : 0; + } + + public long getRecordId() { + return record_id; + } + + @Override + public String toString() { + return + sdf.format(getEventTime()) + "|" + + "LOG|" + + getPublishId() + "|" + + getFeedid() + "|" + + getRequestUri() + "|" + + getMethod() + "|" + + getContentType() + "|" + + getContentLength() + "|" + + type + "|" + + feedFileid + "|" + + remoteAddr + "|" + + user + "|" + + status + "|" + + subid + "|" + + fileid + "|" + + result + "|" + + attempts + "|" + + reason + "|" + + record_id + "|" + + clength2 + + "\n"; + } + + @Override + public void load(PreparedStatement ps) throws SQLException { + ps.setString(1, type); + super.load(ps); // loads fields 2-8 + if (type.equals("pub")) { + ps.setString(9, feedFileid); + ps.setString(10, remoteAddr); + ps.setString(11, user); + ps.setInt (12, status); + 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 (18, record_id); + ps.setNull (19, Types.BIGINT); + } else if (type.equals("del")) { + ps.setNull (9, Types.VARCHAR); + ps.setNull (10, Types.VARCHAR); + ps.setString(11, user); + ps.setNull (12, Types.INTEGER); + ps.setInt (13, subid); + ps.setString(14, fileid); + ps.setInt (15, result); + ps.setNull (16, Types.INTEGER); + ps.setNull (17, Types.VARCHAR); + ps.setLong (18, record_id); + ps.setNull (19, Types.BIGINT); + } else if (type.equals("exp")) { + ps.setNull (9, Types.VARCHAR); + ps.setNull (10, Types.VARCHAR); + ps.setNull (11, Types.VARCHAR); + ps.setNull (12, Types.INTEGER); + ps.setInt (13, subid); + ps.setString(14, fileid); + ps.setNull (15, Types.INTEGER); + ps.setInt (16, attempts); + ps.setString(17, reason); + ps.setLong (18, record_id); + ps.setNull (19, Types.BIGINT); + } else if (type.equals("pbf")) { + ps.setString( 9, feedFileid); + ps.setString(10, remoteAddr); + ps.setString(11, user); + 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 (18, record_id); + ps.setLong (19, clength2); + } else if (type.equals("dlx")) { + ps.setNull ( 9, Types.VARCHAR); + ps.setNull (10, Types.VARCHAR); + ps.setNull (11, Types.VARCHAR); + ps.setNull (12, Types.INTEGER); + ps.setInt (13, subid); + ps.setNull (14, Types.VARCHAR); + ps.setNull (15, Types.INTEGER); + ps.setNull (16, Types.INTEGER); + ps.setNull (17, Types.VARCHAR); + ps.setLong (18, record_id); + ps.setLong (19, clength2); + } + } + + public static void main(String[] a) throws IOException { + LogRecord.printLogRecords(System.out, new RLEBitSet(a[0])); + } +}