Uses of Class
org.waarp.common.database.exception.WaarpDatabaseSqlException

Packages that use WaarpDatabaseSqlException

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.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.dao.database
org.waarp.openr66.database.data	Classes implementing Database Data model
org.waarp.openr66.pojo
org.waarp.openr66.protocol.configuration	Class implementing Configuration

Uses of WaarpDatabaseSqlException in org.waarp.common.database

Methods in org.waarp.common.database that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
void	DbAdmin.commit() Commit on connection (since in autocommit, should not be used)
void	DbSession.commit() Commit everything
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.

Constructors in org.waarp.common.database that throw WaarpDatabaseSqlException

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

Uses of WaarpDatabaseSqlException in org.waarp.common.database.data

Methods in org.waarp.common.database.data that throw WaarpDatabaseSqlException

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)
String	DbValue.getValueAsString()
protected void	AbstractDbData.getValues(DbPreparedStatement preparedStatement, DbValue[] values) Get several values into DbValue from DbPreparedStatement
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)
protected void	DbDataModel.setToArray()
protected abstract void	AbstractDbData.setToArray() Internal function to set to Array used to push data to database
static void	AbstractDbData.setTrueValue(PreparedStatement ps, DbValue value, int rank) Set Value into PreparedStatement
void	DbValue.setValueFromString(String svalue)
protected void	AbstractDbData.setValues(DbPreparedStatement preparedStatement, DbValue[] values) Set several values to a DbPreparedStatement
static void	AbstractDbData.validateLength(byte[]... values) Validate Byte array max length
static void	AbstractDbData.validateLength(int type, String... values) Validate String max length

Constructors in org.waarp.common.database.data that throw WaarpDatabaseSqlException

Constructor and Description
DbDataModel(DbSession dbSession, String hostid, long rg, long wg, long rs, long ws, long del)

Uses of WaarpDatabaseSqlException in org.waarp.common.database.model

Methods in org.waarp.common.database.model that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
long	DbModelOracle.nextSequence(DbSession dbSession)
long	DbModelPostgresql.nextSequence(DbSession dbSession)
long	DbModel.nextSequence(DbSession dbSession)
long	EmptyDbModel.nextSequence(DbSession dbSession)
long	DbModelCommonMariadbMySql.nextSequence(DbSession dbSession)
long	DbModelH2.nextSequence(DbSession dbSession)
long	DbModelMariadb.nextSequence(DbSession dbSession)

Uses of WaarpDatabaseSqlException in org.waarp.gateway.ftp.database.data

Methods in org.waarp.gateway.ftp.database.data that throw WaarpDatabaseSqlException

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()
protected void	DbTransferLog.setToArray()

Uses of WaarpDatabaseSqlException in org.waarp.gateway.kernel.database.data

Methods in org.waarp.gateway.kernel.database.data that throw WaarpDatabaseSqlException

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.setToArray()

Uses of WaarpDatabaseSqlException in org.waarp.gateway.kernel.database.model

Methods in org.waarp.gateway.kernel.database.model that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
static long	DbModelFactoryGateway.nextSequenceMonitoring(DbSession dbSession)

Uses of WaarpDatabaseSqlException in org.waarp.openr66.commander

Methods in org.waarp.openr66.commander that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
void	InternalRunner.reloadInternalRunner()

Constructors in org.waarp.openr66.commander that throw WaarpDatabaseSqlException

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

Uses of WaarpDatabaseSqlException in org.waarp.openr66.configuration

Methods in org.waarp.openr66.configuration that throw WaarpDatabaseSqlException

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

Uses of WaarpDatabaseSqlException in org.waarp.openr66.dao.database

Methods in org.waarp.openr66.dao.database that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
protected Object[]	DBBusinessDAO.getInsertValues(Business business)
protected abstract Object[]	StatementExecutor.getInsertValues(E e1)
protected Object[]	DBHostDAO.getInsertValues(Host host)
protected Object[]	DBBusinessDAO.getUpdateValues(Business business)
protected abstract Object[]	StatementExecutor.getUpdateValues(E e1)
protected Object[]	DBHostDAO.getUpdateValues(Host host)

Uses of WaarpDatabaseSqlException in org.waarp.openr66.database.data

Methods in org.waarp.openr66.database.data that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
protected void	DbRule.checkPathes()
protected void	DbHostConfiguration.checkValues()
protected void	DbMultipleMonitor.checkValues()
protected void	DbTaskRunner.checkValues()
protected abstract void	AbstractDbDataDao.checkValues()
protected void	DbConfiguration.checkValues()
protected void	DbHostAuth.checkValues()
protected void	DbRule.checkValues()
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 DbHostConfiguration	DbHostConfiguration.getFromStatement(DbPreparedStatement preparedStatement) For instance from Commander when getting updated information
static DbMultipleMonitor	DbMultipleMonitor.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 DbConfiguration	DbConfiguration.getFromStatement(DbPreparedStatement statement)
static DbHostAuth	DbHostAuth.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 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	DbTaskRunner.getJson(DbPreparedStatement preparedStatement, int limit) Write selected TaskRunners to a Json String
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 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
void	DbTaskRunner.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode source, boolean ignorePrimaryKey)
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	DbConfiguration.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node, boolean ignorePrimaryKey) Read json object into Array then setFromArray
void	DbHostAuth.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node, boolean ignorePrimaryKey)
void	DbRule.setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node, boolean ignorePrimaryKey)
protected abstract void	AbstractDbDataDao.setFromJson(String field, com.fasterxml.jackson.databind.JsonNode value)
protected void	DbRule.setFromJson(String field, com.fasterxml.jackson.databind.JsonNode value)
static void	AbstractDbDataDao.validateLength(byte[]... values) Validate Byte array max length
static void	AbstractDbDataDao.validateLength(int type, String... values) Validate String max length
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

