Skip to content

Commit

Permalink
Feat[TE-15497]: Added SQL Server Queries Addon
Browse files Browse the repository at this point in the history
  • Loading branch information
@SivasaiPodugu
SivasaiPodugu committed Feb 7, 2024
1 parent 82cb0ba commit 1885b54
Show file tree
Hide file tree
Showing 45 changed files with 3,953 additions and 0 deletions.
110 changes: 110 additions & 0 deletions sql_server_queries/pom.xml
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,110 @@
<?xml version="1.0" encoding="UTF-8"?>
<project
xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.testsigma.addons</groupId>
<artifactId>sql_server_queries</artifactId>
<version>1.1.0</version>
<packaging>jar</packaging>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
<testsigma.sdk.version>1.2.5_cloud</testsigma.sdk.version>
<junit.jupiter.version>5.8.0-M1</junit.jupiter.version>
<testsigma.addon.maven.plugin>1.0.0</testsigma.addon.maven.plugin>
<maven.source.plugin.version>3.2.1</maven.source.plugin.version>
<lombok.version>1.18.20</lombok.version>

</properties>

<dependencies>
<dependency>
<groupId>com.testsigma</groupId>
<artifactId>testsigma-java-sdk</artifactId>
<version>${testsigma.sdk.version}</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter-api</artifactId>
<version>${junit.jupiter.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.testng</groupId>
<artifactId>testng</artifactId>
<version>6.14.3</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.seleniumhq.selenium/selenium-java -->
<dependency>
<groupId>org.seleniumhq.selenium</groupId>
<artifactId>selenium-java</artifactId>
<version>4.14.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.appium/java-client -->
<dependency>
<groupId>io.appium</groupId>
<artifactId>java-client</artifactId>
<version>9.0.0</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-annotations</artifactId>
<version>2.13.0</version>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.14.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.ibatis/ibatis-core -->
<dependency>
<groupId>org.apache.ibatis</groupId>
<artifactId>ibatis-core</artifactId>
<version>3.0</version>
</dependency>

</dependencies>
<build>
<finalName>sql_server_queries</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.2.4</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
<version>${maven.source.plugin.version}</version>
<executions>
<execution>
<id>attach-sources</id>
<goals>
<goal>jar</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
160 changes: 160 additions & 0 deletions ...server_queries/src/main/java/com/testsigma/addons/android/SqlValidateQueriesonTables.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,160 @@
package com.testsigma.addons.android;

import com.testsigma.addons.util.DatabaseUtil;
import com.testsigma.sdk.ApplicationType;
import com.testsigma.sdk.Result;
import com.testsigma.sdk.WebAction;
import com.testsigma.sdk.annotation.Action;
import com.testsigma.sdk.annotation.TestData;
import lombok.Data;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.openqa.selenium.NoSuchElementException;

import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetProvider;
import java.sql.*;
import java.util.Objects;

@Data
@Action(actionText = "Validate SQL Query Query1 and compare with the Query Query2 from the Connection DB_Connection_URL for Database Database-Name using Username user-name and Password password",
description = "This action validate queries on the database connections",
applicationType = ApplicationType.ANDROID)
public class SqlValidateQueriesonTables extends WebAction {

@TestData(reference = "Query1")
private com.testsigma.sdk.TestData testData1;
@TestData(reference = "Query2")
private com.testsigma.sdk.TestData testData2;
@TestData(reference = "DB_Connection_URL")
private com.testsigma.sdk.TestData testData3;
@TestData(reference = "user-name")
private com.testsigma.sdk.TestData userName;
@TestData(reference = "password")
private com.testsigma.sdk.TestData password;
@TestData(reference = "Database-Name")
private com.testsigma.sdk.TestData databaseName;
StringBuffer sb = new StringBuffer();

@Override
public Result execute() throws NoSuchElementException {
Result result = Result.SUCCESS;
logger.info("Initiating execution");
String url = String.format("jdbc:sqlserver://%s;databaseName=%s;user=%s;password=%s;encrypt=false;",testData3.getValue().toString(), databaseName.getValue().toString(), userName.getValue().toString(), password.getValue().toString());
DatabaseUtil databaseUtil = new DatabaseUtil();
try{

Connection connection1 = databaseUtil.getConnection(url);
Connection connection2 = databaseUtil.getConnection(url);

Statement stmt1 = connection1.createStatement();
Statement stmt2 = connection2.createStatement();

String query1 = testData1.getValue().toString();
String query2 = testData2.getValue().toString();

ResultSet resultSet1 = stmt1.executeQuery(query1);
ResultSet resultSet2 = stmt2.executeQuery(query2);

boolean metadataComparisonSuccess = compareMetadata(resultSet1,resultSet2);
if(!metadataComparisonSuccess) {
return Result.FAILED;
}
boolean dataComparisonSuccess = compareQueryData(resultSet1, resultSet2);
if(!dataComparisonSuccess) {
return Result.FAILED;
}
logger.info(sb.toString());
}catch (Exception e){
String errorMessage = ExceptionUtils.getStackTrace(e);
result = Result.FAILED;
setErrorMessage(errorMessage);
logger.warn(errorMessage);
}
setSuccessMessage("The two queries are have similar data");
logger.info("The two queries are have similar data");
logger.info(sb.toString());
return result;
}

private boolean compareMetadata(ResultSet resultSet1, ResultSet resultSet2) throws SQLException {

ResultSetMetaData rsmd1 = resultSet1.getMetaData();
ResultSetMetaData rsmd2 = resultSet2.getMetaData();

int columnNo1 = resultSet1.getMetaData().getColumnCount();
int columnNo2 = resultSet2.getMetaData().getColumnCount();

if(columnNo1 == columnNo2)
{
if(columnNo1 != 1)
{
for(int i=1;i<=columnNo1;i++) {
if (!rsmd1.getColumnName(i).equals(rsmd2.getColumnName(i))) {
sb.append("The ColumnNames does not match:<br>");
sb.append("Column name from Query-1:" +"'" +rsmd1.getColumnName(i) + "'" + "and Column name from Query-2:" + "'" +rsmd2.getColumnName(i) +"'");
setErrorMessage(sb.toString());
logger.warn(sb.toString());
return false;
}
}
}
return true;
}
sb.append("The Columns count does not match:<br>");
sb.append("Columns from Query-1:" + "'").append(columnNo1).append("'").append("and Columns from Query-2:").append("'").append(columnNo2).append("'");
setErrorMessage(sb.toString());
return false;
}
private boolean compareQueryData(ResultSet resultSet1, ResultSet resultSet2) throws SQLException {
int columnNo1 = resultSet1.getMetaData().getColumnCount();

CachedRowSet cachedResultSet1 = RowSetProvider.newFactory().createCachedRowSet();
CachedRowSet cachedResultSet2 = RowSetProvider.newFactory().createCachedRowSet();

cachedResultSet1.populate(resultSet1);
cachedResultSet2.populate(resultSet2);

while (cachedResultSet1.next() && cachedResultSet2.next()) {
for (int i = 1; i <= columnNo1; i++) {
if (!Objects.equals(cachedResultSet1.getObject(i), cachedResultSet2.getObject(i))) {
sb.append("The values do not match for column: Column Position(Starting from 1) ").append(i).append(" Row Number: ").append(cachedResultSet1.getRow());
sb.append("<br>");
sb.append("Value from Query-1: '").append(cachedResultSet1.getObject(i)).append("' and Value from Query-2: '").append(cachedResultSet2.getObject(i)).append("'");
setErrorMessage(sb.toString());
logger.warn(sb.toString());
return false;
}
}
}

// Log the contents of both queries when values match
StringBuilder successLog = new StringBuilder("Values match for all columns. Contents of both queries:\n");

cachedResultSet1.beforeFirst();
cachedResultSet2.beforeFirst();

// Log the contents of cachedResultSet1
successLog.append("Query-1:\n");
while (cachedResultSet1.next()) {
successLog.append(cachedResultSet1.getRow()).append(": ");
for (int i = 1; i <= columnNo1; i++) {
successLog.append(cachedResultSet1.getObject(i)).append("\n");
}
successLog.append("\n");
}

// Log the contents of cachedResultSet2
successLog.append("\nQuery-2:\n");
while (cachedResultSet2.next()) {
successLog.append(cachedResultSet2.getRow()).append(": ");
for (int i = 1; i <= columnNo1; i++) {
successLog.append(cachedResultSet2.getObject(i)).append("\n");
}
successLog.append("\n");
}

logger.info(successLog.toString());

return true;
}
}
Loading

0 comments on commit 1885b54

Please sign in to comment.