Skip to content

e2e sqlserver additional scenarios #567

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
AnkitCLI merged 1 commit into from
Mar 18, 2025
Merged

e2e sqlserver additional scenarios #567

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
90 changes: 90 additions & 0 deletions mssql-plugin/src/e2e-test/features/mssql/mssql sink/DesignTimeValidation.feature
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -171,3 +171,93 @@ Feature: Mssql source- Verify Mssql source plugin design time validation scenari
Then Enter input plugin property: "referenceName" with value: "targetRef"
And Click on the Validate button
Then Verify that the Plugin is displaying an error message: "errormessageBlankHost" on the header

@Mssql_Required
Scenario: Verify required fields missing validation messages
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Navigate to the properties page of plugin: "SQL Server"
Then Click on the Validate button
Then Verify mandatory property error for below listed properties:
| jdbcPluginName |
| referenceName |
| database |
| tableName |

@Mssql_Required
Scenario: Verify the validation error message with missing jdbc plugin name
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Navigate to the properties page of plugin: "SQL Server"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Click plugin property: "switch-useConnection"
Then Click on the Validate button
Then Verify that the Plugin is displaying an error message: "blank.jdbcPluginName.message" on the header

@MSSQL_AS_SOURCE @MSSQL_AS_TARGET @Mssql_Required
Scenario: Verify the validation error message with blank password value
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Connect plugins: "SQL Server" and "SQL Server2" to establish connection
Then Navigate to the properties page of plugin: "SQL Server"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Enter input plugin property: "referenceName" with value: "sourceRef"
Then Replace input plugin property: "database" with value: "databaseName"
Then Enter textarea plugin property: "importQuery" with value: "selectQuery"
Then Validate "SQL Server" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "SQL Server2"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "database" with value: "databaseName"
Then Replace input plugin property: "tableName" with value: "targetTable"
Then Replace input plugin property: "dbSchemaName" with value: "schema"
Then Enter input plugin property: "referenceName" with value: "targetRef"
Then Click on the Validate button
Then Verify that the Plugin is displaying an error message: "blank.connection.message" on the header

@MSSQL_AS_SOURCE @MSSQL_AS_TARGET @Mssql_Required
Scenario: Verify the validation error message with blank host value
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Connect plugins: "SQL Server" and "SQL Server2" to establish connection
Then Navigate to the properties page of plugin: "SQL Server"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Enter input plugin property: "referenceName" with value: "sourceRef"
Then Replace input plugin property: "database" with value: "databaseName"
Then Enter textarea plugin property: "importQuery" with value: "selectQuery"
Then Validate "MySQL" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "SQL Server2"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "database" with value: "databaseName"
Then Replace input plugin property: "tableName" with value: "targetTable"
Then Replace input plugin property: "dbSchemaName" with value: "schema"
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Enter input plugin property: "referenceName" with value: "targetRef"
Then Click on the Validate button
Then Verify that the Plugin is displaying an error message: "blank.connection.message" on the header
52 changes: 52 additions & 0 deletions mssql-plugin/src/e2e-test/features/mssql/mssql sink/RunTime.feature
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,3 +60,55 @@ Feature: Mssql - Verify Mssql sink data transfer
Then Close the pipeline logs
Then Validate the values of records transferred to target MsSql table is equal to the values from source BigQuery table

