Package org.jumpmind.symmetric.util

Class SnapshotUtil

java.lang.Object

org.jumpmind.symmetric.util.SnapshotUtil

@IgnoreJRERequirement
public class SnapshotUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SNAPSHOT_DIR
protected static final int	THREAD_INDENT_SPACE

Constructor Summary

Constructors

Constructor	Description
SnapshotUtil()

Method Summary

Modifier and Type	Method	Description
protected static void	addTablesForLoadByCatalogSchema(ISymmetricEngine engine, HashMap<CatalogSchema,List<Table>> catalogSchemas)
protected static void	checkpoint(ISymmetricEngine engine, IProgressListener listener, int stepNumber, int totalSteps)
static void	createProcessInfoFile(ISymmetricEngine engine, String parent)
static File	createSnapshot(ISymmetricEngine engine, IProgressListener listener)
static File	createThreadsFile(String parent, boolean isFiltered)
static File	createThreadStatsFile(String parent)
protected static void	extract(DbExport export, int maxRows, String whereClause, File file, String... tables)
protected static void	extract(DbExport export, File file, String... tables)
protected static void	extractQuery(ISqlTemplate sqlTemplate, String fileName, String sql)
protected static Map<String,List<TransformTable>>	getByTableTransforms(ITransformService transformService, Map<NodeGroupLink,Map<String,List<TransformTable>>> transformMap, NodeGroupLink nodeGroupLink, TransformPoint transformPoint)
protected static String	getJobStatus(IJob job, Lock lock)
protected static String	getLastFinishTime(IJob job, Lock lock)
static File	getSnapshotDirectory(ISymmetricEngine engine)
static HashMap<CatalogSchema,List<Table>>	getTablesForCaptureByCatalogSchema(ISymmetricEngine engine)
static HashMap<CatalogSchema,List<Table>>	getTablesForLoadByCatalogSchema(ISymmetricEngine engine)
static void	outputSymDataForBatchesInError(ISymmetricEngine engine, File tmpDir)
protected static void	printDirectoryContents(File dir, StringBuilder output, org.jumpmind.symmetric.util.SnapshotUtil.PrintDirConfig config)
protected static Map<String,List<TransformTable>>	toMap(List<TransformService.TransformTableNodeGroupLink> transforms)
protected static void	writeDirectoryListing(ISymmetricEngine engine, File tmpDir)
protected static void	writeDirectoryStaging(ISymmetricEngine engine, File tmpDir)
protected static void	writeJobsStats(ISymmetricEngine engine, File tmpDir)
protected static void	writeProperties(Properties properties, File tmpDir, String fileName)
protected static void	writeRuntimeStats(ISymmetricEngine engine, File tmpDir)

Methods inherited from class java.lang.Object

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

Field Details

THREAD_INDENT_SPACE

protected static final int THREAD_INDENT_SPACE

See Also:

• Constant Field Values

SNAPSHOT_DIR

public static final String SNAPSHOT_DIR

See Also:

• Constant Field Values

Constructor Details

SnapshotUtil

public SnapshotUtil()

Method Details

getSnapshotDirectory

public static File getSnapshotDirectory(ISymmetricEngine engine)

createSnapshot

public static File createSnapshot(ISymmetricEngine engine,
 IProgressListener listener)

checkpoint

protected static void checkpoint(ISymmetricEngine engine,
 IProgressListener listener,
 int stepNumber,
 int totalSteps)

extract

protected static void extract(DbExport export,
 File file,
 String... tables)

extract

protected static void extract(DbExport export,
 int maxRows,
 String whereClause,
 File file,
 String... tables)

extractQuery

protected static void extractQuery(ISqlTemplate sqlTemplate,
 String fileName,
 String sql)

writeDirectoryListing

protected static void writeDirectoryListing(ISymmetricEngine engine,
 File tmpDir)

writeDirectoryStaging

protected static void writeDirectoryStaging(ISymmetricEngine engine,
 File tmpDir)

printDirectoryContents

protected static void printDirectoryContents(File dir,
 StringBuilder output,
 org.jumpmind.symmetric.util.SnapshotUtil.PrintDirConfig config)
                                      throws IOException

Throws:

IOException

writeRuntimeStats

protected static void writeRuntimeStats(ISymmetricEngine engine,
 File tmpDir)

writeProperties

protected static void writeProperties(Properties properties,
 File tmpDir,
 String fileName)

writeJobsStats

protected static void writeJobsStats(ISymmetricEngine engine,
 File tmpDir)

getJobStatus

protected static String getJobStatus(IJob job,
 Lock lock)

getLastFinishTime

protected static String getLastFinishTime(IJob job,
 Lock lock)

createThreadsFile

public static File createThreadsFile(String parent,
 boolean isFiltered)

createThreadStatsFile

public static File createThreadStatsFile(String parent)

createProcessInfoFile

public static void createProcessInfoFile(ISymmetricEngine engine,
 String parent)

outputSymDataForBatchesInError

public static void outputSymDataForBatchesInError(ISymmetricEngine engine,
 File tmpDir)

getTablesForCaptureByCatalogSchema

public static HashMap<CatalogSchema,List<Table>> getTablesForCaptureByCatalogSchema(ISymmetricEngine engine)

getTablesForLoadByCatalogSchema

public static HashMap<CatalogSchema,List<Table>> getTablesForLoadByCatalogSchema(ISymmetricEngine engine)

addTablesForLoadByCatalogSchema

protected static void addTablesForLoadByCatalogSchema(ISymmetricEngine engine,
 HashMap<CatalogSchema,List<Table>> catalogSchemas)

getByTableTransforms

protected static Map<String,List<TransformTable>> getByTableTransforms(ITransformService transformService,
 Map<NodeGroupLink,Map<String,List<TransformTable>>> transformMap,
 NodeGroupLink nodeGroupLink,
 TransformPoint transformPoint)

toMap

protected static Map<String,List<TransformTable>> toMap(List<TransformService.TransformTableNodeGroupLink> transforms)