oracle.pg.common

Class HelperUtilities

java.lang.Object

oracle.pg.common.HelperUtilities

All Implemented Interfaces:

oracle.pg.common.messages.MesgConsts, OracleMessageConstants

public class HelperUtilities
extends java.lang.Object
implements OracleMessageConstants, oracle.pg.common.messages.MesgConsts

Field Summary

Fields inherited from interface oracle.pg.common.OracleMessageConstants

MG_ERR_USER_REQ_OP_CANCEL, ms_nfe, MSG_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_E_AUTO_IDX_NOT_EXIST, MSG_ERR_ARG_CANNOT_BE_NULL, MSG_ERR_ID_CANNOT_BE_NULL, MSG_ERR_NO_ELEM_TO_BE_CONSUMED, MSG_ERR_NO_OP_SUPPORTED, MSG_IDX_KEY_NOT_NULL, MSG_IDX_KEYS_NOT_NULL, MSG_TXT_IDX_NOT_FOUND, MSG_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_V_AUTO_IDX_NOT_EXIST

Fields inherited from interface oracle.pg.common.messages.MesgConsts

ERR_ARG_CANNOT_BE_NULL, ERR_CODE_NOT_IN_LIST, ERR_DOP_CONSTRAINT, ERR_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_E_AUTO_IDX_NOT_EXIST, ERR_E_DS_MUSTBE_FILE_OR_IS, ERR_E_MAX_LINE_CONSTRAINT, ERR_EDGE_DIR_NOT_BOTH, ERR_EDGE_WORK_TBL_NOT_CLEAN, ERR_GRAPH_NAME_CANT_BENULL, ERR_HIT_EXCEPTION, ERR_HIT_INTERRUPT, ERR_HIT_IO, ERR_HIT_OPGE, ERR_HIT_PARSEE, ERR_ID_CANNOT_BE_NULL, ERR_IDX_KEY_CANNOT_BE_NULL, ERR_IDX_KEY_NOT_NULL, ERR_IDX_KEYS_NOT_NULL, ERR_IN_DS_EDGE_CANTBE_NULL, ERR_IN_DS_VERT_CANTBE_NULL, ERR_IN_E_FLAT_DOESNT_EXIST, ERR_IN_V_FLAT_DOESNT_EXIST, ERR_INPUT_LIST_NOT_NULL, ERR_INPUT_NOT_NULL, ERR_INVALID_CHANGE_ACTION, ERR_INVALID_NUM_FIELDS, ERR_INVALID_NUM_NOARG, ERR_INVALID_NUMBER, ERR_INVALID_VAL, ERR_KEY_CANNOT_BE_ID, ERR_KEY_CANNOT_BE_NULL, ERR_KEY_CANNOT_BE_NULL_EMPTY, ERR_KEY_NOT_SET_TO, ERR_NO_ELEM_TO_BE_CONSUMED, ERR_NO_OP_SUPPORTED, ERR_NOT_IMPLEMENTED_YET, ERR_NOT_ORACLE_V_E, ERR_NUM_PART_CONSTRAINT, ERR_OFFSET_CONSTRAINT, ERR_OFFSET_E_MUST_BE_POS, ERR_OFFSET_V_MUST_BE_POS, ERR_OPT_FLAG_EDGE_INVALID, ERR_OPT_FLAG_VERT_INVALID, ERR_ORA_TEXT_INVALID_KEY, ERR_ORA_TEXT_ONLY_AUTO, ERR_OUTPUT_LIST_NOT_NULL, ERR_PG_ALREADY_EXISTS, ERR_PG_NOT_EMPTY, ERR_PG_NOT_NULL, ERR_SIZE_MUST_BE_POS, ERR_TIMEOUT_TAB_CREATION, ERR_TXT_IDX_NOT_FOUND, ERR_TYPE_ID_NOT_RECO, ERR_UNSUPPORTED_VAL_TYP, ERR_USER_REQ_OP_CANCEL, ERR_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_V_AUTO_IDX_NOT_EXIST, ERR_V_DS_MUSTBE_FILE_OR_IS, ERR_V_MAX_LINE_CONSTRAINT, ERR_VALUE_CANNOT_BE_NULL, INFO_EMP_K_NO_P_VAL, INFO_NUL_K_NO_P_VAL