Constructors in org.waarp.openr66.database.data that throw WaarpDatabaseSqlException

Constructor and Description
DbConfiguration(com.fasterxml.jackson.databind.node.ObjectNode source) Constructor from Json
DbConfiguration(String hostid, long rg, long wg, long rs, long ws, long del)
DbHostAuth(com.fasterxml.jackson.databind.node.ObjectNode source)
DbHostAuth(String hostid, String address, int port, boolean isSSL, byte[] hostkey, boolean adminrole, boolean isClient)
DbHostConfiguration(com.fasterxml.jackson.databind.node.ObjectNode source) Constructor from Json
DbHostConfiguration(String hostid, String business, String roles, String aliases, String others)
DbMultipleMonitor(String hostid, int cc, int ch, int cr)
DbRule(com.fasterxml.jackson.databind.node.ObjectNode source) Constructor from Json
DbRule(String idrule, String[] idsArrayRef, int mode, String recvpath, String sendpath, String archivepath, String workpath, String[][] rpretasksArray, String[][] rposttasksArray, String[][] rerrortasksArray, String[][] spretasksArray, String[][] sposttasksArray, String[][] serrortasksArray) Constructor used from XML file
DbRule(String idRule, String ids, int mode, String recvPath, String sendPath, String archivePath, String workPath, String rpreTasks, String rpostTasks, String rerrorTasks, String spreTasks, String spostTasks, String serrorTasks)

Uses of WaarpDatabaseSqlException in org.waarp.openr66.pojo

Methods in org.waarp.openr66.pojo that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
void	Business.checkValues()
void	Host.checkValues()
void	Limit.checkValues()
void	MultipleMonitor.checkValues()
void	Transfer.checkValues()
void	Rule.checkValues()
void	Rule.setArchivePath(String archivePath)
void	Rule.setRecvPath(String recvPath)
void	Rule.setSendPath(String sendPath)
void	Rule.setWorkPath(String workPath)

Constructors in org.waarp.openr66.pojo that throw WaarpDatabaseSqlException

Constructor and Description
Business(String hostid, String business, String roles, String aliases, String others)
Business(String hostid, String business, String roles, String aliases, String others, UpdatedInfo updatedInfo)
Host(String hostid, String address, int port, byte[] hostkey, boolean ssl, boolean client)
Host(String hostid, String address, int port, byte[] hostkey, boolean ssl, boolean client, boolean proxified, boolean admin)
Host(String hostid, String address, int port, byte[] hostkey, boolean ssl, boolean client, boolean proxified, boolean admin, boolean active)
Host(String hostid, String address, int port, byte[] hostkey, boolean ssl, boolean client, boolean proxified, boolean admin, boolean active, UpdatedInfo updatedInfo)
Limit(String hostid, long delayLimit)
Limit(String hostid, long delayLimit, long readGlobalLimit, long writeGlobalLimit, long readSessionLimit, long writeSessionLimit)
Limit(String hostid, long delayLimit, long readGlobalLimit, long writeGlobalLimit, long readSessionLimit, long writeSessionLimit, UpdatedInfo updatedInfo)
MultipleMonitor(String hostid, int countConfig, int countHost, int countRule)
Rule(String name, int mode)
Rule(String name, int mode, List<String> hostids)
Rule(String name, int mode, List<String> hostids, String recvPath, String sendPath, String archivePath, String workPath)
Rule(String name, int mode, List<String> hostids, String recvPath, String sendPath, String archivePath, String workPath, List<RuleTask> rPre, List<RuleTask> rPost, List<RuleTask> rError, List<RuleTask> sPre, List<RuleTask> sPost, List<RuleTask> sError)
Rule(String name, int mode, List<String> hostids, String recvPath, String sendPath, String archivePath, String workPath, List<RuleTask> rPre, List<RuleTask> rPost, List<RuleTask> rError, List<RuleTask> sPre, List<RuleTask> sPost, List<RuleTask> sError, UpdatedInfo updatedInfo)
Transfer(long id, String rule, int mode, String filename, String originalName, String fileInfo, boolean isMoved, int blockSize, boolean retrieveMode, String ownerReq, String requester, String requested, String transferInfo, Transfer.TASKSTEP globalStep, Transfer.TASKSTEP lastGlobalStep, int step, ErrorCode stepStatus, ErrorCode infoStatus, int rank, Timestamp start, Timestamp stop) Constructor to create Transfer from remote requests
Transfer(long id, String rule, int mode, String filename, String originalName, String fileInfo, boolean isMoved, int blockSize, boolean retrieveMode, String ownerReq, String requester, String requested, String transferInfo, Transfer.TASKSTEP globalStep, Transfer.TASKSTEP lastGlobalStep, int step, ErrorCode stepStatus, ErrorCode infoStatus, int rank, Timestamp start, Timestamp stop, UpdatedInfo updatedInfo) Full Constructor to create Transfer from the database
Transfer(String remote, String rule, int ruleMode, boolean retrieveMode, String file, String fileInfo, int blockSize) Constructor to create transfer locally
Transfer(String remote, String rule, int ruleMode, boolean retrieveMode, String file, String fileInfo, int blockSize, Timestamp start) Constructor to create transfer locally with delayed start time

Uses of WaarpDatabaseSqlException in org.waarp.openr66.protocol.configuration

Methods in org.waarp.openr66.protocol.configuration that throw WaarpDatabaseSqlException

Modifier and Type	Method and Description
void	Configuration.r66Startup()
void	Configuration.serverStartup() Startup the server
void	Configuration.startMonitoring()