@MSSQL_SOURCE @MSSQL_TARGET @CONNECTION @Mssql_Required
Scenario: To verify data is getting transferred from Mssql to Mssql successfully with use connection using MAX type datatypes
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Connect plugins: "SQL Server" and "SQL Server2" to establish connection
Then Navigate to the properties page of plugin: "SQL Server"
And Click plugin property: "switch-useConnection"
And Click on the Browse Connections button
And Click on the Add Connection button
Then Click plugin property: "connector-SQL Server"
And Enter input plugin property: "name" with value: "connection.name"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Click on the Test Connection button
And Verify the test connection is successful
Then Click on the Create button
Then Select connection: "connection.name"
Then Enter input plugin property: "referenceName" with value: "sourceRef"
Then Replace input plugin property: "database" with value: "databaseName"
Then Enter textarea plugin property: "importQuery" with value: "selectQuery"
Then Click on the Get Schema button
Then Verify the Output Schema matches the Expected Schema: "mssqlOutputDatatypesSchema"
Then Validate "SQL Server" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "SQL Server2"
And Click plugin property: "switch-useConnection"
And Click on the Browse Connections button
Then Select connection: "connection.name"
Then Replace input plugin property: "database" with value: "databaseName"
Then Replace input plugin property: "tableName" with value: "targetTable"
Then Replace input plugin property: "dbSchemaName" with value: "schema"
Then Enter input plugin property: "referenceName" with value: "targetRef"
Then Validate "SQL Server2" plugin properties
Then Close the Plugin Properties page
Then Save the pipeline
Then Preview and run the pipeline
Then Verify the preview of pipeline is "success"
Then Click on preview data for Mssql sink
Then Verify preview output schema matches the outputSchema captured in properties
Then Close the preview data
Then Deploy the pipeline
Then Run the Pipeline in Runtime
Then Wait till pipeline is in running state
Then Open and capture logs
Then Verify the pipeline status is "Succeeded"
Then Validate records transferred to target table are equal to number of records from the source table
84 changes: 84 additions & 0 deletions mssql-plugin/src/e2e-test/features/mssql/mssql sink/RunTimeWithMacros.feature
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -203,3 +203,87 @@ Feature: Mssql Sink - Run time scenarios (macro)
Then Open Pipeline logs and verify Log entries having below listed Level and Message:
| Level | Message |
| ERROR | errorMessageInvalidCredentials |

