derryh/ujetl
1
0
Fork 0
mirror of https://github.com/rasilon/ujetl.git synced 2026-04-11 10:29:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Change table to job, since it's no longer just tables

Browse source
This commit is contained in:
Derry Hamilton 2019-05-10 14:37:56 +01:00
parent 93d8be0185
commit 4ec3aa8fe8
2 changed files with 15 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/main/java/com/rasilon/ujetl/CopyingApp.java
View file

@ -50,6 +50,9 @@ public class CopyingApp {
CopyingAppCommandParser cli;
String jobName;
Integer blockSize = 100;
public CopyingApp(CopyingAppCommandParser cli) {
this.cli = cli;
@ -107,28 +110,26 @@ public class CopyingApp {
long startTime = System.nanoTime();
log.info(String.format("%s - Tables are:",jobName));
Object prop = config.getProperty("tables.table.name");
log.info(String.format("%s - Jobs are:",jobName));
Object prop = config.getProperty("jobs.job.name");
if(prop instanceof Collection) {
int numTabs = ((Collection<?>) prop).size();
log.info(String.format("%s - Number of tables: %s",jobName, new Integer(numTabs)));
log.info(String.format("%s - Number of jobs: %s",jobName, new Integer(numTabs)));
for(int i=0; i < numTabs; i++ ) {
String tabName = config.getString("tables.table("+i+").name");
String tabKey = config.getString("tables.table("+i+").key");
String tabSelect = config.getString("tables.table("+i+").select");
String tabInsert = config.getString("tables.table("+i+").insert");
//processTable(sConn,dConn,tabName,tabKey,tabSelect,tabInsert,nRowsToLog);
String tabName = config.getString("jobs.job("+i+").name");
String tabKey = config.getString("jobs.job("+i+").key");
String tabSelect = config.getString("jobs.job("+i+").select");
String tabInsert = config.getString("jobs.job("+i+").insert");
Job j = new Job(sConn,dConn,tabName,jobName,tabKey,tabSelect,tabInsert,nRowsToLog,blockSize);
j.start();
j.join();
}
} else if(prop instanceof String) {
String tabName = config.getString("tables.table.name");
String tabKey = config.getString("tables.table.key");
String tabSelect = config.getString("tables.table.select");
String tabInsert = config.getString("tables.table.insert");
//processTable(sConn,dConn,tabName,tabKey,tabSelect,tabInsert,nRowsToLog);
String tabName = config.getString("jobs.job.name");
String tabKey = config.getString("jobs.job.key");
String tabSelect = config.getString("jobs.job.select");
String tabInsert = config.getString("jobs.job.insert");
Job j = new Job(sConn,dConn,tabName,jobName,tabKey,tabSelect,tabInsert,nRowsToLog,blockSize);
j.start();
j.join();