Class MergeLogsCLI

java.lang.Object

com.scivicslab.actoriac.cli.MergeLogsCLI

All Implemented Interfaces:

Callable<Integer>

public class MergeLogsCLI
extends Object
implements Callable<Integer>

CLI subcommand to merge scattered log databases into a single database.

Before the log-server feature, each workflow run would create its own separate database file. This command consolidates them into one database.

Usage Examples

# Scan a directory for .mv.db files and merge them
actor-iac merge-logs --scan ./workflows --target ./logs/merged

# Merge specific database files
actor-iac merge-logs --target ./logs/merged ./db1 ./db2 ./db3

# Dry-run to see what would be merged
actor-iac merge-logs --scan ./workflows --target ./logs/merged --dry-run

Since:

2.10.0

Author:

devteam@scivics-lab.com

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	dryRun
private File	scanDir
private boolean	skipDuplicates
private int	skippedSessions
private List<File>	sourceDbs
private File	targetDb
private int	totalLogs
private int	totalNodeResults
private int	totalSessions	Statistics for reporting
private boolean	verbose

Constructor Summary

Constructors

Constructor	Description
MergeLogsCLI()

Method Summary

Modifier and Type	Method	Description
Integer	call()
private List<File>	collectSourceDatabases()	Collects all source database files from scan directory and explicit parameters.
private int	copyLogs(Connection source, Connection target, long oldSessionId, long newSessionId)	Copies logs from source to target with new session ID.
private int	copyNodeResults(Connection source, Connection target, long oldSessionId, long newSessionId)	Copies node_results from source to target with new session ID.
private int	countRows(Connection conn, String table)	Counts rows in a table.
private int	dryRunAnalysis(List<File> sources)	Performs dry-run analysis showing what would be merged.
private void	initializeSchema(Connection conn)	Initializes the target database schema.
private long	insertSession(Connection target, ResultSet rs, String sourceName)	Inserts a session into the target database.
private Set<String>	loadExistingSessions(Connection conn)	Loads existing session keys for duplicate detection.
private String	makeSessionKey(String workflowName, Timestamp startedAt)	Creates a unique key for duplicate detection.
private void	mergeDatabase(Connection source, Connection target, Set<String> existingSessions, String sourceName)	Merges one source database into the target.
private Connection	openDatabase(File dbPath)	Opens a database connection.
private int	performMerge(List<File> sources)	Performs the actual merge operation.
private boolean	tableExists(Connection conn, String tableName)	Checks if a table exists in the database.
private static String	truncate(String s, int maxLen)	Truncates a string to max length with ellipsis.

Methods inherited from class Object

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

Field Details

targetDb

private File targetDb

scanDir

private File scanDir

sourceDbs

private List<File> sourceDbs

dryRun

private boolean dryRun

verbose

private boolean verbose

skipDuplicates

private boolean skipDuplicates

totalSessions

private int totalSessions

Statistics for reporting

totalLogs

private int totalLogs

totalNodeResults

private int totalNodeResults

skippedSessions

private int skippedSessions

Constructor Details

MergeLogsCLI

public MergeLogsCLI()

Method Details

call

public Integer call()

Specified by:

call in interface Callable<Integer>

collectSourceDatabases

private List<File> collectSourceDatabases()

Collects all source database files from scan directory and explicit parameters.

dryRunAnalysis

private int dryRunAnalysis(List<File> sources)

Performs dry-run analysis showing what would be merged.

performMerge

private int performMerge(List<File> sources)
                  throws SQLException

Performs the actual merge operation.

Throws:

SQLException

openDatabase

private Connection openDatabase(File dbPath)
                         throws SQLException

Opens a database connection.

Throws:

SQLException

initializeSchema

private void initializeSchema(Connection conn)
                       throws SQLException

Initializes the target database schema.

Throws:

SQLException

loadExistingSessions

private Set<String> loadExistingSessions(Connection conn)
                                  throws SQLException

Loads existing session keys for duplicate detection.

Throws:

SQLException

makeSessionKey

private String makeSessionKey(String workflowName,
 Timestamp startedAt)

Creates a unique key for duplicate detection.

tableExists

private boolean tableExists(Connection conn,
 String tableName)

Checks if a table exists in the database.

mergeDatabase

private void mergeDatabase(Connection source,
 Connection target,
 Set<String> existingSessions,
 String sourceName)
                    throws SQLException

Merges one source database into the target.

Throws:

SQLException

insertSession

private long insertSession(Connection target,
 ResultSet rs,
 String sourceName)
                    throws SQLException

Inserts a session into the target database.

Throws:

SQLException

copyLogs

private int copyLogs(Connection source,
 Connection target,
 long oldSessionId,
 long newSessionId)
              throws SQLException

Copies logs from source to target with new session ID.

Throws:

SQLException

copyNodeResults

private int copyNodeResults(Connection source,
 Connection target,
 long oldSessionId,
 long newSessionId)
                     throws SQLException

Copies node_results from source to target with new session ID.

Throws:

SQLException

countRows

private int countRows(Connection conn,
 String table)
               throws SQLException

Counts rows in a table.

Throws:

SQLException

truncate

private static String truncate(String s,
 int maxLen)

Truncates a string to max length with ellipsis.