| File | Line |
|---|
| openr66\database\model\DbModelMysql.java | 64 |
| openr66\database\model\DbModelPostgresql.java | 59 |
String primaryKey = " PRIMARY KEY ";
String notNull = " NOT NULL ";
// Multiple Mode
String action = createTableH2 + DbMultipleMonitor.table + "(";
DbMultipleMonitor.Columns[] mcolumns = DbMultipleMonitor.Columns
.values();
for (int i = 0; i < mcolumns.length - 1; i ++) {
action += mcolumns[i].name() +
DBType.getType(DbMultipleMonitor.dbTypes[i]) + notNull +
", ";
}
action += mcolumns[mcolumns.length - 1].name() +
DBType.getType(DbMultipleMonitor.dbTypes[mcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
DbRequest request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
DbMultipleMonitor multipleMonitor = new DbMultipleMonitor(session,
Configuration.configuration.HOST_ID,0,0,0);
try {
if (!multipleMonitor.exist())
multipleMonitor.insert();
} catch (GoldenGateDatabaseException e1) {
e1.printStackTrace();
}
// Configuration
action = createTableH2 + DbConfiguration.table + "(";
DbConfiguration.Columns[] ccolumns = DbConfiguration.Columns
.values();
for (int i = 0; i < ccolumns.length - 1; i ++) {
action += ccolumns[i].name() +
DBType.getType(DbConfiguration.dbTypes[i]) + notNull +
", ";
}
action += ccolumns[ccolumns.length - 1].name() +
DBType.getType(DbConfiguration.dbTypes[ccolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// hosts
action = createTableH2 + DbHostAuth.table + "(";
DbHostAuth.Columns[] hcolumns = DbHostAuth.Columns.values();
for (int i = 0; i < hcolumns.length - 1; i ++) {
action += hcolumns[i].name() +
DBType.getType(DbHostAuth.dbTypes[i]) + notNull + ", ";
}
action += hcolumns[hcolumns.length - 1].name() +
DBType.getType(DbHostAuth.dbTypes[hcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// rules
action = createTableH2 + DbRule.table + "(";
DbRule.Columns[] rcolumns = DbRule.Columns.values();
for (int i = 0; i < rcolumns.length - 1; i ++) {
action += rcolumns[i].name() +
DBType.getType(DbRule.dbTypes[i]) + ", ";
}
action += rcolumns[rcolumns.length - 1].name() +
DBType.getType(DbRule.dbTypes[rcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// runner
action = createTableH2 + DbTaskRunner.table + "(";
DbTaskRunner.Columns[] acolumns = DbTaskRunner.Columns.values();
for (int i = 0; i < acolumns.length; i ++) {
action += acolumns[i].name() +
DBType.getType(DbTaskRunner.dbTypes[i]) + notNull + ", ";
}
// Several columns for primary key
action += " CONSTRAINT runner_pk " + primaryKey + "(";
for (int i = DbTaskRunner.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 Runner
action = "CREATE INDEX IDX_RUNNER ON "+ DbTaskRunner.table + "(";
DbTaskRunner.Columns[] icolumns = DbTaskRunner.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 |
|---|
| openr66\database\model\DbModelH2.java | 57 |
| openr66\database\model\DbModelMysql.java | 60 |
@Override
public void createTables(DbSession session) throws GoldenGateDatabaseNoConnectionException {
// Create tables: configuration, hosts, rules, runner, cptrunner
String createTableH2 = "CREATE TABLE IF NOT EXISTS ";
String primaryKey = " PRIMARY KEY ";
String notNull = " NOT NULL ";
// Multiple Mode
String action = createTableH2 + DbMultipleMonitor.table + "(";
DbMultipleMonitor.Columns[] mcolumns = DbMultipleMonitor.Columns
.values();
for (int i = 0; i < mcolumns.length - 1; i ++) {
action += mcolumns[i].name() +
DBType.getType(DbMultipleMonitor.dbTypes[i]) + notNull +
", ";
}
action += mcolumns[mcolumns.length - 1].name() +
DBType.getType(DbMultipleMonitor.dbTypes[mcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
DbRequest request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
DbMultipleMonitor multipleMonitor = new DbMultipleMonitor(session,
Configuration.configuration.HOST_ID,0,0,0);
try {
if (!multipleMonitor.exist())
multipleMonitor.insert();
} catch (GoldenGateDatabaseException e1) {
e1.printStackTrace();
}
// Configuration
action = createTableH2 + DbConfiguration.table + "(";
DbConfiguration.Columns[] ccolumns = DbConfiguration.Columns
.values();
for (int i = 0; i < ccolumns.length - 1; i ++) {
action += ccolumns[i].name() +
DBType.getType(DbConfiguration.dbTypes[i]) + notNull +
", ";
}
action += ccolumns[ccolumns.length - 1].name() +
DBType.getType(DbConfiguration.dbTypes[ccolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// hosts
action = createTableH2 + DbHostAuth.table + "(";
DbHostAuth.Columns[] hcolumns = DbHostAuth.Columns.values();
for (int i = 0; i < hcolumns.length - 1; i ++) {
action += hcolumns[i].name() +
DBType.getType(DbHostAuth.dbTypes[i]) + notNull + ", ";
}
action += hcolumns[hcolumns.length - 1].name() +
DBType.getType(DbHostAuth.dbTypes[hcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// rules
action = createTableH2 + DbRule.table + "(";
DbRule.Columns[] rcolumns = DbRule.Columns.values();
for (int i = 0; i < rcolumns.length - 1; i ++) {
action += rcolumns[i].name() +
DBType.getType(DbRule.dbTypes[i]) + ", ";
}
action += rcolumns[rcolumns.length - 1].name() +
DBType.getType(DbRule.dbTypes[rcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// runner
action = createTableH2 + DbTaskRunner.table + "(";
DbTaskRunner.Columns[] acolumns = DbTaskRunner.Columns.values();
for (int i = 0; i < acolumns.length; i ++) {
action += acolumns[i].name() +
DBType.getType(DbTaskRunner.dbTypes[i]) + notNull + ", ";
}
// Several columns for primary key
action += " CONSTRAINT runner_pk " + primaryKey + "(";
for (int i = DbTaskRunner.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 Runner
action = "CREATE INDEX IF NOT EXISTS IDX_RUNNER ON "+ DbTaskRunner.table + "("; |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 61 |
| openr66\database\model\DbModelPostgresql.java | 59 |
String primaryKey = " PRIMARY KEY ";
String notNull = " NOT NULL ";
// Multiple Mode
String action = createTableH2 + DbMultipleMonitor.table + "(";
DbMultipleMonitor.Columns[] mcolumns = DbMultipleMonitor.Columns
.values();
for (int i = 0; i < mcolumns.length - 1; i ++) {
action += mcolumns[i].name() +
DBType.getType(DbMultipleMonitor.dbTypes[i]) + notNull +
", ";
}
action += mcolumns[mcolumns.length - 1].name() +
DBType.getType(DbMultipleMonitor.dbTypes[mcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
DbRequest request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
DbMultipleMonitor multipleMonitor = new DbMultipleMonitor(session,
Configuration.configuration.HOST_ID,0,0,0);
try {
if (!multipleMonitor.exist())
multipleMonitor.insert();
} catch (GoldenGateDatabaseException e1) {
e1.printStackTrace();
}
// Configuration
action = createTableH2 + DbConfiguration.table + "(";
DbConfiguration.Columns[] ccolumns = DbConfiguration.Columns
.values();
for (int i = 0; i < ccolumns.length - 1; i ++) {
action += ccolumns[i].name() +
DBType.getType(DbConfiguration.dbTypes[i]) + notNull +
", ";
}
action += ccolumns[ccolumns.length - 1].name() +
DBType.getType(DbConfiguration.dbTypes[ccolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// hosts
action = createTableH2 + DbHostAuth.table + "(";
DbHostAuth.Columns[] hcolumns = DbHostAuth.Columns.values();
for (int i = 0; i < hcolumns.length - 1; i ++) {
action += hcolumns[i].name() +
DBType.getType(DbHostAuth.dbTypes[i]) + notNull + ", ";
}
action += hcolumns[hcolumns.length - 1].name() +
DBType.getType(DbHostAuth.dbTypes[hcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// rules
action = createTableH2 + DbRule.table + "(";
DbRule.Columns[] rcolumns = DbRule.Columns.values();
for (int i = 0; i < rcolumns.length - 1; i ++) {
action += rcolumns[i].name() +
DBType.getType(DbRule.dbTypes[i]) + ", ";
}
action += rcolumns[rcolumns.length - 1].name() +
DBType.getType(DbRule.dbTypes[rcolumns.length - 1]) +
primaryKey + ")";
System.out.println(action);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
// runner
action = createTableH2 + DbTaskRunner.table + "(";
DbTaskRunner.Columns[] acolumns = DbTaskRunner.Columns.values();
for (int i = 0; i < acolumns.length; i ++) {
action += acolumns[i].name() +
DBType.getType(DbTaskRunner.dbTypes[i]) + notNull + ", ";
}
// Several columns for primary key
action += " CONSTRAINT runner_pk " + primaryKey + "(";
for (int i = DbTaskRunner.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 Runner
action = "CREATE INDEX IF NOT EXISTS IDX_RUNNER ON "+ DbTaskRunner.table + "("; |
| File | Line |
|---|
| openr66\client\DirectTransfer.java | 150 |
| openr66\protocol\test\TestProgressBarTransfer.java | 115 |
logger.debug("finish transfer: "+future.isSuccess());
long delay = time2 - time1;
R66Result result = future.getResult();
if (future.isSuccess()) {
if (result.runner.getErrorInfo() == ErrorCode.Warning) {
logger.warn("Transfer in status:\nWARNED\n "+result.runner.toShortString()+
"\n <REMOTE>"+rhost+"</REMOTE>"+
"\n <FILEFINAL>" +
(result.file != null? result.file.toString()+"</FILEFINAL>" : "no file")
+"\n delay: "+delay);
} else {
logger.info("Transfer in status:\nSUCCESS\n "+result.runner.toShortString()+
"\n <REMOTE>"+rhost+"</REMOTE>"+
"\n <FILEFINAL>" +
(result.file != null? result.file.toString()+"</FILEFINAL>" : "no file")
+"\n delay: "+delay);
}
if (nolog) {
// In case of success, delete the runner
try {
result.runner.delete();
} catch (GoldenGateDatabaseException e) {
logger.warn("Cannot apply nolog to\n "+result.runner.toShortString(), e);
}
}
} else {
if (result == null || result.runner == null) {
logger.error("Transfer in\n FAILURE with no Id", future.getCause());
networkTransaction.closeAll();
System.exit(ErrorCode.Unknown.ordinal());
}
if (result.runner.getErrorInfo() == ErrorCode.Warning) {
logger.warn("Transfer is\n WARNED\n "+result.runner.toShortString()+
"\n <REMOTE>"+rhost+"</REMOTE>", future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
} else {
logger.error("Transfer in\n FAILURE\n "+result.runner.toShortString()+
"\n <REMOTE>"+rhost+"</REMOTE>", future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
}
}
} catch (Exception e) { |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 377 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 481 |
body0 = REQUEST.Listing.readBodyHeader();
String parm = parms.get(0);
if ("Filter".equalsIgnoreCase(parm)) {
String startid = getTrimValue("startid");
String stopid = getTrimValue("stopid");
if (startid != null && stopid == null) {
stopid = Long.toString(Long.parseLong(startid)+(LIMITROW/2));
}
if (stopid != null && startid == null) {
startid = Long.toString(Long.parseLong(stopid)-(LIMITROW/2));
}
String start = getValue("start");
String stop = getValue("stop");
String rule = getTrimValue("rule");
String req = getTrimValue("req");
boolean pending, transfer, error, done, all;
pending = params.containsKey("pending");
transfer = params.containsKey("transfer");
error = params.containsKey("error");
done = params.containsKey("done");
all = params.containsKey("all");
if (pending && transfer && error && done) {
all = true;
} else if (!(pending || transfer || error || done)) {
all = true;
}
Timestamp tstart = GgStringUtils.fixDate(start);
if (tstart != null) {
start = tstart.toString();
}
Timestamp tstop = GgStringUtils.fixDate(stop, tstart);
if (tstop != null) {
stop = tstop.toString();
}
head = resetOptionTransfer(head, startid == null ? "":startid,
stopid == null ? "":stopid, start, stop,
rule == null ? "":rule, req == null ? "":req,
pending, transfer, error, done, all);
body = REQUEST.Listing.readBody(); |
| File | Line |
|---|
| openr66\client\SendThroughClient.java | 176 |
| openr66\protocol\test\TestSendThroughForward.java | 193 |
ClientRunner runner = new ClientRunner(networkTransaction, taskRunner, future);
runner.setSendThroughMode();
OpenR66ProtocolNotYetConnectionException exc = null;
for (int i = 0; i < Configuration.RETRYNB; i++) {
try {
localChannelReference = runner.initRequest();
exc = null;
break;
} catch (OpenR66RunnerErrorException e) {
logger.error("Cannot Transfer", e);
future.setResult(new R66Result(e, null, true,
ErrorCode.Internal, taskRunner));
future.setFailure(e);
return false;
} catch (OpenR66ProtocolNoConnectionException e) {
logger.error("Cannot Connect", e);
future.setResult(new R66Result(e, null, true,
ErrorCode.ConnectionImpossible, taskRunner));
future.setFailure(e);
return false;
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, taskRunner));
future.setFailure(e);
return false;
} catch (OpenR66ProtocolNotYetConnectionException e) {
logger.debug("Not Yet Connected", e);
exc = e;
continue;
}
}
if (exc!= null) {
taskRunner.setLocalChannelReference(new LocalChannelReference());
logger.error("Cannot Connect", exc);
future.setResult(new R66Result(exc, null, true,
ErrorCode.ConnectionImpossible, taskRunner));
future.setFailure(exc);
return false;
}
try {
localChannelReference.waitReadyForSendThrough();
} catch (OpenR66Exception e) {
logger.error("Cannot Transfer", e);
future.setResult(new R66Result(e, null, true,
ErrorCode.Internal, taskRunner));
future.setFailure(e);
return false;
} |
| File | Line |
|---|
| openr66\context\task\ExecMoveTask.java | 101 |
| openr66\context\task\ExecOutputTask.java | 106 |
move(result.status, result.result, finalname);
localExecClient.disconnect();
return;
} // else continue
}
String[] args = finalname.split(" ");
File exec = new File(args[0]);
if (exec.isAbsolute()) {
if (! exec.canExecute()) {
logger.error("Exec command is not executable: " + finalname);
R66Result result = new R66Result(session, false,
ErrorCode.CommandNotFound, session.getRunner());
futureCompletion.setResult(result);
futureCompletion.cancel();
return;
}
}
CommandLine commandLine = new CommandLine(args[0]);
for (int i = 1; i < args.length; i ++) {
commandLine.addArgument(args[i]);
}
DefaultExecutor defaultExecutor = new DefaultExecutor();
PipedInputStream inputStream = new PipedInputStream();
PipedOutputStream outputStream = null;
try {
outputStream = new PipedOutputStream(inputStream);
} catch (IOException e1) {
try {
inputStream.close();
} catch (IOException e) {
}
logger.error("Exception: " + e1.getMessage() +
" Exec in error with " + commandLine.toString(), e1);
futureCompletion.setFailure(e1);
return;
}
PumpStreamHandler pumpStreamHandler = new PumpStreamHandler(
outputStream, null);
defaultExecutor.setStreamHandler(pumpStreamHandler);
int[] correctValues = {
0, 1 };
defaultExecutor.setExitValues(correctValues);
ExecuteWatchdog watchdog = null;
if (delay > 0) {
watchdog = new ExecuteWatchdog(delay);
defaultExecutor.setWatchdog(watchdog);
} |
| File | Line |
|---|
| openr66\database\data\DbRule.java | 365 |
| openr66\database\data\DbRule.java | 393 |
protected void setFromArray() throws GoldenGateDatabaseSqlException {
ids = (String) allFields[Columns.HOSTIDS.ordinal()].getValue();
mode = (Integer) allFields[Columns.MODETRANS.ordinal()].getValue();
recvPath = (String) allFields[Columns.RECVPATH.ordinal()].getValue();
sendPath = (String) allFields[Columns.SENDPATH.ordinal()].getValue();
archivePath = (String) allFields[Columns.ARCHIVEPATH.ordinal()]
.getValue();
workPath = (String) allFields[Columns.WORKPATH.ordinal()].getValue();
rpreTasks = (String) allFields[Columns.RPRETASKS.ordinal()].getValue();
rpostTasks = (String) allFields[Columns.RPOSTTASKS.ordinal()].getValue();
rerrorTasks = (String) allFields[Columns.RERRORTASKS.ordinal()]
.getValue();
spreTasks = (String) allFields[Columns.SPRETASKS.ordinal()].getValue();
spostTasks = (String) allFields[Columns.SPOSTTASKS.ordinal()].getValue();
serrorTasks = (String) allFields[Columns.SERRORTASKS.ordinal()]
.getValue();
updatedInfo = (Integer) allFields[Columns.UPDATEDINFO.ordinal()]
.getValue();
idRule = (String) allFields[Columns.IDRULE.ordinal()].getValue(); |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 216 |
| openr66\database\model\DbModelPostgresql.java | 214 |
" 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 " + DbTaskRunner.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('" + DbTaskRunner.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 |
|---|
| openr66\configuration\FileBasedConfiguration.java | 1573 |
| openr66\configuration\FileBasedConfiguration.java | 1654 |
public static boolean setConfigurationServerShutdownFromXml(Configuration config, String filename) {
Document document = null;
// Open config file
try {
document = new SAXReader().read(filename);
} catch (DocumentException e) {
logger.error("Unable to read the XML Config file: " + filename, e);
return false;
}
if (document == null) {
logger.error("Unable to read the XML Config file: " + filename);
return false;
}
configuration = XmlUtil.read(document, configServer);
hashConfig = new XmlHash(configuration);
// Now read the configuration
if (! loadIdentity(config)) {
logger.error("Cannot load Identity");
return false;
}
if (!loadDatabase(config)) {
logger.error("Cannot load Database configuration");
return false;
}
if (! loadServerParam(config)) {
logger.error("Cannot load Server Parameters");
return false;
}
if (! loadDirectory(config)) {
logger.error("Cannot load Directory configuration");
return false;
}
if (! loadLimit(config, false)) {
logger.error("Cannot load Limit configuration");
return false;
}
if (config.useSSL) {
if (!loadSsl(config)) {
logger.error("Cannot load SSL configuration");
return false;
}
}
if (! loadNetworkServer(config)) {
logger.error("Cannot load Network configuration");
return false;
}
if (!DbConstant.admin.isConnected) { |
| File | Line |
|---|
| openr66\server\ChangeBandwidthLimits.java | 88 |
| openr66\server\ConfigExport.java | 81 |
writeSessionLimit+" "+readSessionLimit, LocalPacketFactory.BANDWIDTHPACKET);
DbHostAuth host = Configuration.configuration.HOST_SSLAUTH;
SocketAddress socketAddress = host.getSocketAddress();
boolean isSSL = host.isSsl();
LocalChannelReference localChannelReference = networkTransaction
.createConnectionWithRetry(socketAddress, isSSL, future);
socketAddress = null;
if (localChannelReference == null) {
host = null;
logger.error("Cannot Connect");
future.setResult(new R66Result(
new OpenR66ProtocolNoConnectionException("Cannot connect to server"),
null, true, ErrorCode.Internal, null));
future.setFailure(future.getResult().exception);
return;
}
localChannelReference.sessionNewState(R66FiniteDualStates.VALIDOTHER);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference, valid, false);
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
host = null;
valid = null;
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, null));
future.setFailure(e);
return;
}
host = null;
future.awaitUninterruptibly();
logger.info("Request done with "+(future.isSuccess()?"success":"error"));
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
}
protected static long swriteGlobalLimit = -1; |
| File | Line |
|---|
| openr66\database\data\DbTaskRunner.java | 3236 |
| openr66\database\data\DbTaskRunner.java | 3343 |
} catch (FileNotFoundException e) {
logger.error("Cannot write XML file", e);
throw new OpenR66ProtocolBusinessException("File not found");
} catch (UnsupportedEncodingException e) {
logger.error("Cannot write XML file", e);
throw new OpenR66ProtocolBusinessException("Unsupported Encoding");
} finally {
if (xmlWriter != null) {
try {
xmlWriter.endDocument();
xmlWriter.flush();
xmlWriter.close();
} catch (SAXException e) {
try {
outputStream.close();
} catch (IOException e2) {
}
File file = new File(filename);
file.delete();
logger.error("Cannot write XML file", e);
throw new OpenR66ProtocolBusinessException("Unsupported Encoding");
} catch (IOException e) {
try {
outputStream.close();
} catch (IOException e2) {
}
File file = new File(filename);
file.delete();
logger.error("Cannot write XML file", e);
throw new OpenR66ProtocolBusinessException("Unsupported Encoding");
}
} else if (outputStream != null){
try {
outputStream.close();
} catch (IOException e) {
}
File file = new File(filename);
file.delete();
}
} |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 76 |
| openr66\database\model\DbModelMysql.java | 79 |
| openr66\database\model\DbModelOracle.java | 79 |
| openr66\database\model\DbModelPostgresql.java | 74 |
System.out.println(action);
DbRequest request = new DbRequest(session);
try {
request.query(action);
} catch (GoldenGateDatabaseNoConnectionException e) {
e.printStackTrace();
return;
} catch (GoldenGateDatabaseSqlException e) {
e.printStackTrace();
return;
} finally {
request.close();
}
DbMultipleMonitor multipleMonitor = new DbMultipleMonitor(session,
Configuration.configuration.HOST_ID,0,0,0);
try {
if (!multipleMonitor.exist())
multipleMonitor.insert();
} catch (GoldenGateDatabaseException e1) {
e1.printStackTrace();
}
// Configuration
action = createTableH2 + DbConfiguration.table + "(";
DbConfiguration.Columns[] ccolumns = DbConfiguration.Columns
.values();
for (int i = 0; i < ccolumns.length - 1; i ++) {
action += ccolumns[i].name() +
DBType.getType(DbConfiguration.dbTypes[i]) + notNull +
", ";
}
action += ccolumns[ccolumns.length - 1].name() +
DBType.getType(DbConfiguration.dbTypes[ccolumns.length - 1]) + |
| File | Line |
|---|
| openr66\context\task\ExecMoveTask.java | 209 |
| openr66\context\task\ExecOutputTask.java | 205 |
futureCompletion.setFailure(e);
return;
}
} catch (IOException e) {
try {
outputStream.close();
} catch (IOException e1) {
}
thread.interrupt();
try {
inputStream.close();
} catch (IOException e1) {
}
pumpStreamHandler.stop();
logger.error("IOException: " + e.getMessage() +
" . Exec in error with " + commandLine.toString());
futureCompletion.setFailure(e);
return;
}
try {
outputStream.flush();
} catch (IOException e) {
}
try {
outputStream.close();
} catch (IOException e) {
}
pumpStreamHandler.stop();
try {
if (delay > 0) {
thread.join(delay);
} else {
thread.join();
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
try {
inputStream.close();
} catch (IOException e1) {
}
String newname = null;
if (defaultExecutor.isFailure(status) && watchdog != null &&
watchdog.killedProcess()) {
// kill by the watchdoc (time out)
status = -1;
newname = "TimeOut";
} else {
newname = lastLineReader.lastLine; |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 415 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 519 |
body = REQUEST.Listing.readBody();
DbPreparedStatement preparedStatement = null;
try {
preparedStatement =
DbTaskRunner.getFilterPrepareStatement(dbSession, LIMITROW, false,
startid, stopid, tstart, tstop, rule, req,
pending, transfer, error, done, all);
preparedStatement.executeQuery();
StringBuilder builder = new StringBuilder();
int i = 0;
while (preparedStatement.getNext()) {
try {
i++;
DbTaskRunner taskRunner = DbTaskRunner.getFromStatement(preparedStatement);
LocalChannelReference lcr =
Configuration.configuration.getLocalTransaction().
getFromRequest(taskRunner.getKey());
builder.append(taskRunner.toSpecializedHtml(authentHttp, body,
lcr != null ? "Active" : "NotActive"));
if (i > LIMITROW) {
break;
}
} catch (GoldenGateDatabaseException e) {
// try to continue if possible
logger.warn("An error occurs while accessing a Runner: {}",
e.getMessage());
continue;
}
}
preparedStatement.realClose();
body = builder.toString();
} catch (GoldenGateDatabaseException e) {
if (preparedStatement != null) {
preparedStatement.realClose();
}
logger.warn("OpenR66 Web Error {}",e.getMessage());
} |
| File | Line |
|---|
| openr66\server\ConfigExport.java | 86 |
| openr66\server\LogExport.java | 110 |
LocalChannelReference localChannelReference = networkTransaction
.createConnectionWithRetry(socketAddress, isSSL, future);
socketAddress = null;
if (localChannelReference == null) {
host = null;
logger.error("Cannot Connect");
future.setResult(new R66Result(
new OpenR66ProtocolNoConnectionException("Cannot connect to server"),
null, true, ErrorCode.Internal, null));
future.setFailure(future.getResult().exception);
return;
}
localChannelReference.sessionNewState(R66FiniteDualStates.VALIDOTHER);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference, valid, false);
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
host = null;
valid = null;
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, null));
future.setFailure(e);
return;
}
host = null;
future.awaitUninterruptibly();
logger.info("Request done with "+(future.isSuccess()?"success":"error"));
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
}
protected static boolean shost = false; |
| File | Line |
|---|
| openr66\server\ChangeBandwidthLimits.java | 92 |
| openr66\server\LogExport.java | 110 |
LocalChannelReference localChannelReference = networkTransaction
.createConnectionWithRetry(socketAddress, isSSL, future);
socketAddress = null;
if (localChannelReference == null) {
host = null;
logger.error("Cannot Connect");
future.setResult(new R66Result(
new OpenR66ProtocolNoConnectionException("Cannot connect to server"),
null, true, ErrorCode.Internal, null));
future.setFailure(future.getResult().exception);
return;
}
localChannelReference.sessionNewState(R66FiniteDualStates.VALIDOTHER);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference, valid, false);
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
host = null;
valid = null;
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, null));
future.setFailure(e);
return;
}
host = null;
future.awaitUninterruptibly();
logger.info("Request done with "+(future.isSuccess()?"success":"error"));
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
}
protected static long swriteGlobalLimit = -1; |
| File | Line |
|---|
| openr66\server\ChangeBandwidthLimits.java | 88 |
| openr66\server\ConfigExport.java | 81 |
| openr66\server\ConfigImport.java | 87 |
writeSessionLimit+" "+readSessionLimit, LocalPacketFactory.BANDWIDTHPACKET);
DbHostAuth host = Configuration.configuration.HOST_SSLAUTH;
SocketAddress socketAddress = host.getSocketAddress();
boolean isSSL = host.isSsl();
LocalChannelReference localChannelReference = networkTransaction
.createConnectionWithRetry(socketAddress, isSSL, future);
socketAddress = null;
if (localChannelReference == null) {
host = null;
logger.error("Cannot Connect");
future.setResult(new R66Result(
new OpenR66ProtocolNoConnectionException("Cannot connect to server"),
null, true, ErrorCode.Internal, null));
future.setFailure(future.getResult().exception);
return;
}
localChannelReference.sessionNewState(R66FiniteDualStates.VALIDOTHER);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference, valid, false);
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
host = null;
valid = null;
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, null));
future.setFailure(e);
return;
}
host = null;
future.awaitUninterruptibly();
logger.info("Request done with "+(future.isSuccess()?"success":"error")); |
| File | Line |
|---|
| openr66\configuration\FileBasedConfiguration.java | 1458 |
| openr66\configuration\FileBasedConfiguration.java | 1506 |
public static boolean setConfigurationInitDatabase(Configuration config, String filename) {
Document document = null;
// Open config file
try {
document = new SAXReader().read(filename);
} catch (DocumentException e) {
logger.error("Unable to read the XML Config file: " + filename, e);
return false;
}
if (document == null) {
logger.error("Unable to read the XML Config file: " + filename);
return false;
}
configuration = XmlUtil.read(document, configServer);
hashConfig = new XmlHash(configuration);
if (! loadIdentity(config)) {
logger.error("Cannot load Identity");
return false;
}
if (!loadDatabase(config)) {
logger.error("Cannot load Database configuration");
return false;
}
if (! loadDirectory(config)) {
logger.error("Cannot load Directory configuration");
return false;
}
if (! loadLimit(config, false)) {
logger.error("Cannot load Limit configuration");
return false;
}
if (!DbConstant.admin.isConnected) {
// if no database, must load authentication from file
if (! loadAuthentication(config)) {
logger.error("Cannot load Authentication configuration");
return false;
}
} |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 1382 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 1481 |
String system = REQUEST.System.readFileUnique(this);
StringBuilder builder = new StringBuilder(system);
GgStringUtils.replace(builder, REPLACEMENT.XXXXSESSIONLIMITWXXX.toString(),
Long.toString(Configuration.configuration.serverChannelWriteLimit));
GgStringUtils.replace(builder, REPLACEMENT.XXXXSESSIONLIMITRXXX.toString(),
Long.toString(Configuration.configuration.serverChannelReadLimit));
GgStringUtils.replace(builder, REPLACEMENT.XXXXDELAYCOMMDXXX.toString(),
Long.toString(Configuration.configuration.delayCommander));
GgStringUtils.replace(builder, REPLACEMENT.XXXXDELAYRETRYXXX.toString(),
Long.toString(Configuration.configuration.delayRetry));
GgStringUtils.replace(builder, REPLACEMENT.XXXXCHANNELLIMITWXXX.toString(),
Long.toString(Configuration.configuration.serverGlobalWriteLimit));
GgStringUtils.replace(builder, REPLACEMENT.XXXXCHANNELLIMITRXXX.toString(),
Long.toString(Configuration.configuration.serverGlobalReadLimit)); |
| File | Line |
|---|
| openr66\server\ConfigImport.java | 92 |
| openr66\server\LogExport.java | 110 |
LocalChannelReference localChannelReference = networkTransaction
.createConnectionWithRetry(socketAddress, isSSL, future);
socketAddress = null;
if (localChannelReference == null) {
host = null;
logger.error("Cannot Connect");
future.setResult(new R66Result(
new OpenR66ProtocolNoConnectionException("Cannot connect to server"),
null, true, ErrorCode.Internal, null));
future.setFailure(future.getResult().exception);
return;
}
localChannelReference.sessionNewState(R66FiniteDualStates.VALIDOTHER);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference, valid, false);
} catch (OpenR66ProtocolPacketException e) {
logger.error("Bad Protocol", e);
Channels.close(localChannelReference.getLocalChannel());
localChannelReference = null;
host = null;
valid = null;
future.setResult(new R66Result(e, null, true,
ErrorCode.TransferError, null));
future.setFailure(e);
return;
}
host = null;
future.awaitUninterruptibly();
logger.debug("Request done with "+(future.isSuccess()?"success":"error")); |
| File | Line |
|---|
| openr66\database\data\DbTaskRunner.java | 1463 |
| openr66\database\data\DbTaskRunner.java | 1500 |
DbSession session, boolean in)
throws GoldenGateDatabaseNoConnectionException, GoldenGateDatabaseSqlException {
String request = "SELECT COUNT(" + Columns.SPECIALID.name() + ") FROM " + table;
String requesterd;
String from = Configuration.configuration.HOST_ID;
String sfrom = Configuration.configuration.HOST_SSLID;
if (in) {
requesterd = Columns.REQUESTED.name();
} else {
requesterd = Columns.REQUESTER.name();
}
if (from != null & sfrom != null) {
request += " WHERE ((" + requesterd + " = '" +
from + "' OR " + requesterd + " = '" +sfrom+ "') ";
} else if (from != null) {
request += " WHERE (" + requesterd + " = '" + from + "' ";
} else {
request += " WHERE (" + requesterd + " = '" + sfrom+ "' ";
}
request += " AND "+getLimitWhereCondition()+") ";
request += " AND "+Columns.STARTTRANS.name() + " >= ? "; |
| File | Line |
|---|
| openr66\protocol\test\TestRecvThroughClient.java | 120 |
| openr66\protocol\test\TestSendThroughClient.java | 198 |
}
} else {
if (result == null || result.runner == null) {
logger.warn("Transfer in Error with no Id", future.getCause());
networkTransaction.closeAll();
System.exit(1);
}
if (result.runner.getErrorInfo() == ErrorCode.Warning) {
logger.warn("Transfer in Warning with Id: " +
result.runner.getSpecialId(), future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
} else {
logger.error("Transfer in Error with Id: " +
result.runner.getSpecialId(), future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
}
}
} finally {
networkTransaction.closeAll();
}
}
} |
| File | Line |
|---|
| openr66\configuration\FileBasedConfiguration.java | 1534 |
| openr66\configuration\FileBasedConfiguration.java | 1616 |
logger.error("Cannot load Limit configuration");
return false;
}
if (!DbConstant.admin.isConnected) {
// if no database, must load authentication from file
if (! loadAuthentication(config)) {
logger.error("Cannot load Authentication configuration");
return false;
}
}
config.HOST_AUTH = R66Auth.getServerAuth(
DbConstant.admin.session, config.HOST_ID);
if (config.HOST_AUTH == null &&
config.useNOSSL) {
logger.error("Cannot find Authentication for current host");
return false;
}
if (config.HOST_SSLID != null) {
config.HOST_SSLAUTH = R66Auth.getServerAuth(
DbConstant.admin.session,
config.HOST_SSLID);
if (config.HOST_SSLAUTH == null &&
config.useSSL) {
logger.error("Cannot find SSL Authentication for current host");
return false;
}
}
hashConfig.clear();
hashConfig = null;
configuration = null;
return true;
}
/**
* Initiate the configuration from the xml file for server shutdown
*
* @param filename
* @return True if OK
*/
public static boolean setConfigurationServerShutdownFromXml(Configuration config, String filename) { |
| File | Line |
|---|
| openr66\database\model\DbModelOracle.java | 193 |
| openr66\database\model\DbModelPostgresql.java | 189 |
return;
} finally {
request.close();
}
// Index Runner
action = "CREATE INDEX IDX_RUNNER ON "+ DbTaskRunner.table + "(";
DbTaskRunner.Columns[] icolumns = DbTaskRunner.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 " + DbTaskRunner.fieldseq +
" MINVALUE " + (DbConstant.ILLEGALVALUE + 1)+ |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 695 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 726 |
body = REQUEST.CancelRestart.readBody();
body = taskRunner.toSpecializedHtml(authentHttp, body,
lcr != null ? "Active" : "NotActive");
String tstart = taskRunner.getStart().toString();
tstart = tstart.substring(0, tstart.length());
String tstop = taskRunner.getStop().toString();
tstop = tstop.substring(0, tstop.length());
head = resetOptionTransfer(head, (taskRunner.getSpecialId()-1)+"",
(taskRunner.getSpecialId()+1)+"", tstart, tstop,
taskRunner.getRuleId(), taskRunner.getRequested(),
false, false, false, false, true);
} |
| File | Line |
|---|
| openr66\context\task\ExecMoveTask.java | 101 |
| openr66\context\task\ExecOutputTask.java | 106 |
| openr66\context\task\ExecTask.java | 89 |
move(result.status, result.result, finalname);
localExecClient.disconnect();
return;
} // else continue
}
String[] args = finalname.split(" ");
File exec = new File(args[0]);
if (exec.isAbsolute()) {
if (! exec.canExecute()) {
logger.error("Exec command is not executable: " + finalname);
R66Result result = new R66Result(session, false,
ErrorCode.CommandNotFound, session.getRunner());
futureCompletion.setResult(result);
futureCompletion.cancel();
return;
}
}
CommandLine commandLine = new CommandLine(args[0]);
for (int i = 1; i < args.length; i ++) {
commandLine.addArgument(args[i]);
}
DefaultExecutor defaultExecutor = new DefaultExecutor(); |
| File | Line |
|---|
| openr66\protocol\test\TestRecvThroughClient.java | 104 |
| openr66\protocol\test\TestSendThroughClient.java | 174 |
future.awaitUninterruptibly();
long time2 = System.currentTimeMillis();
long delay = time2 - time1;
R66Result result = future.getResult();
if (future.isSuccess()) {
if (result.runner.getErrorInfo() == ErrorCode.Warning) {
logger.warn("Warning with Id: " +
result.runner.getSpecialId()+" on file: " +
(result.file != null? result.file.toString() : "no file")
+" delay: "+delay);
} else {
logger.warn("Success with Id: " +
result.runner.getSpecialId()+" on Final file: " +
(result.file != null? result.file.toString() : "no file")
+" delay: "+delay);
} |
| File | Line |
|---|
| openr66\configuration\FileBasedConfiguration.java | 1534 |
| openr66\configuration\FileBasedConfiguration.java | 1616 |
| openr66\configuration\FileBasedConfiguration.java | 1701 |
logger.error("Cannot load Limit configuration");
return false;
}
if (!DbConstant.admin.isConnected) {
// if no database, must load authentication from file
if (! loadAuthentication(config)) {
logger.error("Cannot load Authentication configuration");
return false;
}
}
config.HOST_AUTH = R66Auth.getServerAuth(
DbConstant.admin.session, config.HOST_ID);
if (config.HOST_AUTH == null &&
config.useNOSSL) {
logger.error("Cannot find Authentication for current host");
return false;
}
if (config.HOST_SSLID != null) {
config.HOST_SSLAUTH = R66Auth.getServerAuth(
DbConstant.admin.session,
config.HOST_SSLID);
if (config.HOST_SSLAUTH == null &&
config.useSSL) {
logger.error("Cannot find SSL Authentication for current host");
return false;
}
} |
| File | Line |
|---|
| openr66\database\model\DbModelMysql.java | 194 |
| openr66\database\model\DbModelOracle.java | 193 |
return;
} finally {
request.close();
}
// Index Runner
action = "CREATE INDEX IDX_RUNNER ON "+ DbTaskRunner.table + "(";
DbTaskRunner.Columns[] icolumns = DbTaskRunner.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 |
|---|
| openr66\commander\Commander.java | 295 |
| openr66\commander\Commander.java | 412 |
hostAuth = null;
}
} catch (GoldenGateDatabaseNoConnectionException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database No Connection Error: Cannot execute Commander", e);
return;
} catch (GoldenGateDatabaseSqlException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database SQL Error: Cannot execute Commander", e);
return;
} catch (GoldenGateDatabaseException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database Error: Cannot execute Commander", e);
return;
} finally { |
| File | Line |
|---|
| openr66\configuration\FileBasedConfiguration.java | 1458 |
| openr66\configuration\FileBasedConfiguration.java | 1506 |
| openr66\configuration\FileBasedConfiguration.java | 1573 |
| openr66\configuration\FileBasedConfiguration.java | 1654 |
public static boolean setConfigurationInitDatabase(Configuration config, String filename) {
Document document = null;
// Open config file
try {
document = new SAXReader().read(filename);
} catch (DocumentException e) {
logger.error("Unable to read the XML Config file: " + filename, e);
return false;
}
if (document == null) {
logger.error("Unable to read the XML Config file: " + filename);
return false;
}
configuration = XmlUtil.read(document, configServer);
hashConfig = new XmlHash(configuration);
if (! loadIdentity(config)) {
logger.error("Cannot load Identity");
return false;
}
if (!loadDatabase(config)) {
logger.error("Cannot load Database configuration");
return false;
}
if (! loadDirectory(config)) { |
| File | Line |
|---|
| openr66\commander\Commander.java | 241 |
| openr66\commander\Commander.java | 297 |
| openr66\commander\Commander.java | 414 |
} catch (GoldenGateDatabaseNoConnectionException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database No Connection Error: Cannot execute Commander", e);
return;
} catch (GoldenGateDatabaseSqlException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database SQL Error: Cannot execute Commander", e);
return;
} catch (GoldenGateDatabaseException e) {
try {
DbModelFactory.dbModel.validConnection(DbConstant.admin.session);
} catch (GoldenGateDatabaseNoConnectionException e1) {
}
logger.error("Database Error: Cannot execute Commander", e);
return;
} finally { |
| File | Line |
|---|
| openr66\server\ConfigExport.java | 183 |
| openr66\server\LogExport.java | 285 |
logger.warn("SUCCESS on Final files:\n " +
(result.other != null? ((ValidPacket)result.other).getSheader() :
"no file")
+"\n delay: "+delay);
}
} else {
if (result.code == ErrorCode.Warning) {
logger.warn("Transfer is\n WARNED", future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
} else {
logger.error("Transfer in\n FAILURE", future.getCause());
networkTransaction.closeAll();
System.exit(result.code.ordinal());
}
}
} finally {
networkTransaction.closeAll();
}
}
} |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 505 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 578 |
all = true;
}
Timestamp tstart = GgStringUtils.fixDate(start);
if (tstart != null) {
start = tstart.toString();
}
Timestamp tstop = GgStringUtils.fixDate(stop, tstart);
if (tstop != null) {
stop = tstop.toString();
}
head = resetOptionTransfer(head, startid == null ? "":startid,
stopid == null ? "":stopid, start, stop,
rule == null ? "":rule, req == null ? "":req,
pending, transfer, error, done, all);
body = REQUEST.CancelRestart.readBody(); |
| File | Line |
|---|
| openr66\context\filesystem\R66File.java | 470 |
| openr66\context\filesystem\R66File.java | 523 |
File newFile = getFileFromPath(path);
if (newFile.getParentFile().canWrite()) {
if (!file.renameTo(newFile)) {
FileOutputStream fileOutputStream;
try {
fileOutputStream = new FileOutputStream(newFile);
} catch (FileNotFoundException e) {
logger
.warn("Cannot find file: " + newFile.getName(),
e);
return false;
}
FileChannel fileChannelOut = fileOutputStream.getChannel();
if (get(fileChannelOut)) {
delete();
} else {
try {
fileChannelOut.close();
} catch (IOException e) {
}
logger.error("Cannot write file: {}", newFile);
return false;
}
}
currentFile = getRelativePath(newFile); |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 971 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 1014 |
} else if ("TestConn".equalsIgnoreCase(parm)) {
String host = getTrimValue("host");
String addr = getTrimValue("address");
String port = getTrimValue("port");
String key = getTrimValue("hostkey");
boolean ssl, admin, isclient;
ssl = params.containsKey("ssl");
admin = params.containsKey("admin");
isclient = params.containsKey("isclient");
head = resetOptionHosts(head, host, addr, ssl);
int iport = Integer.parseInt(port);
DbHostAuth dbhost = new DbHostAuth(dbSession, host, addr, iport,
ssl, key.getBytes(), admin, isclient); |
| File | Line |
|---|
| openr66\configuration\RuleFileBasedConfiguration.java | 481 |
| openr66\configuration\RuleFileBasedConfiguration.java | 495 |
| openr66\configuration\RuleFileBasedConfiguration.java | 509 |
| openr66\configuration\RuleFileBasedConfiguration.java | 523 |
| openr66\configuration\RuleFileBasedConfiguration.java | 537 |
if (array != null) {
for (rank = 0; rank < array.length; rank++) {
Element task = new DefaultElement(XTASK);
task.add(newElement(DbRule.TASK_TYPE, array[rank][0]));
task.add(newElement(DbRule.TASK_PATH, array[rank][1]));
task.add(newElement(DbRule.TASK_DELAY, array[rank][2]));
roottasks.add(task);
}
}
tasks.add(roottasks);
root.add(tasks);
tasks = new DefaultElement(XRPOSTTASKS); |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 196 |
| openr66\database\model\DbModelMysql.java | 199 |
| openr66\database\model\DbModelOracle.java | 198 |
| openr66\database\model\DbModelPostgresql.java | 194 |
action = "CREATE INDEX IF NOT EXISTS IDX_RUNNER ON "+ DbTaskRunner.table + "(";
DbTaskRunner.Columns[] icolumns = DbTaskRunner.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 " + DbTaskRunner.fieldseq + |
| File | Line |
|---|
| openr66\protocol\http\adminssl\HttpSslHandler.java | 401 |
| openr66\protocol\http\adminssl\HttpSslHandler.java | 578 |
all = true;
}
Timestamp tstart = GgStringUtils.fixDate(start);
if (tstart != null) {
start = tstart.toString();
}
Timestamp tstop = GgStringUtils.fixDate(stop, tstart);
if (tstop != null) {
stop = tstop.toString();
}
head = resetOptionTransfer(head, startid == null ? "":startid,
stopid == null ? "":stopid, start, stop,
rule == null ? "":rule, req == null ? "":req,
pending, transfer, error, done, all);
body = REQUEST.Listing.readBody(); |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 119 |
| openr66\database\model\DbModelMysql.java | 122 |
| openr66\database\model\DbModelOracle.java | 122 |
| openr66\database\model\DbModelPostgresql.java | 117 |
return;
} finally {
request.close();
}
// hosts
action = createTableH2 + DbHostAuth.table + "(";
DbHostAuth.Columns[] hcolumns = DbHostAuth.Columns.values();
for (int i = 0; i < hcolumns.length - 1; i ++) {
action += hcolumns[i].name() +
DBType.getType(DbHostAuth.dbTypes[i]) + notNull + ", ";
}
action += hcolumns[hcolumns.length - 1].name() +
DBType.getType(DbHostAuth.dbTypes[hcolumns.length - 1]) + |
| File | Line |
|---|
| openr66\protocol\localhandler\LocalServerHandler.java | 1863 |
| openr66\protocol\localhandler\LocalServerHandler.java | 1974 |
}
}
R66Result result = null;
if (brule || bhost) {
result = new R66Result(session, true, ErrorCode.CompleteOk, null);
} else {
result = new R66Result(session, true, ErrorCode.TransferError, null);
}
// Now answer
ValidPacket valid = new ValidPacket(shost+" "+srule, result.code.getCode(),
LocalPacketFactory.REQUESTUSERPACKET);
localChannelReference.validateRequest(result);
try {
ChannelUtils.writeAbstractLocalPacket(localChannelReference,
valid, true);
} catch (OpenR66ProtocolPacketException e) {
}
Channels.close(channel);
break;
}
case LocalPacketFactory.CONFIMPORTPACKET: { |
| File | Line |
|---|
| openr66\client\Message.java | 147 |
| openr66\client\RequestInformation.java | 157 |
logger.debug("Requested host cannot be found: "+requested);
R66Result result = new R66Result(null, true, ErrorCode.ConnectionImpossible, null);
this.future.setResult(result);
this.future.cancel();
return;
}
if (host.isClient()) {
logger.error("Requested host is a client and cannot be requested: "+requested);
R66Result result = new R66Result(null, true, ErrorCode.ConnectionImpossible, null);
this.future.setResult(result);
this.future.cancel();
return;
}
SocketAddress socketAddress = host.getSocketAddress();
boolean isSSL = host.isSsl();
LocalChannelReference localChannelReference = null; |
| File | Line |
|---|
| openr66\context\task\RescheduleTransferTask.java | 224 |
| openr66\context\task\RescheduleTransferTask.java | 267 |
String[] elmts = args[i].split(";");
boolean startModified = false;
String[] values = elmts[0].split(":");
Calendar start = getCalendar(values);
if (start != null) {
startModified = true;
} else {
start = Calendar.getInstance();
}
boolean stopModified = false;
values = elmts[1].split(":");
Calendar stop = getCalendar(values);
if (stop != null) {
stopModified = true;
} else {
stop = Calendar.getInstance();
}
logger.debug("Dates before check: Not between "+start.getTime()+" and "+stop.getTime()); |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 61 |
| openr66\database\model\DbModelMysql.java | 64 |
| openr66\database\model\DbModelOracle.java | 63 |
| openr66\database\model\DbModelPostgresql.java | 59 |
String primaryKey = " PRIMARY KEY ";
String notNull = " NOT NULL ";
// Multiple Mode
String action = createTableH2 + DbMultipleMonitor.table + "(";
DbMultipleMonitor.Columns[] mcolumns = DbMultipleMonitor.Columns
.values();
for (int i = 0; i < mcolumns.length - 1; i ++) {
action += mcolumns[i].name() +
DBType.getType(DbMultipleMonitor.dbTypes[i]) + notNull +
", ";
}
action += mcolumns[mcolumns.length - 1].name() +
DBType.getType(DbMultipleMonitor.dbTypes[mcolumns.length - 1]) + |
| File | Line |
|---|
| openr66\configuration\RuleFileBasedConfiguration.java | 481 |
| openr66\configuration\RuleFileBasedConfiguration.java | 495 |
| openr66\configuration\RuleFileBasedConfiguration.java | 509 |
| openr66\configuration\RuleFileBasedConfiguration.java | 523 |
| openr66\configuration\RuleFileBasedConfiguration.java | 537 |
| openr66\configuration\RuleFileBasedConfiguration.java | 551 |
if (array != null) {
for (rank = 0; rank < array.length; rank++) {
Element task = new DefaultElement(XTASK);
task.add(newElement(DbRule.TASK_TYPE, array[rank][0]));
task.add(newElement(DbRule.TASK_PATH, array[rank][1]));
task.add(newElement(DbRule.TASK_DELAY, array[rank][2]));
roottasks.add(task);
}
}
tasks.add(roottasks);
root.add(tasks); |
| File | Line |
|---|
| openr66\database\model\DbModelH2.java | 142 |
| openr66\database\model\DbModelMysql.java | 145 |
| openr66\database\model\DbModelOracle.java | 145 |
| openr66\database\model\DbModelPostgresql.java | 140 |
return;
} finally {
request.close();
}
// rules
action = createTableH2 + DbRule.table + "(";
DbRule.Columns[] rcolumns = DbRule.Columns.values();
for (int i = 0; i < rcolumns.length - 1; i ++) {
action += rcolumns[i].name() +
DBType.getType(DbRule.dbTypes[i]) + ", ";
}
action += rcolumns[rcolumns.length - 1].name() +
DBType.getType(DbRule.dbTypes[rcolumns.length - 1]) + |
| File | Line |
|---|
| openr66\database\data\DbTaskRunner.java | 708 |
| openr66\database\data\DbTaskRunner.java | 746 |
public void insert() throws GoldenGateDatabaseException {
if (isSaved) {
return;
}
if (dbSession == null) {
if (specialId == DbConstant.ILLEGALVALUE) {
// New SpecialId is not possible with No Database Model
createNoDbSpecialId();
}
isSaved = true;
if (Configuration.configuration.saveTaskRunnerWithNoDb) {
try {
setToArray();
this.writeXmlWorkNoDb();
} catch (OpenR66ProtocolBusinessException e) {
// Ignore
}
}
if (this.updatedInfo == UpdatedInfo.TOSUBMIT.ordinal()) {
addNoDb();
}
return;
}
// First need to find a new id if id is not ok
if (specialId == DbConstant.ILLEGALVALUE) {
specialId = DbModelFactory.dbModel.nextSequence(dbSession);
logger.debug("Try Insert create a new Id from sequence: " + |
| File | Line |
|---|
| openr66\client\SendThroughClient.java | 143 |
| openr66\protocol\test\TestSendThroughForward.java | 159 |
logger = GgInternalLoggerFactory.getLogger(SendThroughClient.class);
}
DbRule rule;
try {
rule = new DbRule(DbConstant.admin.session, rulename);
} catch (GoldenGateDatabaseException e) {
logger.error("Cannot get Rule: "+rulename, e);
future.setResult(new R66Result(new OpenR66DatabaseGlobalException(e), null, true,
ErrorCode.Internal,null));
future.setFailure(e);
return false;
}
int mode = rule.mode;
if (isMD5) {
mode = RequestPacket.getModeMD5(mode);
}
RequestPacket request = new RequestPacket(rulename,
mode, filename, blocksize, 0, |
| File | Line |
|---|
| openr66\configuration\FileBasedConfiguration.java | 582 |
| openr66\configuration\FileBasedConfiguration.java | 594 |
new XmlDecl(XML_NETWORK, XmlType.XVAL, XML_ROOT+XML_NETWORK, configNetworkServerDecls, false),
new XmlDecl(XML_SSL, XmlType.XVAL, XML_ROOT+XML_SSL, configSslDecls, false),
new XmlDecl(XML_DIRECTORY, XmlType.XVAL, XML_ROOT+XML_DIRECTORY, configDirectoryDecls, false),
new XmlDecl(XML_LIMIT, XmlType.XVAL, XML_ROOT+XML_LIMIT, configLimitDecls, false),
new XmlDecl(XML_DB, XmlType.XVAL, XML_ROOT+XML_DB, configDbDecls, false),
new XmlDecl(XML_BUSINESS, XmlType.STRING, XML_ROOT+XML_BUSINESS+"/"+XML_BUSINESSID, true)
};
/**
* Global Structure for Client Configuration
*/
private static final XmlDecl[] configClient = { |
| File | Line |
|---|
| openr66\protocol\test\TestSubmitTransfer.java | 42 |
| openr66\protocol\test\TestTransferNoDb.java | 46 |
public class TestSubmitTransfer extends SubmitTransfer {
static int nb = 100;
/**
* @param args
* @param rank
* @return True if OK
*/
protected static boolean getSpecialParams(String []args, int rank) {
for (int i = rank; i<args.length; i++) {
if (args[i].equalsIgnoreCase("-nb")) {
i++;
nb = Integer.parseInt(args[i]);
} else if (args[i].equalsIgnoreCase("-md5")) {
} else if (args[i].charAt(0) == '-') {
i++;// jump one
}
}
return true;
}
public TestSubmitTransfer(R66Future future, String remoteHost, |
| File | Line |
|---|
| openr66\context\task\ExecMoveTask.java | 150 |
| openr66\context\task\ExecOutputTask.java | 154 |
Thread thread = new Thread(lastLineReader, "ExecRename" + session.getRunner().getSpecialId());
thread.setDaemon(true);
Configuration.configuration.getExecutorService().execute(thread);
int status = -1;
try {
status = defaultExecutor.execute(commandLine);
} catch (ExecuteException e) {
if (e.getExitValue() == -559038737) {
// Cannot run immediately so retry once
try {
Thread.sleep(Configuration.RETRYINMS);
} catch (InterruptedException e1) {
}
try {
status = defaultExecutor.execute(commandLine);
} catch (ExecuteException e1) { |
