Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use SqlUtils class of com.consol.citrus.util package

Best Citrus code snippet using com.consol.citrus.util.SqlUtils

Source:ExecuteSQLQueryBuilder.java

...17import com.consol.citrus.actions.ExecuteSQLQueryAction;18import com.consol.citrus.exceptions.CitrusRuntimeException;19import com.consol.citrus.script.ScriptTypes;20import com.consol.citrus.util.FileUtils;21import com.consol.citrus.util.SqlUtils;22import com.consol.citrus.validation.script.ScriptValidationContext;23import com.consol.citrus.validation.script.sql.SqlResultSetScriptValidator;24import org.springframework.core.io.Resource;25import org.springframework.jdbc.core.JdbcTemplate;26import org.springframework.transaction.PlatformTransactionManager;27import javax.sql.DataSource;28import java.io.IOException;29import java.nio.charset.Charset;30import java.util.Arrays;31import java.util.List;32/**33 * Action executes SQL queries and offers result set validation.34 *35 * The class enables you to query data result sets from a36 * database. Validation will happen on column basis inside the result set.37 * 38 * @author Christoph Deppisch39 * @since 2.340 */41public class ExecuteSQLQueryBuilder extends AbstractTestActionBuilder<ExecuteSQLQueryAction> {42    /**43     * Constructor using action field.44     * @param action45     */46	public ExecuteSQLQueryBuilder(ExecuteSQLQueryAction action) {47	    super(action);48    }49    /**50     * Default constructor.51     */52    public ExecuteSQLQueryBuilder() {53        super(new ExecuteSQLQueryAction());54    }55    /**56     * Sets the Spring JDBC template to use.57     * @param jdbcTemplate58     * @return59     */60    public ExecuteSQLQueryBuilder jdbcTemplate(JdbcTemplate jdbcTemplate) {61        action.setJdbcTemplate(jdbcTemplate);62        return this;63    }64    /**65     * Sets the transaction manager to use.66     * @param transactionManager67     * @return68     */69    public ExecuteSQLQueryBuilder transactionManager(PlatformTransactionManager transactionManager) {70        action.setTransactionManager(transactionManager);71        return this;72    }73    /**74     * Sets the transaction timeout to use.75     * @param transactionTimeout76     * @return77     */78    public ExecuteSQLQueryBuilder transactionTimeout(int transactionTimeout) {79        action.setTransactionTimeout(String.valueOf(transactionTimeout));80        return this;81    }82    /**83     * Sets the transaction timeout to use.84     * @param transactionTimeout85     * @return86     */87    public ExecuteSQLQueryBuilder transactionTimeout(String transactionTimeout) {88        action.setTransactionTimeout(transactionTimeout);89        return this;90    }91    /**92     * Sets the transaction isolation level to use.93     * @param isolationLevel94     * @return95     */96    public ExecuteSQLQueryBuilder transactionIsolationLevel(String isolationLevel) {97        action.setTransactionIsolationLevel(isolationLevel);98        return this;99    }100    /**101     * Sets the SQL data source.102     * @param dataSource103     * @return104     */105    public ExecuteSQLQueryBuilder dataSource(DataSource dataSource) {106        action.setDataSource(dataSource);107        return this;108    }109	/**110     * List of statements to execute. Declared inline in the test case. 111     * @param statements112     */113	public ExecuteSQLQueryBuilder statements(List<String> statements) {114		action.getStatements().addAll(statements);115		return this;116	}117	118	/**119	 * Adds a new statement to the list of SQL executions.120	 * @param statements121	 * @return122	 */123	public ExecuteSQLQueryBuilder statement(String statements) {124	    action.getStatements().add(statements);125		return this;126	}127	128	/**129     * Setter for external file resource containing the SQL statements to execute.130     * @param sqlResource131     */132	public ExecuteSQLQueryBuilder sqlResource(Resource sqlResource) {133        statements(SqlUtils.createStatementsFromFileResource(sqlResource));134		return this;135	}136	137	/**138     * Setter for external file resource containing the SQL statements to execute.139     * @param filePath140     */141    public ExecuteSQLQueryBuilder sqlResource(String filePath) {142        action.setSqlResourcePath(filePath);143        return this;144    }145	146	/**147     * Set expected control result set. Keys represent the column names, values...

Source:AbstractDatabaseConnectingTestAction.java

...16package com.consol.citrus.actions;17import com.consol.citrus.TestAction;18import com.consol.citrus.TestActor;19import com.consol.citrus.context.TestContext;20import com.consol.citrus.util.SqlUtils;21import org.slf4j.Logger;22import org.slf4j.LoggerFactory;23import org.springframework.core.io.support.PathMatchingResourcePatternResolver;24import org.springframework.jdbc.core.support.JdbcDaoSupport;25import org.springframework.transaction.PlatformTransactionManager;26import org.springframework.transaction.TransactionDefinition;27import java.util.ArrayList;28import java.util.List;29/**30 * Abstract base class for database connection test actions. Extends {@link JdbcDaoSupport} providing31 * access to a {@link javax.sql.DataSource}.32 * 33 * @author Christoph Deppisch34 */35public abstract class AbstractDatabaseConnectingTestAction extends JdbcDaoSupport implements TestAction {36    /**37     * Logger38     */39    protected final Logger log = LoggerFactory.getLogger(this.getClass());40    41    /** Text describing the test action */42    private String description;43    /** TestAction name injected as spring bean name */44    private String name = this.getClass().getSimpleName();45    46    /** SQL file resource path */47    protected String sqlResourcePath;48    49    /** List of SQL statements */50    protected List<String> statements = new ArrayList<>();51    52    /** This actions explicit test actor */53    private TestActor actor;54    /** Optional transaction manager */55    private PlatformTransactionManager transactionManager;56    private String transactionTimeout = String.valueOf(TransactionDefinition.TIMEOUT_DEFAULT);57    private String transactionIsolationLevel = "ISOLATION_DEFAULT";58    /**59     * Do basic logging and delegate execution to subclass.60     */61    public void execute(TestContext context) {62        doExecute(context);63    }64    65    /**66     * Subclasses may add custom execution logic here.67     */68    public abstract void doExecute(TestContext context);69    /**70     * Checks if this test action is disabled. Delegates to test actor defined71     * for this test action by default. Subclasses may add additional disabled logic here.72     * 73     * @param context the current test context.74     * @return75     */76    public boolean isDisabled(TestContext context) {77        if (actor != null) {78            return actor.isDisabled();79        } else {80            return false;81        }82    }83    /**84     * Reads SQL statements from external file resource. File resource can hold several85     * multi-line statements and comments.86     *87     * @param context the current test context.88     * @return list of SQL statements.89     */90    protected List<String> createStatementsFromFileResource(TestContext context) {91        return SqlUtils.createStatementsFromFileResource(new PathMatchingResourcePatternResolver()92                .getResource(context.replaceDynamicContentInString(sqlResourcePath)));93    }94    /**95     * Reads SQL statements from external file resource. File resource can hold several96     * multi-line statements and comments.97     *98     * @param context the current test context.99     * @return list of SQL statements.100     */101    protected List<String> createStatementsFromFileResource(TestContext context, SqlUtils.LastScriptLineDecorator lineDecorator) {102        return SqlUtils.createStatementsFromFileResource(new PathMatchingResourcePatternResolver()103                .getResource(context.replaceDynamicContentInString(sqlResourcePath)), lineDecorator);104    }105    106    /**107     * Gets this action's description.108     * @return the description109     */110    public String getDescription() {111        return description;112    }113    /**114     * Sets this test action's description.115     * @param description the description to set116     */...

Source:ExecutePLSQLAction.java

...15 */16package com.consol.citrus.actions;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.exceptions.CitrusRuntimeException;19import com.consol.citrus.util.SqlUtils;20import org.springframework.dao.DataAccessException;21import org.springframework.transaction.support.TransactionTemplate;22import org.springframework.util.StringUtils;23import java.util.*;24/**25 * Class executes PLSQL statements either declared inline as PLSQL statements or given by an26 * external file resource.27 *28 * @author Christoph Deppisch29 * @since 200830 */31public class ExecutePLSQLAction extends AbstractDatabaseConnectingTestAction {32    /** In line script */33    private String script = null;34    /** boolean flag marking that possible SQL errors will be ignored */35    private boolean ignoreErrors = false;36    /** Special statement endoing character sequence */37    public static final String PLSQL_STMT_ENDING = "/";38    /**39     * Default constructor.40     */41    public ExecutePLSQLAction() {42        setName("plsql");43    }44    @Override45    public void doExecute(TestContext context) {46        if (StringUtils.hasText(script)) {47            statements = createStatementsFromScript(context);48        } else if (StringUtils.hasText(sqlResourcePath)) {49            statements = createStatementsFromFileResource(context, new SqlUtils.LastScriptLineDecorator() {50                @Override51                public String getStatementEndingCharacter() {52                    return PLSQL_STMT_ENDING;53                }54                @Override55                public String decorate(String line) {56                    return line.trim().substring(0, (line.trim().length() - 1));57                }58            });59        }60        if (getTransactionManager() != null) {61            if (log.isDebugEnabled()) {62                log.debug("Using transaction manager: " + getTransactionManager().getClass().getName());63            }...

SqlUtils

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.util.SqlUtils;3import org.testng.annotations.Test;4import java.sql.Connection;5import java.sql.DriverManager;6import java.sql.ResultSet;7import java.sql.SQLException;8import java.sql.Statement;9public class SqlUtilsTest {10public void testSqlUtils() throws SQLException {11Connection connection = DriverManager.getConnection("jdbc:hsqldb:mem:mydb", "SA", "");12Statement statement = connection.createStatement();13statement.executeUpdate("CREATE TABLE test (id INTEGER, name VARCHAR(100))");14statement.executeUpdate("INSERT INTO test VALUES (1, 'Hello World')");15ResultSet resultSet = statement.executeQuery("SELECT * FROM test");16while (resultSet.next()) {17System.out.println(resultSet.getString("name"));18}19resultSet.close();20statement.close();21connection.close();22}23}

SqlUtils

Using AI Code Generation

1package com.consol.citrus.samples;2import java.util.Map;3import org.springframework.context.annotation.Bean;4import org.springframework.context.annotation.Configuration;5import org.springframework.context.annotation.Import;6import com.consol.citrus.dsl.CitrusTestDesigner;7import com.consol.citrus.dsl.builder.*;8import com.consol.citrus.dsl.design.*;9import com.consol.citrus.dsl.junit.*;10import com.consol.citrus.dsl.runner.*;11import com.consol.citrus.dsl.testng.*;12import com.consol.citrus.dsl.util.*;13import com.consol.citrus.dsl.variables.*;14import com.consol.citrus.dsl.xml.*;15import com.consol.citrus.sql.*;16import com.consol.citrus.util.*;17import com.consol.citrus.*;18import com.consol.citrus.annotations.*;19import com.consol.citrus.dsl.*;20import com.consol.citrus.dsl.endpoint.*;21import com.consol.citrus.dsl.endpoint.builder.*;22import com.consol.citrus.dsl.endpoint.CitrusEndpoints;23import com.consol.citrus.dsl.junit.JUnit4CitrusTest;24import com.consol.citrus.dsl.runner.TestRunner;25import com.consol.citrus.dsl.testng.TestNGCitrusTest;26import com.consol.citrus.http.client.*;27import com.consol.citrus.http.server.*;28import com.consol.citrus.jms.*;29import com.consol.citrus.message.*;30import com.consol.citrus.report.*;31import com.consol.citrus.report.MessageTracingReporter;32import com.consol.citrus.report.TestActionListeners;33import com.consol.citrus.report.TestListeners;34import com.consol.citrus.report.TestReporter;35import com.consol.citrus.report.TestReporters;36import com.consol.citrus.report.TestResultListeners;37import com.consol.citrus.reporter.*;38import com.consol.citrus.script.*;39import com.consol.citrus.server.*;40import com.consol.citrus.spi.ReferenceResolver;41import com.consol.citrus.spi.ReferenceResolverAware;42import com.consol.citrus.spi.ReferenceResolverAwareType;43import com.consol.citrus.spi.ReferenceResolverType;44import com.consol.citrus.spi.ReferenceResolverTypeAware;45import com.consol.citrus.spi.ReferenceResolverTypeAwareType;46import com.consol.citrus.spi.ReferenceResolverTypeAwareType;47import com.consol.citrus.spi.ReferenceResolverTypeAware

SqlUtils

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;4import com.consol.citrus.util.SqlUtils;5import org.springframework.core.io.ClassPathResource;6import org.testng.annotations.Test;7public class SqlUtilsTest extends TestNGCitrusTestDesigner {8    public void sqlUtilsTest() {9        variable("tableName", "test_table");10        variable("columnName", "test_column");11        variable("columnValue", "test_value");12        variable("columnType", "VARCHAR");13        variable("columnSize", "255");14        sql(builder -> builder15            .statement(SqlUtils.createTableStatement("${tableName}", "${columnName}", "${columnType}", "${columnSize}"))16            .statement(SqlUtils.insertIntoStatement("${tableName}", "${columnName}", "${columnValue}"))17            .statement(SqlUtils.selectFromStatement("${tableName}", "${columnName}", "${columnValue}"))18        );19        echo("Table ${tableName} created with column ${columnName} and value ${columnValue}");20        sql(builder -> builder21            .statement(SqlUtils.dropTableStatement("${tableName}"))22        );23        echo("Table ${tableName} dropped");24    }25}26package com.consol.citrus.samples;27import com.consol.citrus.annotations.CitrusTest;28import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;29import com.consol.citrus.util.SqlUtils;30import org.springframework.core.io.ClassPathResource;31import org.testng.annotations.Test;32public class SqlUtilsTest extends TestNGCitrusTestDesigner {33    public void sqlUtilsTest() {34        variable("tableName", "test_table");35        variable("columnName", "test_column");36        variable("columnValue", "test_value");37        variable("columnType", "VARCHAR");38        variable("columnSize", "255");39        sql(builder -> builder40            .statement(SqlUtils.createTableStatement("${tableName}", "${columnName}", "${columnType}", "${columnSize}"))41            .statement(SqlUtils.insertIntoStatement("${tableName}", "${columnName}", "${columnValue}"))42            .statement(SqlUtils.selectFromStatement("${tableName}", "${columnName}", "${column

SqlUtils

Using AI Code Generation

1public void testSqlUtils() throws Exception {2SqlUtils sqlUtils = new SqlUtils();3sqlUtils.queryForList("SELECT * FROM EMPLOYEE");4sqlUtils.queryForMap("SELECT * FROM EMPLOYEE WHERE EMP_ID = 1");5sqlUtils.queryForString("SELECT * FROM EMPLOYEE WHERE EMP_ID = 1");6sqlUtils.queryForObject("SELECT * FROM EMPLOYEE WHERE EMP_ID = 1",7String.class);8sqlUtils.queryForInt("SELECT * FROM EMPLOYEE WHERE EMP_ID = 1");9sqlUtils.queryForLong("SELECT * FROM EMPLOYEE WHERE EMP_ID = 1");10}11}12public void testSqlUtils() throws Exception {13SqlUtils sqlUtils = new SqlUtils();14sqlUtils.queryForList("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",15new Object[] { 1 });16sqlUtils.queryForMap("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",17new Object[] { 1 });18sqlUtils.queryForString("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",19new Object[] { 1 });20sqlUtils.queryForObject("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",21new Object[] { 1 }, String.class);22sqlUtils.queryForInt("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",23new Object[] { 1 });24sqlUtils.queryForLong("SELECT * FROM EMPLOYEE WHERE EMP_ID = ?",25new Object[] { 1 });26}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.