|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.objectweb.cjdbc.controller.backup.Octopus
Octopus Hook Class. It has the necessary methods and fields to use octopus simply.
OctopusConstants
Field Summary | |
private boolean |
backupMode
|
private java.lang.String |
checkpoint
|
(package private) boolean |
cleanOctopus
|
(package private) static java.lang.String |
COPY_MODE
|
private java.lang.String |
csvDir
|
private DatabaseBackend |
database
|
(package private) static java.lang.String |
GENERATE_DOC
|
private BackupListener |
listener
|
private java.lang.String |
loaderJobXmlFile
|
(package private) static Trace |
logger
|
(package private) static java.lang.String |
mainDirectory
|
static int |
MODE_BACKUP
Mode for backup using octopus |
static int |
MODE_RECOVERY
Mode for recovery using octopus |
private static java.lang.String |
OCTOPUS_INCLUDE_HREF
|
(package private) static java.lang.String |
OCTOPUS_LOG_FILE
|
(package private) static int |
OCTOPUS_MODE_FROM_CSV
|
(package private) static int |
OCTOPUS_MODE_TO_CSV
|
private java.lang.String |
octopusDir
|
(package private) static java.lang.String |
OVERRIDE_MODE
|
private java.lang.String |
password
|
private java.lang.Exception |
runException
|
private static java.io.PrintStream |
stream
|
private java.util.ArrayList |
tables
|
(package private) static java.lang.String |
TYPE_CSV
|
private java.lang.String |
user
|
(package private) static int |
ZIP_MODE_CREATE
|
(package private) static int |
ZIP_MODE_EXPAND
|
(package private) boolean |
zipOctopus
|
Fields inherited from class java.lang.Thread |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
Octopus(DatabaseBackend database,
java.lang.String checkpoint)
Instanciate hook to octopus |
|
Octopus(DatabaseBackend database,
java.lang.String checkpoint,
java.util.ArrayList tables)
Use Octopus only for a set of tables |
|
Octopus(DatabaseBackend database,
java.lang.String checkpoint,
java.util.ArrayList tables,
boolean backupMode)
Use Octopus only for a set of tables |
|
Octopus(DatabaseBackend database,
java.lang.String checkpoint,
boolean backupMode)
Creates a new Octopus object and sets the mode to use it as
a thread |
Method Summary | |
void |
backup()
Convert database to csv and zip the files |
(package private) void |
callOctopusLoader(java.lang.String sourceType,
java.lang.String sourceUrl,
java.lang.String sourceDriver,
java.lang.String sourceUser,
java.lang.String sourcePassword,
java.lang.String targetType,
java.lang.String targetDriver,
java.lang.String targetUrl,
java.lang.String targetUser,
java.lang.String targetPassword,
boolean backup,
boolean generateAllVendors)
Generate all the metadata |
private void |
cleanUp()
|
private java.lang.String[] |
convertTablesToArray(java.util.ArrayList tablesList)
|
boolean |
deleteDir(java.io.File dir)
Delete a directory by deleting all sub files |
(package private) void |
generateMetadata(java.lang.String sourceType,
java.lang.String sourceUrl,
java.lang.String sourceDriver,
java.lang.String sourceUser,
java.lang.String sourcePassword,
java.lang.String targetType,
java.lang.String targetDriver,
java.lang.String targetUrl,
java.lang.String targetUser,
java.lang.String targetPassword,
boolean backup)
|
private java.lang.String |
getDbType(java.lang.String url)
|
java.lang.String |
getOctopusDirectory()
Retrieve the path for the octopus directory |
(package private) java.util.Hashtable |
getOctopusStrings(DatabaseBackend database)
|
java.lang.Exception |
getRunException()
Returns the runException value. |
private void |
getUserLogin()
|
boolean |
isCleanOctopus()
Returns the cleanOctopus value. |
boolean |
isZipOctopus()
Returns the zipOctopus value. |
private void |
launchOctopus()
This start octopus with previously generated LoaderJob file |
private void |
prepareOctopus(int octopusMode)
|
(package private) void |
prepareOctopus(java.lang.String sourceType,
java.lang.String sourceUrl,
java.lang.String sourceDriver,
java.lang.String sourceUser,
java.lang.String sourcePassword,
java.lang.String targetType,
java.lang.String targetDriver,
java.lang.String targetUrl,
java.lang.String targetUser,
java.lang.String targetPassword,
boolean backup)
Prepare the loader job file for octopus |
void |
restore()
Recover database from zipped csv the files |
void |
run()
|
void |
sanityCheck()
Check if backup can be executed. |
void |
setCleanOctopus(boolean cleanOctopus)
Sets the cleanOctopus value. |
void |
setListener(BackupListener listener)
Set the callback listener of this octopus process |
void |
setOctopusDirectory(java.lang.String path)
Set the default path of octopus directory to a new one |
private void |
setOctopusLoaderJob()
|
void |
setOctopusMode(boolean backup)
When used as a thread Octopus need the mode to run in |
private void |
setPaths()
|
void |
setZipOctopus(boolean zipOctopus)
Sets the zipOctopus value. |
private void |
zipOctopus(int zipMode)
|
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
private static final java.lang.String OCTOPUS_INCLUDE_HREF
static Trace logger
static final java.lang.String TYPE_CSV
static final java.lang.String COPY_MODE
static final java.lang.String OVERRIDE_MODE
static final java.lang.String GENERATE_DOC
static final java.lang.String OCTOPUS_LOG_FILE
boolean cleanOctopus
boolean zipOctopus
static final int ZIP_MODE_CREATE
static final int ZIP_MODE_EXPAND
static final int OCTOPUS_MODE_FROM_CSV
static final int OCTOPUS_MODE_TO_CSV
public static final int MODE_BACKUP
public static final int MODE_RECOVERY
private DatabaseBackend database
private java.lang.String user
private java.lang.String password
private java.lang.String checkpoint
private java.lang.String octopusDir
private java.lang.String csvDir
private java.lang.String loaderJobXmlFile
private java.util.ArrayList tables
private static java.io.PrintStream stream
static java.lang.String mainDirectory
private boolean backupMode
private java.lang.Exception runException
private BackupListener listener
Constructor Detail |
public Octopus(DatabaseBackend database, java.lang.String checkpoint) throws BackupException
database
- backend to manipulate with octopuscheckpoint
- to name files
BackupException
- if failspublic Octopus(DatabaseBackend database, java.lang.String checkpoint, boolean backupMode) throws BackupException
Octopus
object and sets the mode to use it as
a thread
database
- the DatabaseBackend
object to processcheckpoint
- the checkpoint to use for name of backupbackupMode
- true if we should backup, false if we should restore
BackupException
- if fails (not due to Octopus)public Octopus(DatabaseBackend database, java.lang.String checkpoint, java.util.ArrayList tables, boolean backupMode) throws BackupException
database
- backend to manipulate with octopuscheckpoint
- to name filestables
- on which we should use OctopusbackupMode
- true if we should backup, false if we should restore
BackupException
- if failspublic Octopus(DatabaseBackend database, java.lang.String checkpoint, java.util.ArrayList tables) throws BackupException
database
- backend to manipulate with octopuscheckpoint
- to name filestables
- on which we should use Octopus
BackupException
- if failsMethod Detail |
public java.lang.Exception getRunException()
public final void setOctopusDirectory(java.lang.String path)
path
- of the directorypublic final java.lang.String getOctopusDirectory()
public void backup() throws BackupException, OctopusException
BackupException
- if failure is not due to octopus
OctopusException
- if failure is due to octopuspublic void restore() throws BackupException, OctopusException
BackupException
- if failure is not due to octopus
OctopusException
- if failure is due to octopuspublic void setOctopusMode(boolean backup)
backup
- if true, when run will start a backup process, otherwise will
start a restore processpublic void run()
Runnable.run()
private void getUserLogin()
private void setPaths() throws BackupException
BackupException
public void sanityCheck() throws BackupException
BackupException
- if backend cannot be used for backupprivate void setOctopusLoaderJob() throws OctopusException, BackupException
OctopusException
BackupException
private void launchOctopus() throws OctopusException
OctopusException
- if octopus failsprivate void cleanUp()
public boolean deleteDir(java.io.File dir)
dir
- to delete
private void zipOctopus(int zipMode) throws BackupException
BackupException
private java.lang.String getDbType(java.lang.String url) throws BackupException
BackupException
private void prepareOctopus(int octopusMode) throws BackupException, OctopusException
BackupException
OctopusException
final java.util.Hashtable getOctopusStrings(DatabaseBackend database) throws BackupException
BackupException
final void generateMetadata(java.lang.String sourceType, java.lang.String sourceUrl, java.lang.String sourceDriver, java.lang.String sourceUser, java.lang.String sourcePassword, java.lang.String targetType, java.lang.String targetDriver, java.lang.String targetUrl, java.lang.String targetUser, java.lang.String targetPassword, boolean backup) throws OctopusException
OctopusException
final void prepareOctopus(java.lang.String sourceType, java.lang.String sourceUrl, java.lang.String sourceDriver, java.lang.String sourceUser, java.lang.String sourcePassword, java.lang.String targetType, java.lang.String targetDriver, java.lang.String targetUrl, java.lang.String targetUser, java.lang.String targetPassword, boolean backup) throws OctopusException
OctopusException
final void callOctopusLoader(java.lang.String sourceType, java.lang.String sourceUrl, java.lang.String sourceDriver, java.lang.String sourceUser, java.lang.String sourcePassword, java.lang.String targetType, java.lang.String targetDriver, java.lang.String targetUrl, java.lang.String targetUser, java.lang.String targetPassword, boolean backup, boolean generateAllVendors) throws OctopusException
OctopusException
private java.lang.String[] convertTablesToArray(java.util.ArrayList tablesList)
public boolean isCleanOctopus()
public void setCleanOctopus(boolean cleanOctopus)
cleanOctopus
- The cleanOctopus to set.public boolean isZipOctopus()
public void setZipOctopus(boolean zipOctopus)
zipOctopus
- The zipOctopus to set.public void setListener(BackupListener listener)
listener
- this thread will call the callback method on this object
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |