@@ -203,3 +203,87 @@ Feature: Mssql Sink - Run time scenarios (macro)
203
203
Then Open Pipeline logs and verify Log entries having below listed Level and Message:
204
204
| Level | Message |
205
205
| 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