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 |
Main class for the Exec FTP server based on Filesystem and simple
authentication.
|
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.database.model |
Classes implementing Database Model (H2, Oracle, PostgreSQL, MySQL)
|
org.waarp.openr66.protocol.configuration |
Class implementing Configuration
|
org.waarp.openr66.server |
Classes implementing Server startup main class or utility classes
|
Modifier and Type | Method and Description |
---|---|
void |
DbSession.checkConnection()
Check the connection to the Database and try to reopen it if possible
|
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
|
PreparedStatement |
DbPreparedStatement.getPreparedStatement() |
ResultSet |
DbPreparedStatement.getResultSet() |
ResultSet |
DbRequest.getResultSet() |
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.
|
void |
DbSession.setAutoCommit(boolean autoCommit)
Change the autocommit feature
|
void |
DbAdmin.validConnection()
Validate connection
|
Constructor and Description |
---|
DbAdmin(DbModel model,
String server,
String user,
String passwd)
Use a default server for basic connection.
|
DbAdmin(DbModel model,
String server,
String user,
String passwd,
boolean write)
Use a default server for basic connection.
|
DbPreparedStatement(DbSession ls)
Create a DbPreparedStatement from DbSession object
|
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
|
DbRequest(DbSession ls)
Create a new request from the DbSession
|
DbSession(DbAdmin admin,
boolean isReadOnly)
Create a session and connect the current object to the server using the
DbAdmin object.
|
DbSession(DbAdmin admin,
boolean isReadOnly,
boolean autoCommit)
Create a session and connect the current object to the server using the
DbAdmin object.
|
Modifier and Type | Method and Description |
---|---|
static DbPreparedStatement |
DbDataModel.getUpdatedPrepareStament(DbSession session) |
protected void |
AbstractDbData.getValue(DbPreparedStatement preparedStatement,
DbValue value)
Get one value into DbValue from DbPreparedStatement
|
protected void |
AbstractDbData.getValues(DbPreparedStatement preparedStatement,
DbValue[] values)
Get several values into DbValue from DbPreparedStatement
|
protected void |
AbstractDbData.setValue(DbPreparedStatement preparedStatement,
DbValue value)
Set one value to a DbPreparedStatement
|
protected void |
AbstractDbData.setValues(DbPreparedStatement preparedStatement,
DbValue[] values)
Set several values to a DbPreparedStatement
|
Modifier and Type | Method and Description |
---|---|
void |
DbModel.createTables(DbSession session)
Create all necessary tables into the database
|
void |
EmptyDbModel.createTables(DbSession session) |
static DbAdmin |
DbModelFactory.initialize(String dbdriver,
String dbserver,
String dbuser,
String dbpasswd,
boolean write)
Initialize the Database Model according to arguments.
|
boolean |
DbModel.needUpgradeDb(DbSession session,
String version,
boolean tryFix)
Check if Database is ok from version
|
boolean |
EmptyDbModel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
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) |
void |
DbModelCommonMariadbMySql.resetSequence(DbSession session,
long newvalue) |
void |
DbModelOracle.resetSequence(DbSession session,
long newvalue) |
void |
DbModelPostgresql.resetSequence(DbSession session,
long newvalue) |
void |
DbModel.resetSequence(DbSession session,
long newvalue)
Reset the sequence (example)
|
void |
DbModelH2.resetSequence(DbSession session,
long newvalue) |
void |
EmptyDbModel.resetSequence(DbSession session,
long newvalue) |
boolean |
DbModel.upgradeDb(DbSession session,
String version)
Upgrade Database from version
|
boolean |
EmptyDbModel.upgradeDb(DbSession session,
String version) |
void |
DbModel.validConnection(DbSession dbSession)
Validate connection
|
void |
DbModelAbstract.validConnection(DbSession dbSession) |
void |
EmptyDbModel.validConnection(DbSession dbSession) |
protected void |
DbModelAbstract.validConnectionSelect(DbSession dbSession) |
Constructor and Description |
---|
DbModelH2()
Create the object and initialize if necessary the driver
|
DbModelH2(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMariadb()
Create the object and initialize if necessary the driver
|
DbModelMariadb(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMariadb(String dbserver,
String dbuser,
String dbpasswd,
Timer timer,
long delay)
Create the object and initialize if necessary the driver
|
DbModelMysql()
Create the object and initialize if necessary the driver
|
DbModelMysql(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMysql(String dbserver,
String dbuser,
String dbpasswd,
Timer timer,
long delay)
Create the object and initialize if necessary the driver
|
DbModelOracle()
Create the object and initialize if necessary the driver
|
DbModelOracle(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelOracle(String dbserver,
String dbuser,
String dbpasswd,
Timer timer,
long delay)
Create the object and initialize if necessary the driver
|
DbModelPostgresql()
Create the object and initialize if necessary the driver
|
Modifier and Type | Method and Description |
---|---|
static void |
ServerInitDatabase.initdb() |
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) |
Modifier and Type | Method and Description |
---|---|
void |
DbModelH2Ftp.createTables(DbSession session) |
void |
DbModelMariaDbFtp.createTables(DbSession session) |
void |
DbModelMysqlFtp.createTables(DbSession session) |
void |
DbModelOracleFtp.createTables(DbSession session) |
void |
DbModelPostgresqlFtp.createTables(DbSession session) |
static DbAdmin |
DbModelFactoryFtp.initialize(String dbdriver,
String dbserver,
String dbuser,
String dbpasswd,
boolean write)
Initialize the Database Model according to arguments.
|
boolean |
DbModelH2Ftp.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMariaDbFtp.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMysqlFtp.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelOracleFtp.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelPostgresqlFtp.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
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) |
void |
DbModelH2Ftp.resetSequence(DbSession session,
long newvalue) |
void |
DbModelMariaDbFtp.resetSequence(DbSession session,
long newvalue) |
void |
DbModelMysqlFtp.resetSequence(DbSession session,
long newvalue) |
void |
DbModelOracleFtp.resetSequence(DbSession session,
long newvalue) |
void |
DbModelPostgresqlFtp.resetSequence(DbSession session,
long newvalue) |
boolean |
DbModelH2Ftp.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMariaDbFtp.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMysqlFtp.upgradeDb(DbSession session,
String version) |
boolean |
DbModelOracleFtp.upgradeDb(DbSession session,
String version) |
boolean |
DbModelPostgresqlFtp.upgradeDb(DbSession session,
String version) |
Constructor and Description |
---|
DbModelH2Ftp(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMariaDbFtp(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMysqlFtp(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelOracleFtp(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelPostgresqlFtp()
Create the object and initialize if necessary the driver
|
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) |
Modifier and Type | Method and Description |
---|---|
static void |
DbModelH2Kernel.createTableMonitoring(DbSession session) |
static void |
DbModelMysqlKernel.createTableMonitoring(DbSession session) |
static void |
DbModelOracleKernel.createTableMonitoring(DbSession session) |
static void |
DbModelPostgresqlKernel.createTableMonitoring(DbSession session) |
void |
DbModelH2Kernel.createTables(DbSession session) |
void |
DbModelMariaDbKernel.createTables(DbSession session) |
void |
DbModelMysqlKernel.createTables(DbSession session) |
void |
DbModelOracleKernel.createTables(DbSession session) |
void |
DbModelPostgresqlKernel.createTables(DbSession session) |
static DbAdmin |
DbModelFactoryGateway.initialize(String dbdriver,
String dbserver,
String dbuser,
String dbpasswd,
boolean write)
Initialize the Database Model according to arguments.
|
boolean |
DbModelH2Kernel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMariaDbKernel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMysqlKernel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelOracleKernel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelPostgresqlKernel.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
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) |
void |
DbModelH2Kernel.resetSequence(DbSession session,
long newvalue) |
void |
DbModelMariaDbKernel.resetSequence(DbSession session,
long newvalue) |
void |
DbModelMysqlKernel.resetSequence(DbSession session,
long newvalue) |
void |
DbModelOracleKernel.resetSequence(DbSession session,
long newvalue) |
void |
DbModelPostgresqlKernel.resetSequence(DbSession session,
long newvalue) |
static void |
DbModelFactoryGateway.resetSequenceMonitoring(DbSession session,
long newvalue) |
static void |
DbModelMysqlKernel.resetSequenceMonitoring(DbSession session,
long newvalue) |
static void |
DbModelOracleKernel.resetSequenceMonitoring(DbSession session,
long newvalue) |
boolean |
DbModelH2Kernel.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMariaDbKernel.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMysqlKernel.upgradeDb(DbSession session,
String version) |
boolean |
DbModelOracleKernel.upgradeDb(DbSession session,
String version) |
boolean |
DbModelPostgresqlKernel.upgradeDb(DbSession session,
String version) |
Constructor and Description |
---|
DbModelH2Kernel(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMariaDbKernel(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMysqlKernel(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelOracleKernel(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelPostgresqlKernel()
Create the object and initialize if necessary the driver
|
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.changeFinishedToDone()
Change CompleteOk+ALLDONETASK to Updated = DONE TaskRunner from database.
|
static void |
DbTaskRunner.finishSelectOrCountPrepareStatement(DbPreparedStatement pstt,
long time)
Set the current time in the given updatedPreparedStatement
|
static DbHostAuth[] |
DbHostAuth.getAllHosts()
Get All DbHostAuth from database or from internal hashMap in case of no
database support
|
static DbRule[] |
DbRule.getAllRules()
Get All DbRule from database or from internal hashMap in case of no
database support
|
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 DbHostAuth[] |
DbHostAuth.getUpdatedPreparedStatement() |
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
|
static void |
DbTaskRunner.resetToSubmit(DbSession session)
Change RUNNING, INTERRUPTED to TOSUBMIT TaskRunner from database.
|
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
|
Modifier and Type | Method and Description |
---|---|
void |
DbModelH2R66.createTables(DbSession session) |
void |
DbModelMariadbR66.createTables(DbSession session) |
void |
DbModelMysqlR66.createTables(DbSession session) |
void |
DbModelOracleR66.createTables(DbSession session) |
void |
DbModelPostgresqlR66.createTables(DbSession session) |
static DbAdmin |
DbModelFactoryR66.initialize(String dbdriver,
String dbserver,
String dbuser,
String dbpasswd,
boolean write)
Initialize the Database Model according to arguments.
|
boolean |
DbModelH2R66.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMariadbR66.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelMysqlR66.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelOracleR66.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelPostgresqlR66.needUpgradeDb(DbSession session,
String version,
boolean tryFix) |
boolean |
DbModelH2R66.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMariadbR66.upgradeDb(DbSession session,
String version) |
boolean |
DbModelMysqlR66.upgradeDb(DbSession session,
String version) |
boolean |
DbModelOracleR66.upgradeDb(DbSession session,
String version) |
boolean |
DbModelPostgresqlR66.upgradeDb(DbSession session,
String version) |
Constructor and Description |
---|
DbModelH2R66(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMariadbR66(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelMysqlR66(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelOracleR66(String dbserver,
String dbuser,
String dbpasswd)
Create the object and initialize if necessary the driver
|
DbModelPostgresqlR66()
Create the object and initialize if necessary the driver
|
Modifier and Type | Method and Description |
---|---|
void |
Configuration.r66Startup() |
void |
Configuration.serverStartup()
Startup the server
|
Modifier and Type | Method and Description |
---|---|
static void |
ServerInitDatabase.initdb() |
Copyright © 2009–2020 Waarp. All rights reserved.