bq validation

Author: Ishakaushik-cloud

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

@@ -2,7 +2,6 @@
 
 import io.cdap.e2e.utils.PluginPropertyUtils;
 import org.junit.Assert;
-
 import java.sql.*;
 import java.util.Date;
 import java.util.GregorianCalendar;
@@ -108,8 +107,6 @@ public static void createSourceTable(String sourceTable) throws SQLException, Cl
       statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (1, 'Priya')");
       statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (2, 'Shubhangi')");
       statement.executeUpdate("INSERT INTO " + sourceTable + " (id, lastName)" + "VALUES (3, 'Shorya')");
-
-
     }
   }
 
@@ -128,8 +125,6 @@ public static void createSourceDatatypesTable(String sourceTable) throws SQLExce
       String datatypesColumns = PluginPropertyUtils.pluginProp("datatypesColumns");
       String createSourceTableQuery = "CREATE TABLE " + sourceTable + " " + datatypesColumns;
       statement.executeUpdate(createSourceTableQuery);
-      System.out.println(createSourceTableQuery);
-
       // Insert dummy data.
       String datatypesValues = PluginPropertyUtils.pluginProp("datatypesValue1");
       String datatypesColumnsList = PluginPropertyUtils.pluginProp("datatypesColumnsList");
@@ -142,7 +137,6 @@ public static void createTargetDatatypesTable(String targetTable) throws SQLExce
       String datatypesColumns = PluginPropertyUtils.pluginProp("datatypesColumns");
       String createTargetTableQuery = "CREATE TABLE " + targetTable + " " + datatypesColumns;
       statement.executeUpdate(createTargetTableQuery);
-      System.out.println(createTargetTableQuery);
     }
   }
 
@@ -151,11 +145,9 @@ public static void createTargetCloudMysqlTable(String targetTable) throws SQLExc
       String datatypesColumns = PluginPropertyUtils.pluginProp("CloudMySqlDatatypesColumns");
       String createTargetTableQuery = "CREATE TABLE " + targetTable + " " + datatypesColumns;
       statement.executeUpdate(createTargetTableQuery);
-      System.out.println(createTargetTableQuery);
     }
   }
 
-
   public static void dropTables(String[] tables) throws SQLException, ClassNotFoundException {
     try (Connection connect = getCloudSqlConnection(); Statement statement = connect.createStatement()) {
       for (String table : tables) {

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

@@ -31,8 +31,6 @@ public static void setTableName() {
     PluginPropertyUtils.addPluginProp("sourceTable", sourceTableName);
     PluginPropertyUtils.addPluginProp("targetTable", targetTableName);
     PluginPropertyUtils.addPluginProp("selectQuery", String.format("select * from %s", sourceTableName));
-    System.out.println(sourceTableName);
-
   }
 
   @Before(order = 1)
@@ -147,7 +145,6 @@ private static void createSourceBQTableWithQueries(String bqCreateTableQueryFile
       // Insert query does not return any record.
       // Iterator on TableResult values in getSoleQueryResult method throws NoSuchElementException
     }
-    System.out.println(bqSourceTable);
     PluginPropertyUtils.addPluginProp("bqSourceTable", bqSourceTable);
     BeforeActions.scenario.write("BQ Source Table " + bqSourceTable + " created successfully");
   }