Skip to content

Commit

Permalink
Task utils refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
serge-rider committed Feb 8, 2020
1 parent f2601a9 commit 17a0717
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
import org.jkiss.dbeaver.model.task.DBTTask;
import org.jkiss.dbeaver.model.task.DBTTaskExecutionListener;
import org.jkiss.dbeaver.model.task.DBTTaskHandler;
import org.jkiss.dbeaver.model.task.DBTUtils;
import org.jkiss.dbeaver.model.task.DBTaskUtils;
import org.jkiss.dbeaver.tools.sql.SQLScriptExecuteSettings;
import org.jkiss.utils.IOUtils;

Expand Down Expand Up @@ -125,7 +125,7 @@ private void runScripts(DBRProgressMonitor monitor, DBTTask task, DBPDataSourceC
private void processScript(DBRProgressMonitor monitor, DBTTask task, SQLScriptExecuteSettings settings, DBCExecutionContext executionContext, String filePath, String sqlScriptContent, Log log, Writer logStream) throws DBException {
List<SQLScriptElement> scriptElements = SQLScriptParser.parseScript(executionContext, sqlScriptContent);
SQLScriptContext scriptContext = new SQLScriptContext(null, () -> executionContext, null, logStream, null);
scriptContext.setVariables(DBTUtils.getVariables(task));
scriptContext.setVariables(DBTaskUtils.getVariables(task));
SQLScriptDataReceiver dataReceiver = new SQLScriptDataReceiver();
SQLScriptProcessor scriptProcessor = new SQLScriptProcessor(executionContext, scriptElements, scriptContext, dataReceiver, log);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@
import org.jkiss.dbeaver.model.struct.DBSDataContainer;
import org.jkiss.dbeaver.model.struct.DBSEntity;
import org.jkiss.dbeaver.model.task.DBTTask;
import org.jkiss.dbeaver.model.task.DBTUtils;
import org.jkiss.dbeaver.model.task.DBTaskUtils;
import org.jkiss.dbeaver.runtime.DBWorkbench;
import org.jkiss.dbeaver.runtime.serialize.DBPObjectSerializer;
import org.jkiss.dbeaver.tools.transfer.IDataTransferConsumer;
Expand Down Expand Up @@ -162,7 +162,7 @@ public void transferData(
context = DBUtils.getObjectOwnerInstance(getDatabaseObject()).openIsolatedContext(monitor, "Data transfer producer", context);
}
if (task != null) {
DBTUtils.initFromContext(monitor, task, context);
DBTaskUtils.initFromContext(monitor, task, context);
}

try (DBCSession session = context.openSession(monitor, DBCExecutionPurpose.UTIL, contextTask)) {
Expand Down Expand Up @@ -329,7 +329,7 @@ public DatabaseTransferProducer deserializeObject(DBRRunnableContext runnableCon
SQLQuery query = new SQLQuery(ds.getDataSource(), queryText);
SQLScriptContext scriptContext = new SQLScriptContext(null,
new DataSourceContextProvider(ds), null, new PrintWriter(System.err, true), null);
scriptContext.setVariables(DBTUtils.getVariables(objectContext));
scriptContext.setVariables(DBTaskUtils.getVariables(objectContext));
producer.dataContainer = new SQLQueryDataContainer(new DataSourceContextProvider(ds), query, scriptContext, log);
break;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@
/**
* Task utils
*/
public class DBTUtils {
private static final Log log = Log.getLog(DBTUtils.class);
public class DBTaskUtils {
private static final Log log = Log.getLog(DBTaskUtils.class);

public static final String TASK_VARIABLES = "taskVariables";
public static final String TASK_CONTEXT = "taskContext";
Expand All @@ -56,9 +56,9 @@ public static Map<String, Object> getVariables(@NotNull DBTTask task) {

public static void setVariables(@NotNull Map<String, Object> taskState, @Nullable Map<String, Object> variables) {
if (!CommonUtils.isEmpty(variables)) {
taskState.put(DBTUtils.TASK_VARIABLES, variables);
taskState.put(DBTaskUtils.TASK_VARIABLES, variables);
} else {
taskState.remove(DBTUtils.TASK_VARIABLES);
taskState.remove(DBTaskUtils.TASK_VARIABLES);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
import org.jkiss.dbeaver.model.task.DBTTask;
import org.jkiss.dbeaver.model.task.DBTTaskContext;
import org.jkiss.dbeaver.model.task.DBTTaskType;
import org.jkiss.dbeaver.model.task.DBTUtils;
import org.jkiss.dbeaver.model.task.DBTaskUtils;
import org.jkiss.dbeaver.registry.task.TaskRegistry;
import org.jkiss.dbeaver.runtime.DBWorkbench;
import org.jkiss.dbeaver.tasks.ui.view.DatabaseTasksView;
Expand Down Expand Up @@ -236,10 +236,10 @@ protected void saveConfigurationToTask(DBTTask theTask) {

DBTTaskContext context = getTaskContext();
if (context != null) {
DBTUtils.saveTaskContext(state, context);
DBTaskUtils.saveTaskContext(state, context);
}
if (theTask.getType().supportsVariables()) {
DBTUtils.setVariables(state, getTaskVariables());
DBTaskUtils.setVariables(state, getTaskVariables());
}
theTask.setProperties(state);
try {
Expand Down Expand Up @@ -304,7 +304,7 @@ private void configureVariables() {
protected Map<String, Object> getTaskVariables() {
if (variables == null) {
if (currentTask != null) {
variables = DBTUtils.getVariables(currentTask);
variables = DBTaskUtils.getVariables(currentTask);
} else {
variables = new LinkedHashMap<>();
}
Expand All @@ -315,14 +315,14 @@ protected Map<String, Object> getTaskVariables() {
public DBTTaskContext getTaskContext() {
if (taskContext == null) {
if (currentTask != null) {
taskContext = DBTUtils.loadTaskContext(currentTask.getProperties());
taskContext = DBTaskUtils.loadTaskContext(currentTask.getProperties());
}
}
return taskContext;
}

protected void saveTaskContext(DBCExecutionContext executionContext) {
taskContext = DBTUtils.extractContext(executionContext);
taskContext = DBTaskUtils.extractContext(executionContext);
}

public void updateSaveTaskButtons() {
Expand Down

0 comments on commit 17a0717

Please sign in to comment.