@MSSQL_SOURCE_DATATYPES_UIDTYPE_TEST @MSSQL_TARGET_DATATYPES_UIDTYPE_TEST @Mssql_Required
Scenario: To verify data is getting transferred from MsSQL to MsSQL successfully when macro enabled
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "SQL Server" from the plugins list as: "Sink"
Then Connect plugins: "SQL Server" and "SQL Server2" to establish connection
Then Navigate to the properties page of plugin: "SQL Server"
Then Click on the Macro button of Property: "jdbcPluginName" and set the value to: "SQLServerDriverName"
Then Click on the Macro button of Property: "host" and set the value to: "SQLServerHost"
Then Click on the Macro button of Property: "port" and set the value to: "SQLServerPort"
Then Click on the Macro button of Property: "user" and set the value to: "SQLServerUsername"
Then Click on the Macro button of Property: "password" and set the value to: "SQLServerPassword"
Then Click on the Macro button of Property: "connectionArguments" and set the value to: "connArgumentsSource"
Then Click on the Macro button of Property: "database" and set the value to: "SQLServerDatabaseName"
Then Click on the Macro button of Property: "importQuery" and set the value in textarea: "SQLServerImportQuery"
Then Enter input plugin property: "referenceName" with value: "sourceRef"
Then Click on the Macro button of Property: "numSplits" and set the value to: "SQLServerNumSplits"
Then Click on the Macro button of Property: "fetchSize" and set the value to: "SQLServerFetchSize"
Then Click on the Macro button of Property: "splitBy" and set the value to: "SQLServerSplitByColumn"
Then Click on the Macro button of Property: "boundingQuery" and set the value in textarea: "SQLServerBoundingQuery"
Then Validate "SQL Server" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "SQL Server2"
Then Click on the Macro button of Property: "jdbcPluginName" and set the value to: "SQLServerDriverName"
Then Click on the Macro button of Property: "host" and set the value to: "SQLServerHost"
Then Click on the Macro button of Property: "port" and set the value to: "SQLServerPort"
Then Click on the Macro button of Property: "user" and set the value to: "SQLServerUsername"
Then Click on the Macro button of Property: "password" and set the value to: "SQLServerPassword"
Then Click on the Macro button of Property: "connectionArguments" and set the value to: "connArgumentsSink"
Then Click on the Macro button of Property: "database" and set the value to: "SQLServerDatabaseName"
Then Enter input plugin property: "referenceName" with value: "targetRef"
And Click on the Macro button of Property: "tableName" and set the value to: "SQLServerTableName"
And Click on the Macro button of Property: "dbSchemaName" and set the value to: "SQLServerSchemaName"
Then Validate "SQL Server" plugin properties
Then Close the Plugin Properties page
Then Save the pipeline
Then Preview and run the pipeline
Then Enter runtime argument value "driverName" for key "SQLServerDriverName"
Then Enter runtime argument value from environment variable "host" for key "SQLServerHost"
Then Enter runtime argument value from environment variable "port" for key "SQLServerPort"
Then Enter runtime argument value from environment variable "username" for key "SQLServerUsername"
Then Enter runtime argument value from environment variable "password" for key "SQLServerPassword"
Then Enter runtime argument value "connectionArguments" for key "connArgumentsSource"
Then Enter runtime argument value "connectionArguments" for key "connArgumentsSink"
Then Enter runtime argument value "fetchSize" for key "SQLServerFetchSize"
Then Enter runtime argument value "splitByField" for key "SQLServerSplitByColumn"
Then Enter runtime argument value "numberOfSplits" for key "SQLServerNumSplits"
Then Enter runtime argument value "selectQuery" for key "SQLServerImportQuery"
Then Enter runtime argument value "databaseName" for key "SQLServerDatabaseName"
Then Enter runtime argument value "boundingQuery" for key "SQLServerBoundingQuery"
Then Enter runtime argument value "targetTable" for key "SQLServerTableName"
Then Enter runtime argument value "schema" for key "SQLServerSchemaName"
Then Run the preview of pipeline with runtime arguments
Then Wait till pipeline preview is in running state
Then Open and capture pipeline preview logs
Then Verify the preview run status of pipeline in the logs is "succeeded"
Then Close the pipeline logs
Then Close the preview
Then Deploy the pipeline
Then Run the Pipeline in Runtime
Then Enter runtime argument value "driverName" for key "SQLServerDriverName"
Then Enter runtime argument value from environment variable "host" for key "SQLServerHost"
Then Enter runtime argument value from environment variable "port" for key "SQLServerPort"
Then Enter runtime argument value from environment variable "username" for key "SQLServerUsername"
Then Enter runtime argument value from environment variable "password" for key "SQLServerPassword"
Then Enter runtime argument value "connectionArguments" for key "connArgumentsSource"
Then Enter runtime argument value "connectionArguments" for key "connArgumentsSink"
Then Enter runtime argument value "fetchSize" for key "SQLServerFetchSize"
Then Enter runtime argument value "splitByField" for key "SQLServerSplitByColumn"
Then Enter runtime argument value "numberOfSplits" for key "SQLServerNumSplits"
Then Enter runtime argument value "selectQuery" for key "SQLServerImportQuery"
Then Enter runtime argument value "databaseName" for key "SQLServerDatabaseName"
Then Enter runtime argument value "boundingQuery" for key "SQLServerBoundingQuery"
Then Enter runtime argument value "targetTable" for key "SQLServerTableName"
Then Enter runtime argument value "schema" for key "SQLServerSchemaName"
Then Run the Pipeline in Runtime with runtime arguments
Then Wait till pipeline is in running state
Then Open and capture logs
Then Verify the pipeline status is "Succeeded"
Then Close the pipeline logs
Then Validate records transferred to target table are equal to number of records from the source table
28 changes: 28 additions & 0 deletions mssql-plugin/src/e2e-test/features/mssql/mssql source/DesignTimeValidation.feature
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -200,3 +200,31 @@ Feature: Mssql source- Verify Mssql source plugin design time validation scenari
Then Click on the Validate button
Then Verify that the Plugin Property: "boundingQuery" is displaying an in-line error message: "errorMessageBoundingQuery"
Then Verify that the Plugin Property: "numSplits" is displaying an in-line error message: "errorMessagenumofSplit"

@Mssql_Required
Scenario: Verify required fields missing validation messages
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
Then Navigate to the properties page of plugin: "SQL Server"
Then Click on the Validate button
Then Verify mandatory property error for below listed properties:
| jdbcPluginName |
| referenceName |
| database |
| importQuery |

@Mssql_Required
Scenario: Verify the validation error message with missing jdbc plugin name
Given Open Datafusion Project to configure pipeline
When Expand Plugin group in the LHS plugins list: "Source"
When Select plugin: "SQL Server" from the plugins list as: "Source"
Then Navigate to the properties page of plugin: "SQL Server"
Then Select dropdown plugin property: "select-jdbcPluginName" with option value: "driverName"
Then Replace input plugin property: "host" with value: "host" for Credentials and Authorization related fields
Then Replace input plugin property: "port" with value: "port" for Credentials and Authorization related fields
Then Replace input plugin property: "user" with value: "username" for Credentials and Authorization related fields
Then Replace input plugin property: "password" with value: "password" for Credentials and Authorization related fields
Then Click plugin property: "switch-useConnection"
Then Click on the Validate button
Then Verify that the Plugin is displaying an error message: "blank.jdbcPluginName.message" on the header
Loading
Loading