Skip to content
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

Feat[TE-15497]: Added SQL Server Queries Addon #44

Merged
merged 2 commits into from
Apr 2, 2024
Merged

Feat[TE-15497]: Added SQL Server Queries Addon #44

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1885b54
Feat[TE-15497]: Added SQL Server Queries Addon
SivasaiPodugu Feb 7, 2024
5a94451
fix: review changes
SivasaiPodugu Feb 16, 2024
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
134 changes: 134 additions & 0 deletions sql_server_queries/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,134 @@
<?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>2.0.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>
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssql-jdbc</artifactId>
<version>10.2.0.jre11</version>
</dependency>
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>msal4j</artifactId>
<version>1.11.2</version>
</dependency>
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>adal4j</artifactId>
<version>1.6.5</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>
<configuration>
<minimizeJar>true</minimizeJar>
<filters>
<filter>
<artifact>*:*</artifact>
<excludes>
<exclude>META-INF/*.SF</exclude>
<exclude>META-INF/*.DSA</exclude>
<exclude>META-INF/*.RSA</exclude>
</excludes>
</filter>
</filters>
</configuration>
</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
Open in desktop
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 = "SQLServer: 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
Loading