@@ -203,3 +203,87 @@ Feature: Mssql Sink - Run time scenarios (macro)
203203 Then Open Pipeline logs and verify Log entries having below listed Level and Message:
204204 | Level | Message |
205205 | ERROR | errorMessageInvalidCredentials |
206+
207+ @MSSQL_SOURCE_DATATYPES_UIDTYPE_TEST @MSSQL_TARGET_DATATYPES_UIDTYPE_TEST @Mssql_Required
208+ Scenario : To verify data is getting transferred from MsSQL to MsSQL successfully when macro enabled
209+ Given Open Datafusion Project to configure pipeline
210+ When Expand Plugin group in the LHS plugins list: "Source"
211+ When Select plugin: "SQL Server" from the plugins list as: "Source"
212+ When Expand Plugin group in the LHS plugins list: "Sink"
213+ When Select plugin: "SQL Server" from the plugins list as: "Sink"
214+ Then Connect plugins: "SQL Server" and "SQL Server2" to establish connection
215+ Then Navigate to the properties page of plugin: "SQL Server"
216+ Then Click on the Macro button of Property: "jdbcPluginName" and set the value to: "SQLServerDriverName"
217+ Then Click on the Macro button of Property: "host" and set the value to: "SQLServerHost"
218+ Then Click on the Macro button of Property: "port" and set the value to: "SQLServerPort"
219+ Then Click on the Macro button of Property: "user" and set the value to: "SQLServerUsername"
220+ Then Click on the Macro button of Property: "password" and set the value to: "SQLServerPassword"
221+ Then Click on the Macro button of Property: "connectionArguments" and set the value to: "connArgumentsSource"
222+ Then Click on the Macro button of Property: "database" and set the value to: "SQLServerDatabaseName"
223+ Then Click on the Macro button of Property: "importQuery" and set the value in textarea: "SQLServerImportQuery"
224+ Then Enter input plugin property: "referenceName" with value: "sourceRef"
225+ Then Click on the Macro button of Property: "numSplits" and set the value to: "SQLServerNumSplits"
226+ Then Click on the Macro button of Property: "fetchSize" and set the value to: "SQLServerFetchSize"
227+ Then Click on the Macro button of Property: "splitBy" and set the value to: "SQLServerSplitByColumn"
228+ Then Click on the Macro button of Property: "boundingQuery" and set the value in textarea: "SQLServerBoundingQuery"
229+ Then Validate "SQL Server" plugin properties
230+ Then Close the Plugin Properties page
231+ Then Navigate to the properties page of plugin: "SQL Server2"
232+ Then Click on the Macro button of Property: "jdbcPluginName" and set the value to: "SQLServerDriverName"
233+ Then Click on the Macro button of Property: "host" and set the value to: "SQLServerHost"
234+ Then Click on the Macro button of Property: "port" and set the value to: "SQLServerPort"
235+ Then Click on the Macro button of Property: "user" and set the value to: "SQLServerUsername"
236+ Then Click on the Macro button of Property: "password" and set the value to: "SQLServerPassword"
237+ Then Click on the Macro button of Property: "connectionArguments" and set the value to: "connArgumentsSink"
238+ Then Click on the Macro button of Property: "database" and set the value to: "SQLServerDatabaseName"
239+ Then Enter input plugin property: "referenceName" with value: "targetRef"
240+ And Click on the Macro button of Property: "tableName" and set the value to: "SQLServerTableName"
241+ And Click on the Macro button of Property: "dbSchemaName" and set the value to: "SQLServerSchemaName"
242+ Then Validate "SQL Server" plugin properties
243+ Then Close the Plugin Properties page
244+ Then Save the pipeline
245+ Then Preview and run the pipeline
246+ Then Enter runtime argument value "driverName" for key "SQLServerDriverName"
247+ Then Enter runtime argument value from environment variable "host" for key "SQLServerHost"
248+ Then Enter runtime argument value from environment variable "port" for key "SQLServerPort"
249+ Then Enter runtime argument value from environment variable "username" for key "SQLServerUsername"
250+ Then Enter runtime argument value from environment variable "password" for key "SQLServerPassword"
251+ Then Enter runtime argument value "connectionArguments" for key "connArgumentsSource"
252+ Then Enter runtime argument value "connectionArguments" for key "connArgumentsSink"
253+ Then Enter runtime argument value "fetchSize" for key "SQLServerFetchSize"
254+ Then Enter runtime argument value "splitByField" for key "SQLServerSplitByColumn"
255+ Then Enter runtime argument value "numberOfSplits" for key "SQLServerNumSplits"
256+ Then Enter runtime argument value "selectQuery" for key "SQLServerImportQuery"
257+ Then Enter runtime argument value "databaseName" for key "SQLServerDatabaseName"
258+ Then Enter runtime argument value "boundingQuery" for key "SQLServerBoundingQuery"
259+ Then Enter runtime argument value "targetTable" for key "SQLServerTableName"
260+ Then Enter runtime argument value "schema" for key "SQLServerSchemaName"
261+ Then Run the preview of pipeline with runtime arguments
262+ Then Wait till pipeline preview is in running state
263+ Then Open and capture pipeline preview logs
264+ Then Verify the preview run status of pipeline in the logs is "succeeded"
265+ Then Close the pipeline logs
266+ Then Close the preview
267+ Then Deploy the pipeline
268+ Then Run the Pipeline in Runtime
269+ Then Enter runtime argument value "driverName" for key "SQLServerDriverName"
270+ Then Enter runtime argument value from environment variable "host" for key "SQLServerHost"
271+ Then Enter runtime argument value from environment variable "port" for key "SQLServerPort"
272+ Then Enter runtime argument value from environment variable "username" for key "SQLServerUsername"
273+ Then Enter runtime argument value from environment variable "password" for key "SQLServerPassword"
274+ Then Enter runtime argument value "connectionArguments" for key "connArgumentsSource"
275+ Then Enter runtime argument value "connectionArguments" for key "connArgumentsSink"
276+ Then Enter runtime argument value "fetchSize" for key "SQLServerFetchSize"
277+ Then Enter runtime argument value "splitByField" for key "SQLServerSplitByColumn"
278+ Then Enter runtime argument value "numberOfSplits" for key "SQLServerNumSplits"
279+ Then Enter runtime argument value "selectQuery" for key "SQLServerImportQuery"
280+ Then Enter runtime argument value "databaseName" for key "SQLServerDatabaseName"
281+ Then Enter runtime argument value "boundingQuery" for key "SQLServerBoundingQuery"
282+ Then Enter runtime argument value "targetTable" for key "SQLServerTableName"
283+ Then Enter runtime argument value "schema" for key "SQLServerSchemaName"
284+ Then Run the Pipeline in Runtime with runtime arguments
285+ Then Wait till pipeline is in running state
286+ Then Open and capture logs
287+ Then Verify the pipeline status is "Succeeded"
288+ Then Close the pipeline logs
289+ Then Validate records transferred to target table are equal to number of records from the source table
0 commit comments