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.control |
Exec FTP server control business.
|
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.ftp.exec |
Class for the real Exec for the Waarp Gateway.
|
org.waarp.gateway.ftp.snmp |
SNMP support classes.
|
org.waarp.gateway.kernel.database | |
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.gateway.kernel.rest | |
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.protocol.http.rest |
Http Rest R66 interface
|
org.waarp.openr66.protocol.http.rest.client |
R66 REST HTTP Client package
|
org.waarp.openr66.protocol.localhandler |
Classes implementing LocalHandlers (real work)
|
org.waarp.openr66.protocol.networkhandler |
Classes implementing Network Handler (multiplexing local handlers)
|
org.waarp.openr66.protocol.utils |
Classes implementing Utilities
|
Modifier and Type | Method and Description |
---|---|
DbSession |
DbPreparedStatement.getDbSession() |
DbSession |
DbAdmin.getSession() |
Modifier and Type | Method and Description |
---|---|
static void |
DbAdmin.addConnection(GUID id,
DbSession session)
Add a Connection into the list
|
void |
DbAdmin.setSession(DbSession session) |
Constructor and Description |
---|
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
|
Modifier and Type | Field and Description |
---|---|
protected DbSession |
AbstractDbData.dbSession
The DbSession to use
|
Modifier and Type | Method and Description |
---|---|
static DbPreparedStatement |
DbDataModel.getUpdatedPrepareStament(DbSession session) |
Constructor and Description |
---|
AbstractDbData(DbSession dbSession)
Abstract constructor to set the DbSession to use
|
AbstractDbDataWithCommit(DbSession dbSession)
Abstract constructor to set the DbSession to use
|
DbDataModel(DbSession dbSession,
String hostid) |
DbDataModel(DbSession dbSession,
String hostid,
long rg,
long wg,
long rs,
long ws,
long del) |
Modifier and Type | Method and Description |
---|---|
protected void |
DbModelAbstract.closeInternalConnection(DbSession dbSession)
Internal use for closing connection while validating it
|
void |
DbModel.createTables(DbSession session)
Create all necessary tables into the database
|
void |
EmptyDbModel.createTables(DbSession session) |
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) |
Modifier and Type | Method and Description |
---|---|
static long |
WaarpActionLogger.logAction(DbSession ftpSession,
long specialId,
String message,
BusinessHandler handler,
ReplyCode rcode,
AbstractDbData.UpdatedInfo info)
Log the action
|
static long |
WaarpActionLogger.logCreate(DbSession ftpSession,
String message,
String file,
BusinessHandler handler)
Log the action
|
static void |
WaarpActionLogger.logErrorAction(DbSession ftpSession,
long specialId,
FtpTransfer transfer,
String message,
ReplyCode rcode,
BusinessHandler handler)
Log the action in error
|
Constructor and Description |
---|
DbTransferLog(DbSession dbSession,
String user,
String account,
long specialId)
Load from database
|
DbTransferLog(DbSession dbSession,
String user,
String account,
long specialId,
boolean isSender,
String filename,
String mode,
ReplyCode infostatus,
String info,
AbstractDbData.UpdatedInfo updatedInfo)
Insert into database
|
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) |
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) |
Modifier and Type | Field and Description |
---|---|
protected DbSession |
R66PreparedTransferExecutor.dbsession |
Modifier and Type | Method and Description |
---|---|
void |
R66PreparedTransferExecutor.setDbsession(DbSession dbsession) |
Constructor and Description |
---|
FtpMonitoring(DbSession session) |
Modifier and Type | Method and Description |
---|---|
static void |
WaarpActionLogger.logAction(DbSession dbSession,
HttpSession session,
String message,
io.netty.handler.codec.http.HttpResponseStatus rcode,
AbstractDbData.UpdatedInfo info)
Log the action
|
static void |
WaarpActionLogger.logCreate(DbSession dbSession,
String message,
HttpSession session)
Log the action
|
static void |
WaarpActionLogger.logErrorAction(DbSession dbSession,
HttpSession session,
String message,
io.netty.handler.codec.http.HttpResponseStatus rcode)
Log the action in error
|
Modifier and Type | Method and Description |
---|---|
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 DbPreparedStatement |
DbTransferLog.getLogPrepareStament(DbSession session,
Timestamp start,
Timestamp stop) |
static DbPreparedStatement |
DbTransferLog.getStatusPrepareStament(DbSession session,
io.netty.handler.codec.http.HttpResponseStatus status,
int limit) |
Constructor and Description |
---|
DbTransferLog(DbSession dBsession)
Private constructor
|
DbTransferLog(DbSession dbSession,
String user,
String account,
long specialId)
Load from database
|
DbTransferLog(DbSession dbSession,
String user,
String account,
long specialId,
boolean isSender,
String filename,
String mode,
io.netty.handler.codec.http.HttpResponseStatus infostatus,
String info,
AbstractDbData.UpdatedInfo updatedInfo)
Insert into database
|
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) |
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) |
Modifier and Type | Field and Description |
---|---|
protected DbSession |
HttpRestHandler.dbSession |
Modifier and Type | Method and Description |
---|---|
DbSession |
HttpRestHandler.getDbSession() |
Modifier and Type | Method and Description |
---|---|
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 DbPreparedStatement |
DbTaskRunner.getLogPrepareStatement(DbSession session,
Timestamp start,
Timestamp stop) |
static DbPreparedStatement |
DbMultipleMonitor.getUpdatedPrepareStament(DbSession session) |
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.
|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
String |
Configuration.getHostId(DbSession dbSession,
String remoteHost)
Deprecated.
Use getHostId(String remoteHost)
|
Modifier and Type | Method and Description |
---|---|
static HashMap<String,DbSession> |
HttpRestR66Handler.getDbSessionFromUser() |
Modifier and Type | Method and Description |
---|---|
AbstractDbData |
HttpRestR66Client.getDbDataFromFuture(DbSession dbSession,
RestFuture future) |
Modifier and Type | Method and Description |
---|---|
DbSession |
LocalChannelReference.getDbSession() |
Constructor and Description |
---|
Monitoring(long pastLimit,
long minimalDelay,
DbSession session) |
Modifier and Type | Method and Description |
---|---|
DbSession |
NetworkServerHandler.getDbSession() |
Modifier and Type | Method and Description |
---|---|
static void |
TransferUtils.cleanSelectedTransfers(DbSession dbSession,
int limit,
Object map,
R66Session session,
String body,
String startid,
String stopid,
Timestamp tstart,
Timestamp tstop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error)
Clean all selected transfers
|
static void |
TransferUtils.cleanSelectedTransfers(DbSession dbSession,
int limit,
Object map,
R66Session session,
String body,
String startid,
String stopid,
Timestamp tstart,
Timestamp tstop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error,
String host) |
static void |
ChannelCloseTimer.closeFutureTransaction(ConnectionActions connectionActions,
DbSession noconcurrencyDbSession)
Close in the future this transaction
|
void |
ChannelCloseTimer.setDbSession(DbSession dbSession) |
static void |
TransferUtils.stopSelectedTransfers(DbSession dbSession,
int limit,
Object map,
R66Session session,
String body,
String startid,
String stopid,
Timestamp tstart,
Timestamp tstop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error)
Stop all selected transfers
|
static void |
TransferUtils.stopSelectedTransfers(DbSession dbSession,
int limit,
Object map,
R66Session session,
String body,
String startid,
String stopid,
Timestamp tstart,
Timestamp tstop,
String rule,
String req,
boolean pending,
boolean transfer,
boolean error,
String host) |
Copyright © 2009–2020 Waarp. All rights reserved.