org.waarp.openr66.database.data

Class DbRule

java.lang.Object

org.waarp.common.database.data.AbstractDbData

org.waarp.openr66.database.data.AbstractDbDataDao<Rule>

org.waarp.openr66.database.data.DbRule

public class DbRule
extends AbstractDbDataDao<Rule>

Rule Table object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DbRule.Columns

Nested classes/interfaces inherited from class org.waarp.common.database.data.AbstractDbData

AbstractDbData.UpdatedInfo

Field Summary

Fields

Modifier and Type	Field and Description
static int[]	dbTypes
protected static String	insertAllValues
static int	NBPRKEY
protected static String	selectAllFields
static String	table
static String	TASK_COMMENT Internal context XML fields
static String	TASK_DELAY Internal context XML fields
static String	TASK_PATH Internal context XML fields
static String	TASK_TYPE Internal context XML fields
protected static String	updateAllFields

Fields inherited from class org.waarp.openr66.database.data.AbstractDbDataDao

JSON_MODEL, pojo

Fields inherited from class org.waarp.common.database.data.AbstractDbData

allFields, dbSession, isSaved, otherFields, primaryKey

Constructor Summary

Constructors

Constructor and Description
DbRule(com.fasterxml.jackson.databind.node.ObjectNode source) Constructor from Json
DbRule(Rule rule)
DbRule(String idRule)
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)

Method Summary

Modifier and Type	Method and Description
void	changeUpdatedInfo(AbstractDbData.UpdatedInfo info) Change UpdatedInfo status
boolean	checkHostAllow(String hostId) Check if the given hostTo is in the allowed list
protected void	checkPath()
void	delete() Delete object from table DbRule only if no DbTaskRunner is using it.
static DbRule[]	deleteAll() Delete all Rules but returns original one, therefore not checking if any TaskRunner are using it (used by reloading rules)
static DbRule[]	getAllRules() Get All DbRule from database or from internal hashMap in case of no database support
String	getArchivePath()
protected AbstractDAO<Rule>	getDao()
static DbPreparedStatement	getFilterPrepareStament(DbSession session, String rule, int mode)
static DbRule	getFromStatement(DbPreparedStatement preparedStatement) For instance from Commander when getting updated information
String	getIdRule()
String[]	getIdsArray()
static String	getJson(DbPreparedStatement preparedStatement, int limit) Write selected DbRule to a Json String
String	getJsonAsString()
int	getMode()
protected String	getPrimaryField()
protected String	getPrimaryKey()
String	getRecvPath()
String[][]	getRerrorTasksArray()
String[][]	getRpostTasksArray()
String[][]	getRpreTasksArray()
String	getRuleArchivePath()
String	getRuleRecvPath()
String	getRuleSendPath()
String	getRuleWorkPath()
String	getSendPath()
String[][]	getSerrorTasksArray()
String[][]	getSpostTasksArray()
String[][]	getSpreTasksArray()
protected String	getTable()
static DbRule[]	getUpdatedPrepareStament()
String	getWorkPath()
protected void	initObject() To setup primaryKey, otherFields, allFields.
boolean	isRecvMode()
boolean	isSendMode()
String	printTasks(boolean isSender, DbTaskRunner.TASKSTEP step)
String	setArchivePath(String filename) Get the full path from archivePath
void	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	setFromJson(String field, com.fasterxml.jackson.databind.JsonNode value)
String	setRecvPath(String filename) Get the full path from RecvPath (used only in copy MODETRANS)
String	setSendPath(String filename) Get the full path from sendPath
String	setWorkingPath(String filename) Get the full path from workPath
String	toShortString() Object to String
String	toSpecializedHtml(R66Session session, String body)
String	toString() Object to String

Methods inherited from class org.waarp.openr66.database.data.AbstractDbDataDao

asJson, exist, getInsertAllValues, getJson, getSelectAllFields, getUpdateAllFields, getValues, getWherePrimaryKey, insert, select, setFromArray, setPrimaryKey, setToArray, toJson, update

Methods inherited from class org.waarp.common.database.data.AbstractDbData

get, getAllFields, getTrueValue, getValue, setTrueValue, setValue, setValues

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

dbTypes

public static final int[] dbTypes

table

public static final String table

See Also:

Constant Field Values

TASK_TYPE

public static final String TASK_TYPE

Internal context XML fields

See Also:

Constant Field Values

TASK_PATH

