(hop) branch main updated: Fix #4055 MySQL Bulk Load Action: manage connection through variables (#6135)

[hansva]

This is an automated email from the ASF dual-hosted git repository.

hansva pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/hop.git


The following commit(s) were added to refs/heads/main by this push:
     new 28c14e3d51 Fix #4055 MySQL Bulk Load Action: manage connection through 
variables (#6135)
28c14e3d51 is described below

commit 28c14e3d514bbf1b581f755a612e0041f51197e5
Author: Sergio Ramazzina <sergio.ramazz...@serasoft.it>
AuthorDate: Sun Dec 7 14:18:41 2025 +0100

    Fix #4055 MySQL Bulk Load Action: manage connection through variables 
(#6135)
---
 .../hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoad.java    | 7 +------
 .../workflow/actions/mysqlbulkload/ActionMysqlBulkLoadDialog.java  | 3 ++-
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoad.java
 
b/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoad.java
index d78c2d3e43..b2efb85378 100644
--- 
a/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoad.java
+++ 
b/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoad.java
@@ -191,12 +191,7 @@ public class ActionMysqlBulkLoad extends ActionBase {
           }
 
           if (connection != null) {
-            DatabaseMeta databaseMeta = null;
-            try {
-              databaseMeta = DatabaseMeta.loadDatabase(getMetadataProvider(), 
connection);
-            } catch (Exception e) {
-              logError("Unable to load database :" + connection, e);
-            }
+            DatabaseMeta databaseMeta = 
parentWorkflowMeta.findDatabase(connection, getVariables());
             // User has specified a connection, We can continue ...
             try (Database db = new Database(this, this, databaseMeta)) {
               db.connect();
diff --git 
a/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoadDialog.java
 
b/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoadDialog.java
index 6386300104..8878cb9be4 100644
--- 
a/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoadDialog.java
+++ 
b/plugins/actions/mysqlbulkload/src/main/java/org/apache/hop/workflow/actions/mysqlbulkload/ActionMysqlBulkLoadDialog.java
@@ -159,7 +159,8 @@ public class ActionMysqlBulkLoadDialog extends ActionDialog 
{
     wName.setLayoutData(fdName);
 
     // Connection line
-    wConnection = addConnectionLine(shell, wName, action.getConnection(), 
lsMod);
+    DatabaseMeta databaseMeta = 
workflowMeta.findDatabase(action.getConnection(), variables);
+    wConnection = addConnectionLine(shell, wName, databaseMeta, lsMod);
 
     // Schema name line
     // Schema name