How to use success method of com.consol.citrus.jdbc.server.JdbcEndpointAdapterController class

Best Citrus code snippet using com.consol.citrus.jdbc.server.JdbcEndpointAdapterController.success

Source:JdbcEndpointAdapterControllerTest.java

...59    @Test60    public void testHandleMessageWhenEndpointAdapterReturnsNull(){61        //GIVEN62        final Message request = mock(Message.class);63        final Message expectedResponse = JdbcMessage.success();64        when(endpointAdapter.handleMessage(request)).thenReturn(null);65        //WHEN66        final Message response = jdbcEndpointAdapterController.handleMessage(request);67        //THEN68        assertEquals(response.getPayload(), expectedResponse.getPayload());69    }70    @Test71    public void testHandleMessageOperationPayloadConversion(){72        //GIVEN73        final Message request = mock(Message.class);74        final Operation payload = mock(Operation.class);75        when(request.getPayload()).thenReturn(payload);76        when(request.getPayload(Operation.class)).thenReturn(payload);77        final JdbcMarshaller jdbcMarshallerMock = mock(JdbcMarshaller.class);...

Source:JdbcEndpointAdapterController.java

...97                                        .map(Execute.Statement::getSql)98                                        .orElse("");99            if (autoHandleQueryPattern.matcher(sqlQuery).find()) {100                log.debug(String.format("Auto handle query '%s' with positive response", sqlQuery));101                JdbcMessage defaultResponse = JdbcMessage.success().rowsUpdated(0);102                defaultResponse.setHeader(MessageHeaders.MESSAGE_TYPE, MessageType.XML.name());103                return defaultResponse;104            }105        }106        return Optional.ofNullable(delegate.handleMessage(request))107                       .orElse(JdbcMessage.success());108    }109    /**110     * Opens the connection with the given properties111     * @param properties The properties to open the connection with112     * @throws JdbcServerException In case that the maximum connections have been reached113     */114    @Override115    public void openConnection(Map<String, String> properties) throws JdbcServerException {116        if (!endpointConfiguration.isAutoConnect()) {117            List<OpenConnection.Property> propertyList = convertToPropertyList(properties);118            handleMessageAndCheckResponse(JdbcMessage.openConnection(propertyList));119        }120        if (connections.get() == endpointConfiguration.getServerConfiguration().getMaxConnections()) {121            throw new JdbcServerException(String.format("Maximum number of connections (%s) reached",122                    endpointConfiguration.getServerConfiguration().getMaxConnections()));123        }124        connections.incrementAndGet();125    }126    /**127     * Closes the connection128     * @throws JdbcServerException In case that the connection could not be closed129     */130    @Override131    public void closeConnection() throws JdbcServerException {132        if (!endpointConfiguration.isAutoConnect()) {133            handleMessageAndCheckResponse(JdbcMessage.closeConnection());134        }135        if (connections.decrementAndGet() < 0) {136            connections.set(0);137        }138    }139    /**140     * Creates a prepared statement141     * @param stmt The statement to create142     * @throws JdbcServerException In case that the statement was not successful143     */144    @Override145    public void createPreparedStatement(String stmt) throws JdbcServerException {146        if (!endpointConfiguration.isAutoCreateStatement()) {147            handleMessageAndCheckResponse(JdbcMessage.createPreparedStatement(stmt));148        }149    }150    /**151     * Creates a statement152     * @throws JdbcServerException In case that the statement was not successfully created153     */154    @Override155    public void createStatement() throws JdbcServerException {156        if (!endpointConfiguration.isAutoCreateStatement()) {157            handleMessageAndCheckResponse(JdbcMessage.createStatement());158        }159    }160    /**161     * Executes a given query and returns the mapped result162     * @param query The query to execute163     * @return The DataSet containing the query result164     * @throws JdbcServerException In case that the query was not successful165     */166    @Override167    public DataSet executeQuery(String query) throws JdbcServerException {168        log.info("Received execute query request: " + query);169        Message response = handleMessageAndCheckResponse(JdbcMessage.execute(query));170        return dataSetCreator.createDataSet(response, getMessageType(response));171    }172    /**173     * Executes the given statement174     * @param stmt The statement to be executed175     * @throws JdbcServerException In case that the execution was not successful176     */177    @Override178    public DataSet executeStatement(String stmt) throws JdbcServerException {179        log.info("Received execute statement request: " + stmt);180        Message response = handleMessageAndCheckResponse(JdbcMessage.execute(stmt));181        return dataSetCreator.createDataSet(response, getMessageType(response));182    }183    /**184     * Executes the given update185     * @param updateSql The update statement to be executed186     * @throws JdbcServerException In case that the execution was not successful187     */188    @Override189    public int executeUpdate(String updateSql) throws JdbcServerException {190        log.info("Received execute update request: " + updateSql);191        Message response = handleMessageAndCheckResponse(JdbcMessage.execute(updateSql));192        return Optional.ofNullable(193                response.getHeader(JdbcMessageHeaders.JDBC_ROWS_UPDATED))194                .map(Object::toString).map(Integer::valueOf)195                .orElse(0);196    }197    /**198     * Closes the connection199     * @throws JdbcServerException In case that the connection could not be closed200     */201    @Override202    public void closeStatement() throws JdbcServerException {203        if (!endpointConfiguration.isAutoCreateStatement()) {204            handleMessageAndCheckResponse(JdbcMessage.closeStatement());205        }206    }207    /**208     * Sets the transaction state of the database connection209     * @param transactionState The boolean value whether the server is in transaction state.210     */211    @Override212    public void setTransactionState(boolean transactionState) {213        if (log.isDebugEnabled()) {214            log.debug(String.format("Received transaction state change: '%s':%n%s",215                    endpointConfiguration.getServerConfiguration().getDatabaseName(),216                    String.valueOf(transactionState)));217        }218        this.transactionState = transactionState;219        if(!endpointConfiguration.isAutoTransactionHandling() && transactionState){220            handleMessageAndCheckResponse(JdbcMessage.startTransaction());221        }222    }223    /**224     * Returns the transaction state225     * @return The transaction state of the connection226     */227    @Override228    public boolean getTransactionState() {229        return this.transactionState;230    }231    /**232     * Commits the transaction statements233     */234    @Override235    public void commitStatements() {236        if (log.isDebugEnabled()) {237            log.debug(String.format("Received transaction commit: '%s':%n",238                    endpointConfiguration.getServerConfiguration().getDatabaseName()));239        }240        if(!endpointConfiguration.isAutoTransactionHandling()){241            handleMessageAndCheckResponse(JdbcMessage.commitTransaction());242        }243    }244    /**245     * Performs a rollback on the current transaction246     */247    @Override248    public void rollbackStatements() {249        if (log.isDebugEnabled()) {250            log.debug(String.format("Received transaction rollback: '%s':%n",251                    endpointConfiguration.getServerConfiguration().getDatabaseName()));252        }253        if(!endpointConfiguration.isAutoTransactionHandling()){254            handleMessageAndCheckResponse(JdbcMessage.rollbackTransaction());255        }256    }257    /**258     * Creates a callable statement259     */260    @Override261    public void createCallableStatement(String sql) {262        if (!endpointConfiguration.isAutoCreateStatement()) {263            handleMessageAndCheckResponse(JdbcMessage.createCallableStatement(sql));264        }265    }266    /**267     * Determines the MessageType of the given response268     * @param response The response to get the message type from269     * @return The MessageType of the response270     */271    private MessageType getMessageType(Message response) {272        String messageTypeString = (String) response.getHeader(MessageHeaders.MESSAGE_TYPE);273        if (MessageType.knows(messageTypeString)){274            return MessageType.valueOf(messageTypeString.toUpperCase());275        }276        return null;277    }278    /**279     * Converts a property map propertyKey -> propertyValue to a list of OpenConnection.Properties280     * @param properties The map to convert281     * @return A list of Properties282     */283    private List<OpenConnection.Property> convertToPropertyList(Map<String, String> properties) {284        return properties.entrySet()285                .stream()286                .map(this::convertToProperty)287                .sorted(Comparator.comparingInt(OpenConnection.Property::hashCode))288                .collect(Collectors.toList());289    }290    /**291     * Converts a Map entry into a OpenConnection.Property292     * @param entry The entry to convert293     * @return the OpenConnection.Property representation294     */295    private OpenConnection.Property convertToProperty(Map.Entry<String, String> entry) {296        OpenConnection.Property property = new OpenConnection.Property();297        property.setName(entry.getKey());298        property.setValue(entry.getValue());299        return property;300    }301    /**302     * Handle request message and check response is successful.303     * @param request The request message to handle304     * @return The response Message305     * @throws JdbcServerException Thrown when the response has some exception header.306     */307    private Message handleMessageAndCheckResponse(Message request) throws JdbcServerException {308        Message response = handleMessage(request);309        checkSuccess(response);310        return response;311    }312    /**313     * Check that response is not having an exception message.314     * @param response The response message to check315     * @throws JdbcServerException In case the message contains a error.316     */317    private void checkSuccess(Message response) throws JdbcServerException {318        OperationResult operationResult = null;319        if (response instanceof JdbcMessage || response.getPayload() instanceof OperationResult) {320            operationResult = response.getPayload(OperationResult.class);321        } else if (response.getPayload() != null && StringUtils.hasText(response.getPayload(String.class))) {322            operationResult = (OperationResult) endpointConfiguration.getMarshaller().unmarshal(new StringSource(response.getPayload(String.class)));323        }324        if (!success(response, operationResult)) {325            throw new JdbcServerException(getExceptionMessage(response, operationResult));326        }327    }328    private String getExceptionMessage(Message response, OperationResult operationResult) {329        return Optional.ofNullable(response.getHeader(JdbcMessageHeaders.JDBC_SERVER_EXCEPTION))330                        .map(Object::toString)331                        .orElse(Optional.ofNullable(operationResult).map(OperationResult::getException).orElse(""));332    }333    private boolean success(Message response, OperationResult result) {334        return Optional.ofNullable(response.getHeader(JdbcMessageHeaders.JDBC_SERVER_SUCCESS))335                .map(Object::toString)336                .map(Boolean::valueOf)337                .orElse(Optional.ofNullable(result).map(OperationResult::isSuccess).orElse(true));338    }339    @Override340    public Endpoint getEndpoint() {341        return delegate.getEndpoint();342    }343    @Override344    public EndpointConfiguration getEndpointConfiguration() {345        return delegate.getEndpointConfiguration();346    }347    AtomicInteger getConnections() {...

success

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;4import org.springframework.beans.factory.annotation.Autowired;5import org.springframework.beans.factory.annotation.Qualifier;6import org.springframework.jdbc.core.JdbcTemplate;7import org.springframework.jdbc.core.RowMapper;8import org.testng.annotations.Test;9import javax.sql.DataSource;10import java.sql.ResultSet;11import java.sql.SQLException;12import java.util.List;13import static org.testng.Assert.assertEquals;14public class JdbcServerIT extends TestNGCitrusTestRunner {15    @Qualifier("testDataSource")16    private DataSource dataSource;17    public void testJdbcServer() {18        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);19        jdbcTemplate.update("INSERT INTO CUSTOMER (ID, NAME) VALUES (?,?)", 1, "John Doe");20        List<String> names = jdbcTemplate.query("SELECT NAME FROM CUSTOMER", new RowMapper<String>() {21            public String mapRow(ResultSet resultSet, int i) throws SQLException {22                return resultSet.getString("NAME");23            }24        });25        assertEquals(names.size(), 1L);26        assertEquals(names.get(0), "John Doe");27    }28}29package com.consol.citrus.samples;30import com.consol.citrus.annotations.CitrusTest;31import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;32import org.springframework.beans.factory.annotation.Autowired;33import org.springframework.beans.factory.annotation.Qualifier;34import org.springframework.jdbc.core.JdbcTemplate;35import org.springframework.jdbc.core.RowMapper;36import org.testng.annotations.Test;37import javax.sql.DataSource;38import java.sql.ResultSet;39import java.sql.SQLException;40import java.util.List;41import static org.testng.Assert.assertEquals;42public class JdbcServerIT extends TestNGCitrusTestRunner {43    @Qualifier("testDataSource")44    private DataSource dataSource;45    public void testJdbcServer() {46        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);47        jdbcTemplate.update("INSERT INTO CUSTOMER (ID, NAME

success

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;4import com.consol.citrus.dsl.runner.TestRunner;5import com.consol.citrus.dsl.runner.TestRunnerBeforeTestSupport;6import com.consol.citrus.message.MessageType;7import org.junit.Test;8import org.springframework.http.HttpStatus;9import org.springframework.http.MediaType;10import org.springframework.test.context.ContextConfiguration;11import static com.consol.citrus.actions.EchoAction.Builder.echo;12@ContextConfiguration(classes = {CitrusSpringConfig.class})13public class JdbcEndpointAdapterControllerIT extends JUnit4CitrusTestDesigner {14    public void testJdbcEndpointAdapterController() {15        variable("id", "1");16        variable("name", "John Doe");17        variable("age", "25");18        echo("JdbcEndpointAdapterControllerIT: testJdbcEndpointAdapterController");19        http(httpActionBuilder -> httpActionBuilder20                .client("httpClient")21                .send()22                .post("/jdbc")23                .contentType(MediaType.APPLICATION_JSON_VALUE)24                .payload("{\"id\":\"${id}\", \"name\":\"${name}\", \"age\":\"${age}\"}"));25        http(httpActionBuilder -> httpActionBuilder26                .client("httpClient")27                .receive()28                .response(HttpStatus.OK)29                .messageType(MessageType.PLAINTEXT)30                .payload("OK"));31        http(httpActionBuilder -> httpActionBuilder32                .client("httpClient")33                .send()34                .get("/jdbc")35                .contentType(MediaType.APPLICATION_JSON_VALUE));36        http(httpActionBuilder -> httpActionBuilder37                .client("httpClient")38                .receive()39                .response(HttpStatus.OK)40                .messageType(MessageType.PLAINTEXT)41                .payload("{\"id\":\"${id}\", \"name\":\"${name}\", \"age\":\"${age}\"}"));42    }43}44package com.consol.citrus.samples;45import com.consol.citrus.annotations.CitrusTest;46import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;47import com.consol.citrus.dsl.runner.TestRunner;48import com.consol.citrus.dsl.runner.TestRunnerBefore

success

Using AI Code Generation

1package com.consol.citrus;2import java.util.HashMap;3import java.util.Map;4import javax.sql.DataSource;5import org.springframework.context.annotation.Bean;6import org.springframework.context.annotation.Configuration;7import org.springframework.jdbc.datasource.DriverManagerDataSource;8import com.consol.citrus.dsl.endpoint.CitrusEndpoints;9import com.consol.citrus.jdbc.endpoint.JdbcEndpoint;10import com.consol.citrus.jdbc.message.JdbcMessageConverter;11public class JdbcEndpointConfig {12	public JdbcEndpoint jdbcEndpoint() {13		return CitrusEndpoints.jdbc()14				.endpointAdapter(jdbcEndpointAdapter())15				.build();16	}17	public JdbcEndpointAdapterController jdbcEndpointAdapter() {18		return new JdbcEndpointAdapterController();19	}20	public DataSource dataSource() {21		DriverManagerDataSource dataSource = new DriverManagerDataSource();22		dataSource.setDriverClassName("org.hsqldb.jdbc.JDBCDriver");23		dataSource.setUrl("jdbc:hsqldb:mem:mydb");24		dataSource.setUsername("sa");25		dataSource.setPassword("");26		return dataSource;27	}28	public JdbcMessageConverter jdbcMessageConverter() {29		return new JdbcMessageConverter();30	}31}32package com.consol.citrus;33import java.util.Map;34import org.springframework.beans.factory.annotation.Autowired;35import org.springframework.jdbc.core.JdbcTemplate;36import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;37import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;38import org.springframework.jdbc.core.simple.SimpleJdbcCall;39import com.consol.citrus.context.TestContext;40import com.consol.citrus.endpoint.adapter.StaticEndpointUriResolver;41import com.consol.citrus.exceptions.CitrusRuntimeException;42import com.consol.citrus.jdbc.message.JdbcMessage;43import com.consol.citrus.message.Message;44import com.consol.citrus.server.AbstractServer;45public class JdbcEndpointAdapterController extends AbstractServer {46	private JdbcTemplate jdbcTemplate;47	private NamedParameterJdbcTemplate namedParameterJdbcTemplate;48	private SimpleJdbcCall simpleJdbcCall;49	public void start() {50	}51	public void stop() {

success

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestRunner;4import com.consol.citrus.jdbc.server.JdbcEndpointAdapterController;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.CitrusParameters;7import org.testng.annotations.Test;8public class JdbcSampleIT extends JUnit4CitrusTestRunner {9    @CitrusParameters({"jdbcEndpointAdapterController"})10    public void testJdbcSample(JdbcEndpointAdapterController jdbcEndpointAdapterController) {11        description("JDBC sample with Citrus");12        variable("id", "citrus:randomNumber(10)");13        variable("name", "citrus:concat('Citrus:', citrus:randomNumber(4))");14        echo("Execute JDBC SQL update statement");15        jdbc(jdbcEndpointAdapterController)16                .statement("INSERT INTO PERSON (ID, NAME) VALUES (${id}, '${name}')")17                .validate("UPDATECOUNT", "1");18        echo("Execute JDBC SQL query statement");19        jdbc(jdbcEndpointAdapterController)20                .statement("SELECT ID, NAME FROM PERSON WHERE ID = ${id}")21                .validate("ID", "${id}")22                .validate("NAME", "${name}");23        echo("Execute JDBC SQL query statement with validation script");24        jdbc(jdbcEndpointAdapterController)25                .statement("SELECT ID, NAME FROM PERSON WHERE ID = ${id}")26                .validateScript("classpath:com/consol/citrus/samples/validatePerson.js");27        echo("Execute JDBC SQL query statement with validation script file resource");28        jdbc(jdbcEndpointAdapterController)29                .statement("SELECT ID, NAME FROM PERSON WHERE ID = ${id}")30                .validateScript("file:src/test/resources/com/consol/citrus/samples/validatePerson.js");31        echo("Execute JDBC SQL query statement with validation script file resource and parameters");32        jdbc(jdbcEndpointAdapterController)33                .statement("SELECT ID, NAME FROM PERSON WHERE ID = ${id}")34                .validateScript("file:src/test/resources/com/consol/citrus/samples/validatePerson.js", "citrus:concat('Citrus:', citrus:randomNumber(4))");35        echo("Execute JDBC SQL query statement with validation script file resource and parameters and

success

Using AI Code Generation

1package com.consol.citrus.jdbc.server;2import java.util.HashMap;3import java.util.Map;4import org.testng.annotations.Test;5import com.consol.citrus.annotations.CitrusTest;6import com.consol.citrus.testng.CitrusParameters;7public class JdbcEndpointAdapterControllerTest {8    @CitrusParameters("testName")9    public void testSuccess() {10        JdbcEndpointAdapterController controller = new JdbcEndpointAdapterController();11        controller.setEndpointName("jdbcEndpoint");12        Map<String, Object> headers = new HashMap<String, Object>();13        headers.put("test", "test");14        controller.success(headers);15    }16}17package com.consol.citrus.jdbc.server;18import java.util.HashMap;19import java.util.Map;20import org.testng.annotations.Test;21import com.consol.citrus.annotations.CitrusTest;22import com.consol.citrus.testng.CitrusParameters;23public class JdbcEndpointAdapterControllerTest {24    @CitrusParameters("testName")25    public void testSuccess() {26        JdbcEndpointAdapterController controller = new JdbcEndpointAdapterController();27        controller.setEndpointName("jdbcEndpoint");28        Map<String, Object> headers = new HashMap<String, Object>();29        headers.put("test", "test");30        controller.success(headers);31    }32}33package com.consol.citrus.jdbc.server;34import java.util.HashMap;35import java.util.Map;36import org.testng.annotations.Test;37import com.consol.citrus.annotations.CitrusTest;38import com.consol.citrus.testng.CitrusParameters;39public class JdbcEndpointAdapterControllerTest {40    @CitrusParameters("testName")41    public void testSuccess() {42        JdbcEndpointAdapterController controller = new JdbcEndpointAdapterController();43        controller.setEndpointName("jdbcEndpoint");44        Map<String, Object> headers = new HashMap<String, Object>();45        headers.put("test", "test");46        controller.success(headers);47    }48}

success

Using AI Code Generation

1package com.consol.citrus;2import org.springframework.context.ApplicationContext;3import org.springframework.context.support.ClassPathXmlApplicationContext;4public class Citrus {5public static void main(String[] args) {6ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");7System.out.println("hello");8}9}

success

Using AI Code Generation

1package test;2import org.springframework.context.support.ClassPathXmlApplicationContext;3public class JdbcEndpointAdapterControllerTest {4	public static void main(String[] args) {5		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");6		JdbcEndpointAdapterController controller = context.getBean(JdbcEndpointAdapterController.class);7		controller.success();8		context.close();9	}10}

success

Using AI Code Generation

1package com.consol.citrus.samples.jdbc;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestRunner;4import com.consol.citrus.jdbc.message.JdbcMessage;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.CitrusParameters;7import org.springframework.beans.factory.annotation.Autowired;8import org.springframework.jdbc.core.JdbcTemplate;9import org.springframework.jdbc.datasource.SingleConnectionDataSource;10import org.testng.annotations.Test;11import javax.sql.DataSource;12import java.sql.SQLException;13import java.util.List;14public class JdbcServerIT extends JUnit4CitrusTestRunner {15    private DataSource dataSource;16    @CitrusParameters({"query1", "query2"})17    public void testJdbcServer(String query1, String query2) {18        variable("query1", query1);19        variable("query2", query2);20        echo("JdbcServerIT: testJdbcServer: query1 = ${query1}");21        echo("JdbcServerIT: testJdbcServer: query2 = ${query2}");22        echo("JdbcServerIT: testJdbcServer: inserting data into table");23        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);24        jdbcTemplate.execute("insert into books (id, title, author) values (1, 'The Hitchhiker''s Guide to the Galaxy', 'Douglas Adams')");25        jdbcTemplate.execute("insert into books (id, title, author) values (2, 'The Restaurant at the End of the Universe', 'Douglas Adams')");26        jdbcTemplate.execute("insert into books (id, title, author) values (3, 'Life, the Universe and Everything', 'Douglas Adams')");27        jdbcTemplate.execute("insert into books (id, title, author) values (4, 'So Long, and Thanks for All the Fish', 'Douglas Adams')");28        jdbcTemplate.execute("insert into books (id, title, author) values (5, 'Mostly Harmless', 'Douglas Adams')");29        jdbcTemplate.execute("insert into books (id, title, author) values (6, 'And Another Thing...', 'Douglas Adams')");30        jdbcTemplate.execute("insert into books (id, title, author) values (7, 'The Hitchhiker''s Guide to

success

Using AI Code Generation

1public class 3 extends TestNGCitrusTestDesigner {2    public void jdbcTest() {3        variable("id", "1001");4        variable("firstName", "John");5        variable("lastName", "Doe");6        variable("email", "

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.