Constructor Summary

Constructors

Constructor and Description
HelperUtilities()

Method Summary

Modifier and Type	Method and Description
static void	cancelSubTasks(java.util.List<java.util.concurrent.Future<java.lang.Long>> tasks, java.util.concurrent.ThreadPoolExecutor executor)
static boolean	compareDates(java.lang.Object o1, java.lang.Object o2) Returns true if two given objects (either a Date object or a String representation of a Date object) are the same.
static byte[]	escape(java.lang.String s) Escapes a string into the required Oracle flat file format.
static long	executeTasks(java.util.concurrent.ThreadPoolExecutor executor, java.util.List<java.util.concurrent.Future<java.lang.Long>> tasks)
static void	flushIfReachLimit(java.io.ByteArrayOutputStream baos, java.io.OutputStream os)
static void	flushIfReachLimit(java.io.ByteArrayOutputStream baos, java.io.OutputStream os, long limit)
static java.lang.String	sanitizeSimpleFileName(java.lang.String fileName) do sanity checking to the filename, only allowed characters can appear in the file name
static java.lang.String	serializableToStr(java.io.Serializable seri) Convert from a Java Serializable object to a String encoding.
static java.lang.Object	strToSerializable(java.lang.String s) Convert from a String encoding to a Serializable object
static void	waitForTermination(java.util.concurrent.ThreadPoolExecutor executor)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HelperUtilities

public HelperUtilities()

Method Detail

cancelSubTasks

public static void cancelSubTasks(java.util.List<java.util.concurrent.Future<java.lang.Long>> tasks,
                                  java.util.concurrent.ThreadPoolExecutor executor)

compareDates

public static boolean compareDates(java.lang.Object o1,
                                   java.lang.Object o2)

Returns true if two given objects (either a Date object or a String representation of a Date object) are the same.

Parameters:

o1 - must be either a Date object or String

o2 - must be either a Date object or String

escape

public static final byte[] escape(java.lang.String s)

Escapes a string into the required Oracle flat file format. In one scan from left to right, a % is replaced with %25, a tab \t is replaced with %09, a newline \n is replaced with %0A, and a comma is replaced with %2c.

Parameters:

s - the string to be escaped

Returns:

a byte array representation of the escaped string.

executeTasks

public static long executeTasks(java.util.concurrent.ThreadPoolExecutor executor,
                                java.util.List<java.util.concurrent.Future<java.lang.Long>> tasks)
                         throws java.lang.Exception

Throws:

java.lang.Exception

flushIfReachLimit

public static void flushIfReachLimit(java.io.ByteArrayOutputStream baos,
                                     java.io.OutputStream os)
                              throws java.io.IOException

Throws:

java.io.IOException

flushIfReachLimit

public static void flushIfReachLimit(java.io.ByteArrayOutputStream baos,
                                     java.io.OutputStream os,
                                     long limit)
                              throws java.io.IOException

Throws:

java.io.IOException

sanitizeSimpleFileName

public static java.lang.String sanitizeSimpleFileName(java.lang.String fileName)
                                               throws java.lang.IllegalArgumentException

do sanity checking to the filename, only allowed characters can appear in the file name

Parameters:

fileName -

Returns:

String

Throws:

java.lang.IllegalArgumentException

serializableToStr

public static final java.lang.String serializableToStr(java.io.Serializable seri)
                                                throws java.io.IOException

Convert from a Java Serializable object to a String encoding.

Parameters:

seri - an object of Serializable type. It must not be null.

Returns:

a String encoding of the Java Serializable object.

Throws:

java.io.IOException

strToSerializable

public static final java.lang.Object strToSerializable(java.lang.String s)
                                                throws java.io.IOException

Convert from a String encoding to a Serializable object

Parameters:

s - String representation of a Java Serializable object. It MUST not be null.

Returns:

a Java Serializable object obtained from an encoded String.

Throws:

java.io.IOException

waitForTermination

public static void waitForTermination(java.util.concurrent.ThreadPoolExecutor executor)