CloudSql My Sql Sink Run Time Scenarios e2e tests

Author: priyabhatnagar25

cloudsql-mysql-plugin/src/e2e-test/features/source/CloudMySqlRunTime.feature

@@ -31,8 +31,6 @@ Feature: CloudMySql - Verify data transfer from CloudMySql source to BigQuery si
     Then Enter input plugin property: "connectionName" with value: "ConnectionName"
     Then Enter input plugin property: "user" with value: "username"
     Then Enter input plugin property: "password" with value: "password"
-#    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: "RefName"
     Then Enter input plugin property: "database" with value: "DatabaseName"
     Then Enter textarea plugin property: "importQuery" with value: "selectQuery"
@@ -147,6 +145,7 @@ Feature: CloudMySql - Verify data transfer from CloudMySql source to BigQuery si
     Then Wait till pipeline is in running state
     Then Open and capture logs
     Then Verify the pipeline status is "Succeeded"
+    Then Validate the values of records transferred to target table is equal to the values from source table
 
   @CLOUDMYSQL_SOURCE_DATATYPES_TEST
   Scenario: To verify data is getting transferred from CloudMySql source to CloudMySql successfully when connection arguments are set

cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySql/runners/package-info.java

@@ -0,0 +1,21 @@
+/*
+        * Copyright © 2022 Cask Data, Inc.
+        *
+        * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+        * use this file except in compliance with the License. You may obtain a copy of
+        * the License at
+        *
+        * http://www.apache.org/licenses/LICENSE-2.0
+        *
+        * Unless required by applicable law or agreed to in writing, software
+        * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+        * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+        * License for the specific language governing permissions and limitations under
+        * the License.
+        */
+
+/**
+ * Package contains the runners for CoudMysql features.
+ */
+
+package io.cdap.plugin.CloudMySql.runners;

cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySql/stepsdesign/CloudMySql.java

@@ -0,0 +1,30 @@
+package io.cdap.plugin.CloudMySql.stepsdesign;
+
+import io.cdap.e2e.utils.CdfHelper;
+import io.cdap.e2e.utils.PluginPropertyUtils;
+import io.cdap.plugin.CloudMySqlClient;
+import io.cucumber.java.en.Then;
+import org.junit.Assert;
+import stepsdesign.BeforeActions;
+import io.cdap.e2e.utils.PluginPropertyUtils;
+
+import java.sql.SQLException;
+
+/**
+ *  CloudSqlMySql Plugin related step design.
+ */
+public class CloudMysql implements CdfHelper {
+
+    @Then("Validate the values of records transferred to target table is equal to the values from source table")
+    public void validateTheValuesOfRecordsTransferredToTargetTableIsEqualToTheValuesFromSourceTable() throws SQLException, ClassNotFoundException {
+        int countRecords = CloudMySqlClient.countRecord(PluginPropertyUtils.pluginProp("targetTable"));
+        Assert.assertEquals("Number of records transferred should be equal to records out ",
+                countRecords, recordOut());
+        BeforeActions.scenario.write(" ******** Number of records transferred ********:" + countRecords);
+        boolean recordsMatched = CloudMySqlClient.validateRecordValues(PluginPropertyUtils.pluginProp("sourceTable"),
+                PluginPropertyUtils.pluginProp("targetTable"));
+        Assert.assertTrue("Value of records transferred to the target table should be equal to the value " +
+                "of the records in the source table", recordsMatched);
+    }
+}
+

cloudsql-mysql-plugin/src/e2e-test/java/io/cdap/plugin/CloudMySql/stepsdesign/CloudMysql.java

@@ -0,0 +1,21 @@
+/*
+ * Copyright © 2023 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+/**
+ * Package contains the stepDesign for CloudMysql features.
+ */
+
+package io.cdap.plugin.CloudMySql.stepsdesign;