public static final String TASK_PATH

Internal context XML fields

See Also:

Constant Field Values

TASK_DELAY

public static final String TASK_DELAY

Internal context XML fields

See Also:

Constant Field Values

TASK_COMMENT

public static final String TASK_COMMENT

Internal context XML fields

See Also:

Constant Field Values

NBPRKEY

public static final int NBPRKEY

See Also:

Constant Field Values

selectAllFields

protected static final String selectAllFields

updateAllFields

protected static final String updateAllFields

insertAllValues

protected static final String insertAllValues

See Also:

Constant Field Values

Constructor Detail

DbRule

public 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)

Parameters:

idRule -

ids -

mode -

recvPath -

sendPath -

archivePath -

workPath -

rpreTasks -

rpostTasks -

rerrorTasks -

spreTasks -

spostTasks -

serrorTasks -

DbRule

public DbRule(String idRule)
       throws WaarpDatabaseException

Parameters:

idRule -

Throws:

WaarpDatabaseException

DbRule

public DbRule(Rule rule)

DbRule

public 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

Parameters:

idrule -

idsArrayRef -

recvpath -

sendpath -

archivepath -

workpath -

rpretasksArray -

rposttasksArray -

rerrortasksArray -

spretasksArray -

sposttasksArray -

serrortasksArray -

DbRule

public DbRule(com.fasterxml.jackson.databind.node.ObjectNode source)
       throws WaarpDatabaseSqlException

Constructor from Json

Parameters:

source -

Throws:

WaarpDatabaseSqlException

Method Detail

initObject

protected void initObject()

Description copied from class: AbstractDbData

To setup primaryKey, otherFields, allFields. Note this initObject is called within constructor of AbstractDbData. Be careful that no data is actually initialized at this stage.

Overrides:

initObject in class AbstractDbDataDao<Rule>

getTable

protected String getTable()

Specified by:

getTable in class AbstractDbDataDao<Rule>

getDao

protected AbstractDAO<Rule> getDao()
                            throws DAOConnectionException

Specified by:

getDao in class AbstractDbDataDao<Rule>

Throws:

DAOConnectionException

getPrimaryKey

protected String getPrimaryKey()

Specified by:

getPrimaryKey in class AbstractDbDataDao<Rule>

getPrimaryField

protected String getPrimaryField()

Specified by:

getPrimaryField in class AbstractDbDataDao<Rule>

checkPath

protected final void checkPath()

setFromJson

public void setFromJson(com.fasterxml.jackson.databind.node.ObjectNode node,
                        boolean ignorePrimaryKey)
                 throws WaarpDatabaseSqlException

Description copied from class: AbstractDbDataDao

Set the values from the Json node to the current object (no database access)

Overrides:

setFromJson in class AbstractDbDataDao<Rule>

ignorePrimaryKey - True will ignore primaryKey from Json

Throws:

WaarpDatabaseSqlException

setFromJson

protected void setFromJson(String field,
                           com.fasterxml.jackson.databind.JsonNode value)

Specified by:

setFromJson in class AbstractDbDataDao<Rule>

delete

public void delete()
            throws WaarpDatabaseException

Delete object from table DbRule only if no DbTaskRunner is using it.

Overrides:

delete in class AbstractDbDataDao<Rule>

Throws:

WaarpDatabaseException

deleteAll

public static DbRule[] deleteAll()
                          throws WaarpDatabaseException

Delete all Rules but returns original one, therefore not checking if any TaskRunner are using it (used by reloading rules)

Returns:

the previously existing DbRule

Throws:

WaarpDatabaseException

getAllRules

public static DbRule[] getAllRules()
                            throws WaarpDatabaseNoConnectionException

Get All DbRule from database or from internal hashMap in case of no database support

Returns:

the array of DbRule

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

getFromStatement

public static DbRule getFromStatement(DbPreparedStatement preparedStatement)
                               throws WaarpDatabaseNoConnectionException,
                                      WaarpDatabaseSqlException

For instance from Commander when getting updated information

Parameters:

preparedStatement -

Returns:

the next updated DbRule

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

getUpdatedPrepareStament

public static DbRule[] getUpdatedPrepareStament()
                                         throws WaarpDatabaseNoConnectionException,
                                                WaarpDatabaseSqlException

Returns:

the DbPreparedStatement for getting Updated Object

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

changeUpdatedInfo

public void changeUpdatedInfo(AbstractDbData.UpdatedInfo info)

