The following document contains the results of PMD's CPD 4.3.
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelMysql.java | 59 |
goldengate\ftp\exec\database\model\DbModelPostgresql.java | 53 |
String primaryKey = " PRIMARY KEY "; String notNull = " NOT NULL "; DbRequest request = new DbRequest(session); // TRANSLOG String action = createTableH2 + DbTransferLog.table + "("; DbTransferLog.Columns[] acolumns = DbTransferLog.Columns.values(); for (int i = 0; i < acolumns.length; i ++) { action += acolumns[i].name() + DBType.getType(DbTransferLog.dbTypes[i]) + notNull + ", "; } // Several columns for primary key action += " CONSTRAINT TRANSLOG_PK " + primaryKey + "("; for (int i = DbTransferLog.NBPRKEY; i > 1; i--) { action += acolumns[acolumns.length - i].name() + ","; } action += acolumns[acolumns.length - 1].name() + "))"; System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { e.printStackTrace(); return; } finally { request.close(); } // Index TRANSLOG action = "CREATE INDEX IDX_TRANSLOG ON "+ DbTransferLog.table + "("; DbTransferLog.Columns[] icolumns = DbTransferLog.indexes; for (int i = 0; i < icolumns.length-1; i ++) { action += icolumns[i].name()+ ", "; } action += icolumns[icolumns.length-1].name()+ ")"; System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { return; } finally { request.close(); } // cptrunner /* * # Table to handle any number of sequences: CREATE TABLE Sequences ( name VARCHAR(22) NOT NULL, seq INT UNSIGNED NOT NULL, # (or BIGINT) PRIMARY KEY name ); # Create a Sequence: INSERT INTO Sequences (name, seq) VALUES (?, 0); # Drop a Sequence: DELETE FROM Sequences WHERE name = ?; # Get a sequence number: UPDATE Sequences SET seq = LAST_INSERT_ID(seq + 1) WHERE name = ?; $seq = $db->LastInsertId(); */ action = "CREATE TABLE Sequences (name VARCHAR(22) NOT NULL PRIMARY KEY,"+ |
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelH2.java | 106 |
goldengate\ftp\exec\database\model\DbModelPostgresql.java | 103 |
" START WITH " + (DbConstant.ILLEGALVALUE + 1); System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { e.printStackTrace(); return; } finally { request.close(); } } /* * (non-Javadoc) * * @see openr66.databaseold.model.DbModel#resetSequence() */ @Override public void resetSequence(DbSession session, long newvalue) throws GoldenGateDatabaseNoConnectionException { String action = "ALTER SEQUENCE " + DbTransferLog.fieldseq + " RESTART WITH " + newvalue; DbRequest request = new DbRequest(session); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { e.printStackTrace(); return; } finally { request.close(); } System.out.println(action); } /* * (non-Javadoc) * * @see openr66.databaseold.model.DbModel#nextSequence() */ @Override public long nextSequence(DbSession dbSession) throws GoldenGateDatabaseNoConnectionException, GoldenGateDatabaseSqlException, GoldenGateDatabaseNoDataException { long result = DbConstant.ILLEGALVALUE; String action = "SELECT NEXTVAL('" + DbTransferLog.fieldseq + "')"; DbPreparedStatement preparedStatement = new DbPreparedStatement( dbSession); try { preparedStatement.createPrepareStatement(action); // Limit the search preparedStatement.executeQuery(); if (preparedStatement.getNext()) { try { result = preparedStatement.getResultSet().getLong(1); } catch (SQLException e) { throw new GoldenGateDatabaseSqlException(e); } return result; } else { throw new GoldenGateDatabaseNoDataException( "No sequence found. Must be initialized first"); } } finally { preparedStatement.realClose(); } } } |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 843 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_211, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_229, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_230, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_250, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_257, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_331, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_332, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_350; new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; /** * Error part * * @author Frederic Bregier * */ public static enum goldenGateErrorValuesIndex { |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 823 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 937 |
public static GgEntry[] goldenGateDetailedValues = { // reply_000, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_110, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_120, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_125, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_150, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_200, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_202, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_211, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_229, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 828 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 831 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 834 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 837 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 840 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_120, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_125, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_150, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_200, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_202, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_211, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_229, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_230, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 846 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_229, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_230, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_250, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_257, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_331, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_332, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_350; new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 942 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_110, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_120, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_125, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_150, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_200, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_202, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_211, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 849 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_227, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_229, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_230, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_250, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_257, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_331, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_332, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_350; new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 945 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_110, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_120, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_125, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_150, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_200, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_202, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_211, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_212, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_213, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_214, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_215, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_220, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_221, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_225, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // reply_226, new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 849 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 945 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; /** * Detailed part * * @author Frederic Bregier * */ public static enum goldenGateDetailedValuesIndex { |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 828 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 831 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 834 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 837 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 840 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 843 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 846 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 942 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 731 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 852 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 948 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 852 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 948 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 734 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 855 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 951 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 855 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 951 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 738 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 858 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 954 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 858 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 954 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\database\data\DbTransferLog.java | 739 |
goldengate\ftp\exec\database\data\DbTransferLog.java | 769 |
DbSession session, boolean in) throws GoldenGateDatabaseNoConnectionException, GoldenGateDatabaseSqlException { String request = "SELECT COUNT(" + Columns.SPECIALID.name() + ") FROM " + table; String inCond = null; if (in) { inCond = " ("+Columns.MODETRANS.name()+" = '"+FtpCommandCode.APPE.name()+"' OR "+ Columns.MODETRANS.name()+" = '"+FtpCommandCode.STOR.name()+"' OR "+ Columns.MODETRANS.name()+" = '"+FtpCommandCode.STOU.name()+"') "; } else { inCond = " ("+Columns.MODETRANS.name()+" = '"+FtpCommandCode.RETR.name()+"') "; } request += " WHERE "+inCond; request += " AND "+getLimitWhereCondition()+" "; request += " AND "+Columns.STARTTRANS.name() + " >= ? "; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 741 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 861 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 957 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelOracle.java | 82 |
goldengate\ftp\exec\database\model\DbModelPostgresql.java | 78 |
return; } finally { request.close(); } // Index TRANSLOG action = "CREATE INDEX IDX_TRANSLOG ON "+ DbTransferLog.table + "("; DbTransferLog.Columns[] icolumns = DbTransferLog.indexes; for (int i = 0; i < icolumns.length-1; i ++) { action += icolumns[i].name()+ ", "; } action += icolumns[icolumns.length-1].name()+ ")"; System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { return; } finally { request.close(); } // cptrunner action = "CREATE SEQUENCE " + DbTransferLog.fieldseq + " MINVALUE " + (DbConstant.ILLEGALVALUE + 1)+ |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 861 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 957 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 744 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 864 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 960 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelH2.java | 60 |
goldengate\ftp\exec\database\model\DbModelMysql.java | 64 |
goldengate\ftp\exec\database\model\DbModelPostgresql.java | 58 |
String action = createTableH2 + DbTransferLog.table + "("; DbTransferLog.Columns[] acolumns = DbTransferLog.Columns.values(); for (int i = 0; i < acolumns.length; i ++) { action += acolumns[i].name() + DBType.getType(DbTransferLog.dbTypes[i]) + notNull + ", "; } // Several columns for primary key action += " CONSTRAINT TRANSLOG_PK " + primaryKey + "("; for (int i = DbTransferLog.NBPRKEY; i > 1; i--) { action += acolumns[acolumns.length - i].name() + ","; } action += acolumns[acolumns.length - 1].name() + "))"; System.out.println(action); |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 864 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 960 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelMysql.java | 84 |
goldengate\ftp\exec\database\model\DbModelOracle.java | 82 |
return; } finally { request.close(); } // Index TRANSLOG action = "CREATE INDEX IDX_TRANSLOG ON "+ DbTransferLog.table + "("; DbTransferLog.Columns[] icolumns = DbTransferLog.indexes; for (int i = 0; i < icolumns.length-1; i ++) { action += icolumns[i].name()+ ", "; } action += icolumns[icolumns.length-1].name()+ ")"; System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { return; } finally { request.close(); } // cptrunner /* * # Table to handle any number of sequences: CREATE TABLE Sequences ( name VARCHAR(22) NOT NULL, seq INT UNSIGNED NOT NULL, # (or BIGINT) PRIMARY KEY name ); # Create a Sequence: INSERT INTO Sequences (name, seq) VALUES (?, 0); # Drop a Sequence: DELETE FROM Sequences WHERE name = ?; # Get a sequence number: UPDATE Sequences SET seq = LAST_INSERT_ID(seq + 1) WHERE name = ?; $seq = $db->LastInsertId(); */ action = "CREATE TABLE Sequences (name VARCHAR(22) NOT NULL PRIMARY KEY,"+ |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 747 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 867 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 963 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 867 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 963 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\database\model\DbModelH2.java | 86 |
goldengate\ftp\exec\database\model\DbModelMysql.java | 89 |
goldengate\ftp\exec\database\model\DbModelOracle.java | 87 |
goldengate\ftp\exec\database\model\DbModelPostgresql.java | 83 |
action = "CREATE INDEX IF NOT EXISTS IDX_TRANSLOG ON "+ DbTransferLog.table + "("; DbTransferLog.Columns[] icolumns = DbTransferLog.indexes; for (int i = 0; i < icolumns.length-1; i ++) { action += icolumns[i].name()+ ", "; } action += icolumns[icolumns.length-1].name()+ ")"; System.out.println(action); try { request.query(action); } catch (GoldenGateDatabaseNoConnectionException e) { e.printStackTrace(); return; } catch (GoldenGateDatabaseSqlException e) { return; } finally { request.close(); } // cptrunner action = "CREATE SEQUENCE IF NOT EXISTS " + DbTransferLog.fieldseq + |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 750 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 825 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 870 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 939 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 966 |
new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoDone new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Current situation of all transfers, running or not // nbAllTransfer new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryTotal new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryFree new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // memoryUsed new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbThreads new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbNetworkConnection new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY) }; |
File | Line |
---|---|
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 727 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 870 |
goldengate\ftp\exec\snmp\FtpPrivateMib.java | 966 |
new GgEntry(SMIConstants.SYNTAX_COUNTER32, MOAccessImpl.ACCESS_READ_ONLY), // Bandwidth // applInboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // applOutboundBandwidthKBS new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // Overall status including past, future and current transfers // nbInfoUnknown new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoNotUpdated new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoInterrupted new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoToSubmit new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoError new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), // nbInfoRunning new GgEntry(SMIConstants.SYNTAX_GAUGE32, MOAccessImpl.ACCESS_READ_ONLY), |
File | Line |
---|---|
goldengate\ftp\exec\adminssl\HttpSslHandler.java | 347 |
goldengate\ftp\exec\adminssl\HttpSslHandler.java | 395 |
String system = REQUEST.Rule.readFileUnique(); StringBuilder builder = new StringBuilder(system); CommandExecutor exec = AbstractExecutor.getCommandExecutor(); GgStringUtils.replace(builder, "XXXSTCXXX", exec.getStorType()+" "+exec.pstorCMD); GgStringUtils.replace(builder, "XXXSTDXXX", Long.toString(exec.pstorDelay)); GgStringUtils.replace(builder, "XXXRTCXXX", exec.getRetrType()+" "+exec.pretrCMD); GgStringUtils.replace(builder, "XXXRTDXXX", Long.toString(exec.pretrDelay)); |