Package | Description |
---|---|
org.waarp.common.database |
Classes implementing Database access
|
org.waarp.common.database.data |
Classes implementing Database Data model
|
org.waarp.common.database.model |
Classes implementing Database Model (H2, Oracle, PostgreSQL, MySQL, MariaDB)
|
org.waarp.gateway.ftp.database.data |
Classes implementing Database Data model
|
org.waarp.gateway.ftp.database.model |
Classes implementing Database Model (H2, Oracle, PostgreSQL, MySQL)
|
org.waarp.gateway.kernel.database.data |
Classes implementing Database Data model
|
org.waarp.gateway.kernel.database.model |
Classes implementing Database Model (H2, Oracle, PostgreSQL, MySQL)
|
org.waarp.openr66.commander |
Classes implementing Commander, reader of database updates from clients
|
org.waarp.openr66.configuration |
Classes implementing Configuration loading from database or files
|
org.waarp.openr66.database.data |
Classes implementing Database Data model
|
org.waarp.openr66.protocol.configuration |
Class implementing Configuration
|
Modifier and Type | Method and Description |
---|---|
void |
DbSession.commit()
Commit everything
|
void |
DbAdmin.commit()
Commit on connection (since in autocommit, should not be used)
|
void |
DbPreparedStatement.createPrepareStatement(String requestarg)
Create a preparedStatement from request
|
void |
DbPreparedStatement.executeQuery()
Execute a Select preparedStatement
|
int |
DbPreparedStatement.executeUpdate()
Execute the Update/Insert/Delete preparedStatement
|
boolean |
DbPreparedStatement.getNext()
Move the cursor to the next result
|
boolean |
DbRequest.getNext()
Move the cursor to the next result
|
int |
DbRequest.query(String query)
Execute a UPDATE/INSERT/DELETE statement and returns the number of row.
|
void |
DbSession.recreateLongTermPreparedStatements()
Due to a reconnection, recreate all associated long term
PreparedStatements
|
void |
DbPreparedStatement.recreatePreparedStatement()
In case of closing database connection, it is possible to reopen a long
term preparedStatement as it was at
creation.
|
void |
DbSession.releaseSavepoint(Savepoint savepoint)
Release the savepoint
|
void |
DbSession.rollback(Savepoint savepoint)
Rollback from the savepoint or the last set if null
|
Savepoint |
DbSession.savepoint()
Make a savepoint
|
void |
DbRequest.select(String select)
Execute a SELECT statement and set of Result.
|
void |
DbRequest.select(String select,
int timeout)
Execute a SELECT statement and set of Result.
|
Constructor and Description |
---|
DbPreparedStatement(DbSession ls,
String request)
Create a DbPreparedStatement from DbSession object and a request
|
DbPreparedStatement(DbSession ls,
String request,
int nbFetch)
Create a DbPreparedStatement from DbSession object and a request
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractDbData.getTrueValue(ResultSet rs,
DbValue value)
Get one value into DbValue from ResultSet
|
static DbPreparedStatement |
DbDataModel.getUpdatedPrepareStament(DbSession session) |
protected void |
AbstractDbData.getValue(DbPreparedStatement preparedStatement,
DbValue value)
Get one value into DbValue from DbPreparedStatement
|
String |
DbValue.getValueAsString() |
protected void |
AbstractDbData.getValues(DbPreparedStatement preparedStatement,
DbValue[] values)
Get several values into DbValue from DbPreparedStatement
|
protected void |
DbDataModel.setFromArray() |
protected abstract void |
AbstractDbData.setFromArray()
Internal function to retrieve data from Array to pull data from database
|
void |
AbstractDbData.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
boolean ignorePrimaryKey)
Set the values from the Json node to the current object (no database
access)
|
static void |
AbstractDbData.setTrueValue(PreparedStatement ps,
DbValue value,
int rank)
Set Value into PreparedStatement
|
protected void |
AbstractDbData.setValue(DbPreparedStatement preparedStatement,
DbValue value)
Set one value to a DbPreparedStatement
|
void |
DbValue.setValueFromString(String svalue) |
protected void |
AbstractDbData.setValues(DbPreparedStatement preparedStatement,
DbValue[] values)
Set several values to a DbPreparedStatement
|
Modifier and Type | Method and Description |
---|---|
long |
DbModelCommonMariadbMySql.nextSequence(DbSession dbSession) |
long |
DbModelOracle.nextSequence(DbSession dbSession) |
long |
DbModelPostgresql.nextSequence(DbSession dbSession) |
long |
DbModel.nextSequence(DbSession dbSession) |
long |
DbModelH2.nextSequence(DbSession dbSession) |
long |
EmptyDbModel.nextSequence(DbSession dbSession) |
Modifier and Type | Method and Description |
---|---|
static void |
DbTransferLog.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt)
Set the current time in the given updatedPreparedStatement
|
static void |
DbTransferLog.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt,
long time)
Set the current time in the given updatedPreparedStatement
|
static DbPreparedStatement |
DbTransferLog.getCountAllPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTransferLog.getCountInfoPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTransferLog.getCountInOutErrorPrepareStatement(DbSession session,
boolean in)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTransferLog.getCountInOutRunningPrepareStatement(DbSession session,
boolean in,
boolean running)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTransferLog.getCountStatusPrepareStatement(DbSession session) |
static DbTransferLog |
DbTransferLog.getFromStatement(DbPreparedStatement preparedStatement)
For instance when getting updated information
|
static DbPreparedStatement |
DbTransferLog.getLogPrepareStament(DbSession session,
Timestamp start,
Timestamp stop) |
static DbPreparedStatement |
DbTransferLog.getLogPrepareStament(DbSession session,
Timestamp start,
Timestamp stop,
ReplyCode status) |
static DbPreparedStatement |
DbTransferLog.getStatusPrepareStament(DbSession session,
ReplyCode status,
int limit) |
protected void |
DbTransferLog.setFromArray() |
Modifier and Type | Method and Description |
---|---|
long |
DbModelH2Ftp.nextSequence(DbSession dbSession) |
long |
DbModelMariaDbFtp.nextSequence(DbSession dbSession) |
long |
DbModelMysqlFtp.nextSequence(DbSession dbSession) |
long |
DbModelOracleFtp.nextSequence(DbSession dbSession) |
long |
DbModelPostgresqlFtp.nextSequence(DbSession dbSession) |
Modifier and Type | Method and Description |
---|---|
static void |
DbTransferLog.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt)
Set the current time in the given updatedPreparedStatement
|
static void |
DbTransferLog.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt,
long time)
Set the current time in the given updatedPreparedStatement
|
static DbPreparedStatement |
DbTransferLog.getCountAllPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTransferLog.getCountInfoPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTransferLog.getCountInOutErrorPrepareStatement(DbSession session,
boolean in)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTransferLog.getCountInOutRunningPrepareStatement(DbSession session,
boolean in,
boolean running)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTransferLog.getCountStatusPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTransferLog.getFilterPrepareStament(DbSession session,
String modetrans,
String accountid,
String userid,
String filename,
String status) |
static DbTransferLog |
DbTransferLog.getFromStatement(DbPreparedStatement preparedStatement)
For instance when getting updated information
|
static DbPreparedStatement |
DbTransferLog.getLogPrepareStament(DbSession session,
Timestamp start,
Timestamp stop) |
static DbPreparedStatement |
DbTransferLog.getStatusPrepareStament(DbSession session,
io.netty.handler.codec.http.HttpResponseStatus status,
int limit) |
protected void |
DbTransferLog.setFromArray() |
Modifier and Type | Method and Description |
---|---|
long |
DbModelH2Kernel.nextSequence(DbSession dbSession) |
long |
DbModelMariaDbKernel.nextSequence(DbSession dbSession) |
long |
DbModelMysqlKernel.nextSequence(DbSession dbSession) |
long |
DbModelOracleKernel.nextSequence(DbSession dbSession) |
long |
DbModelPostgresqlKernel.nextSequence(DbSession dbSession) |
static long |
DbModelFactoryGateway.nextSequenceMonitoring(DbSession dbSession) |
static long |
DbModelOracleKernel.nextSequenceMonitoring(DbSession dbSession) |
static long |
DbModelMysqlKernel.nextSequenceMonitoring(DbSession dbSession,
ReentrantLock lock) |
Modifier and Type | Method and Description |
---|---|
void |
InternalRunner.reloadInternalRunner() |
Constructor and Description |
---|
Commander(InternalRunner runner)
Prepare requests that will be executed from time to time
|
Commander(InternalRunner runner,
boolean fromStartup)
Prepare requests that will be executed from time to time
|
InternalRunner()
Create the structure to enable submission by database
|
Modifier and Type | Method and Description |
---|---|
static DbRule |
RuleFileBasedConfiguration.getFromFile(File file)
Load and update a Rule from a file
|
static List<DbRule> |
RuleFileBasedConfiguration.getMultipleFromFile(File file)
Load and update multiple Rules from one file
|
static String |
RuleFileBasedConfiguration.writeOneXml(String directory,
String hostname)
Write to directory 1 file prefixed by hostname all Rules from database
|
static void |
AuthenticationFileBasedConfiguration.writeXML(Configuration config,
String filename)
Write all authentication to a file with filename
|
static void |
RuleFileBasedConfiguration.writeXml(String directory,
String hostname)
Write to directory files prefixed by hostname all Rules from database
|
Modifier and Type | Method and Description |
---|---|
static void |
DbTaskRunner.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt,
long time)
Set the current time in the given updatedPreparedStatement
|
static DbPreparedStatement |
DbTaskRunner.getCountInfoPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTaskRunner.getCountInOutErrorPrepareStatement(DbSession session,
boolean in)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTaskRunner.getCountInOutRunningPrepareStatement(DbSession session,
boolean in,
boolean running)
Running or not transfers are concerned
|
static DbPreparedStatement |
DbTaskRunner.getCountStatusPrepareStatement(DbSession session) |
static DbPreparedStatement |
DbTaskRunner.getCountStatusRunningPrepareStatement(DbSession session,
ErrorCode status)
Only running transfers
|
static DbPreparedStatement |
DbTaskRunner.getCountStepPrepareStatement(DbSession session,
DbTaskRunner.TASKSTEP globalstep) |
static DbPreparedStatement |
DbRule.getFilterPrepareStament(DbSession session,
String rule,
int mode) |
static DbPreparedStatement |
DbConfiguration.getFilterPrepareStament(DbSession session,
String hostid,
long limitBandwith) |
static DbPreparedStatement |
DbHostAuth.getFilterPrepareStament(DbSession session,
String host,
String addr) |
static DbPreparedStatement |
DbHostAuth.getFilterPrepareStament(DbSession session,
String host,
String addr,
boolean ssl,
boolean active) |
static DbPreparedStatement |
DbHostConfiguration.getFilterPrepareStament(DbSession session,
String hostid,
String business,
String role,
String alias,
String other) |
static DbPreparedStatement |
DbTaskRunner.getFilterPrepareStatement(DbSession session,
int limit,
boolean orderBySpecialId,
String startid,
String stopid,
Timestamp start,
Timestamp stop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error,
boolean done,
boolean all) |
static DbPreparedStatement |
DbTaskRunner.getFilterPrepareStatement(DbSession session,
int limit,
boolean orderBySpecialId,
String startid,
String stopid,
Timestamp start,
Timestamp stop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error,
boolean done,
boolean all,
String owner) |
static DbHostAuth |
DbHostAuth.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbConfiguration |
DbConfiguration.getFromStatement(DbPreparedStatement statement) |
static DbMultipleMonitor |
DbMultipleMonitor.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbRule |
DbRule.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbHostConfiguration |
DbHostConfiguration.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbTaskRunner |
DbTaskRunner.getFromStatement(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
|
static DbTaskRunner |
DbTaskRunner.getFromStatementNoDbRule(DbPreparedStatement preparedStatement)
For REST interface, to prevent DbRule issue
|
static DbTaskRunner |
DbTaskRunner.getFromStatementNoRule(DbPreparedStatement preparedStatement)
For instance from Commander when getting updated information
This version tries to load DbRule but will not make any error if not found!
|
static String |
DbHostAuth.getJson(DbPreparedStatement preparedStatement,
int limit)
Write selected DbHostAuth to a Json String
|
static String |
DbRule.getJson(DbPreparedStatement preparedStatement,
int limit)
Write selected DbRule to a Json String
|
static String |
DbTaskRunner.getJson(DbPreparedStatement preparedStatement,
int limit)
Write selected TaskRunners to a Json String
|
static DbPreparedStatement |
DbTaskRunner.getLogPrepareStatement(DbSession session,
Timestamp start,
Timestamp stop) |
static DbTaskRunner[] |
DbTaskRunner.getSelectFromInfoPrepareStatement(AbstractDbData.UpdatedInfo info,
boolean orderByStart,
int limit) |
static DbConfiguration[] |
DbConfiguration.getUpdatedPrepareStament() |
static DbRule[] |
DbRule.getUpdatedPrepareStament() |
static DbHostConfiguration[] |
DbHostConfiguration.getUpdatedPrepareStament() |
static DbPreparedStatement |
DbMultipleMonitor.getUpdatedPrepareStament(DbSession session) |
protected void |
AbstractDbDataDao.getValues(DbPreparedStatement preparedStatement,
DbValue[] values)
|
static int |
DbTaskRunner.purgeLogPrepareStatement(DbSession session,
String startid,
String stopid,
Timestamp start,
Timestamp stop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error,
boolean done,
boolean all) |
static int |
DbTaskRunner.purgeLogPrepareStatement(DbSession session,
Timestamp start,
Timestamp stop)
purge in same interval all runners with globallaststep as ALLDONETASK or
UpdatedInfo as Done
|
protected void |
AbstractDbDataDao.setFromArray()
|
void |
DbHostAuth.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
boolean ignorePrimaryKey) |
void |
DbConfiguration.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
boolean ignorePrimaryKey)
Read json object into Array then setFromArray
|
void |
AbstractDbDataDao.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
boolean ignorePrimaryKey)
Set the values from the Json node to the current object (no database
access)
|
void |
DbRule.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
boolean ignorePrimaryKey) |
void |
DbTaskRunner.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode source,
boolean ignorePrimaryKey) |
static NbAndSpecialId |
DbTaskRunner.writeXML(DbPreparedStatement preparedStatement,
org.dom4j.io.XMLWriter xmlWriter)
Write the selected TaskRunners from PrepareStatement to a XMLWriter
|
static NbAndSpecialId |
DbTaskRunner.writeXMLWriter(DbPreparedStatement preparedStatement,
String filename)
Write selected TaskRunners to an XML file using an XMLWriter
|
static void |
DbTaskRunner.writeXMLWriter(String filename)
Write all TaskRunners to an XML file using an XMLWriter
|
Constructor and Description |
---|
DbConfiguration(com.fasterxml.jackson.databind.node.ObjectNode source)
Constructor from Json
|
DbHostAuth(com.fasterxml.jackson.databind.node.ObjectNode source) |
DbHostConfiguration(com.fasterxml.jackson.databind.node.ObjectNode source)
Constructor from Json
|
DbRule(com.fasterxml.jackson.databind.node.ObjectNode source)
Constructor from Json
|
Modifier and Type | Method and Description |
---|---|
void |
Configuration.r66Startup() |
void |
Configuration.serverStartup()
Startup the server
|
void |
Configuration.startMonitoring() |
Copyright © 2009–2020 Waarp. All rights reserved.