Merge pull request #8779 from eddie-martinez/BACKLOG-36983

[BACKLOG-36983] Determine all the fields that are required for Insert…
pentaho · Jan 23, 2023 · 123cb2c · 123cb2c
2 parents a9be652 + f7ca1df
commit 123cb2c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/engine/src/main/java/org/pentaho/di/trans/steps/delete/DeleteMeta.java b/engine/src/main/java/org/pentaho/di/trans/steps/delete/DeleteMeta.java
@@ -84,15 +84,15 @@ public class DeleteMeta extends BaseDatabaseStepMeta implements StepMetaInterfac
   private DatabaseMeta databaseMeta;
 
   /** The target schema name */
-  @Injection( name = "TARGET_SCHEMA" )
+  @Injection( name = "TARGET_SCHEMA", required = true )
   private String schemaName;
 
   /** The lookup table name */
-  @Injection( name = "TARGET_TABLE" )
+  @Injection( name = "TARGET_TABLE", required = true )
   private String tableName;
 
   /** database connection */
-  @Injection( name = "CONNECTIONNAME" )
+  @Injection( name = "CONNECTIONNAME", required = true )
   public void metaSetConnection( String connectionName ) throws KettleException {
     setConnection( connectionName );
   }

diff --git a/engine/src/main/java/org/pentaho/di/trans/steps/insertupdate/InsertUpdateMeta.java b/engine/src/main/java/org/pentaho/di/trans/steps/insertupdate/InsertUpdateMeta.java
@@ -70,13 +70,13 @@ public class InsertUpdateMeta extends BaseDatabaseStepMeta implements StepMetaIn
   /**
    * what's the lookup schema?
    */
-  @Injection( name = "SCHEMA_NAME" )
+  @Injection( name = "SCHEMA_NAME", required = true )
   private String schemaName;
 
   /**
    * what's the lookup table?
    */
-  @Injection( name = "TABLE_NAME" )
+  @Injection( name = "TABLE_NAME", required = true )
   private String tableName;
 
   /**
@@ -102,7 +102,7 @@ public class InsertUpdateMeta extends BaseDatabaseStepMeta implements StepMetaIn
   @Injection( name = "DO_NOT" )
   private boolean updateBypassed;
 
-  @Injection( name = "CONNECTIONNAME" )
+  @Injection( name = "CONNECTIONNAME", required = true )
   public void setConnection( String connectionName ) {
     databaseMeta = DatabaseMeta.findDatabase( databases, connectionName );
   }