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)); | |