Description copied from class: AbstractDbDataDao

Change UpdatedInfo status

Specified by:

changeUpdatedInfo in class AbstractDbDataDao<Rule>

setRecvPath

public String setRecvPath(String filename)
                   throws OpenR66ProtocolSystemException

Get the full path from RecvPath (used only in copy MODETRANS)

Parameters:

filename -

Returns:

the full String path

Throws:

OpenR66ProtocolSystemException

setSendPath

public String setSendPath(String filename)
                   throws OpenR66ProtocolSystemException

Get the full path from sendPath

Parameters:

filename -

Returns:

the full String path

Throws:

OpenR66ProtocolSystemException

setArchivePath

public String setArchivePath(String filename)
                      throws OpenR66ProtocolSystemException

Get the full path from archivePath

Parameters:

filename -

Returns:

the full String path

Throws:

OpenR66ProtocolSystemException

setWorkingPath

public String setWorkingPath(String filename)
                      throws OpenR66ProtocolSystemException

Get the full path from workPath

Parameters:

filename -

Returns:

the full String path

Throws:

OpenR66ProtocolSystemException

checkHostAllow

public boolean checkHostAllow(String hostId)

Check if the given hostTo is in the allowed list

Parameters:

hostId -

Returns:

True if allow, else False

isSendMode

public boolean isSendMode()

Returns:

True if this rule is adapted for SENDMODE

isRecvMode

public boolean isRecvMode()

Returns:

True if this rule is adapted for RECVMODE

toString

public String toString()

Object to String

Overrides:

toString in class Object

Returns:

the string that displays this object

See Also:

Object.toString()

printTasks

public String printTasks(boolean isSender,
                         DbTaskRunner.TASKSTEP step)

Parameters:

isSender -

step -

Returns:

a string that prints (debug) the tasks to execute

toShortString

public String toShortString()

Object to String

Returns:

the string that displays this object

See Also:

Object.toString()

getFilterPrepareStament

public static DbPreparedStatement getFilterPrepareStament(DbSession session,
                                                          String rule,
                                                          int mode)
                                                   throws WaarpDatabaseNoConnectionException,
                                                          WaarpDatabaseSqlException

Parameters:

session -

rule -

mode -

Returns:

the DbPreparedStatement according to the filter

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

getJson

public static String getJson(DbPreparedStatement preparedStatement,
                             int limit)
                      throws WaarpDatabaseNoConnectionException,
                             WaarpDatabaseSqlException,
                             OpenR66ProtocolBusinessException

Write selected DbRule to a Json String

Parameters:

preparedStatement -

Returns:

the associated Json String

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

OpenR66ProtocolBusinessException

getJsonAsString

public String getJsonAsString()

Returns:

the Json string for this

toSpecializedHtml

public String toSpecializedHtml(R66Session session,
                                String body)

Parameters:

session -

body -

Returns:

the runner in Html format specified by body by replacing all instance of fields

getRecvPath

public String getRecvPath()

Returns:

the recvPath

getSendPath

public String getSendPath()

Returns:

the sendPath

getArchivePath

public String getArchivePath()

Returns:

the archivePath

getWorkPath

public String getWorkPath()

Returns:

the workPath

getRuleRecvPath

public String getRuleRecvPath()

Returns:

the Rule recvPath

getRuleSendPath

public String getRuleSendPath()

Returns:

the Rule sendPath

getRuleArchivePath

public String getRuleArchivePath()

Returns:

the Rule archivePath

getRuleWorkPath

public String getRuleWorkPath()

Returns:

the Rule workPath

getIdRule

public String getIdRule()

Returns:

the idRule

getMode

public int getMode()

Returns:

the mode

getIdsArray

public String[] getIdsArray()

Returns:

the idsArray

getRpreTasksArray

public String[][] getRpreTasksArray()

Returns:

the rpreTasksArray

getRpostTasksArray

public String[][] getRpostTasksArray()

Returns:

the rpostTasksArray

getRerrorTasksArray

public String[][] getRerrorTasksArray()

Returns:

the rerrorTasksArray

getSpreTasksArray

public String[][] getSpreTasksArray()

Returns:

the spreTasksArray

getSpostTasksArray

public String[][] getSpostTasksArray()

Returns:

the spostTasksArray

getSerrorTasksArray

public String[][] getSerrorTasksArray()

Returns:

the serrorTasksArray