How to use getRow method of com.consol.citrus.dsl.runner.ExecuteSQLQueryTestRunnerTest class

Best Citrus code snippet using com.consol.citrus.dsl.runner.ExecuteSQLQueryTestRunnerTest.getRow

Source:ExecuteSQLQueryTestRunnerTest.java Github

copy

Full Screen

...75 76 Assert.assertEquals(action.getName(), "sql-query");77 Assert.assertEquals(action.getControlResultSet().size(), 2);78 Set<Map.Entry<String, List<String>>> rows = action.getControlResultSet().entrySet();79 Assert.assertEquals(getRow("NAME", rows).toString(), "NAME=[Leonard]");80 Assert.assertEquals(getRow("CNT_EPISODES", rows).toString(), "CNT_EPISODES=[100000]");81 Assert.assertEquals(action.getExtractVariables().size(), 1);82 Assert.assertEquals(action.getExtractVariables().entrySet().iterator().next().toString(), "NAME=actorName");83 Assert.assertNull(action.getScriptValidationContext());84 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);85 Assert.assertEquals(action.getStatements().size(), 2);86 Assert.assertNull(action.getSqlResourcePath());87 Assert.assertNull(action.getValidator());88 }89 90 @Test91 public void testExecuteSQLQueryWithStatements() {92 List<Map<String, Object>> results = new ArrayList<>();93 results.add(Collections.<String, Object>singletonMap("NAME", "Penny"));94 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));95 reset(jdbcTemplate);96 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);97 when(jdbcTemplate.queryForList("SELECT COUNT(*) as CNT_EPISODES FROM EPISODES")).thenReturn(Collections.singletonList(Collections.<String, Object>singletonMap("CNT_EPISODES", "9999")));98 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {99 @Override100 public void execute() {101 query(builder -> builder.jdbcTemplate(jdbcTemplate)102 .statement("SELECT NAME FROM ACTORS")103 .statement("SELECT COUNT(*) as CNT_EPISODES FROM EPISODES")104 .validate("NAME", "Penny", "Sheldon")105 .validate("CNT_EPISODES", "9999")106 .extract("CNT_EPISODES", "cntEpisodes"));107 }108 };109 TestContext context = builder.getTestContext();110 Assert.assertNotNull(context.getVariable("NAME"));111 Assert.assertNotNull(context.getVariable("CNT_EPISODES"));112 Assert.assertNotNull(context.getVariable("cntEpisodes"));113 Assert.assertEquals(context.getVariable("NAME"), "Penny");114 Assert.assertEquals(context.getVariable("CNT_EPISODES"), "9999");115 Assert.assertEquals(context.getVariable("cntEpisodes"), "9999");116 TestCase test = builder.getTestCase();117 Assert.assertEquals(test.getActionCount(), 1);118 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);119 120 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);121 122 Assert.assertEquals(action.getName(), "sql-query");123 Assert.assertEquals(action.getControlResultSet().size(), 2);124 Set<Map.Entry<String, List<String>>> rows = action.getControlResultSet().entrySet();125 Assert.assertEquals(getRow("NAME", rows).toString(), "NAME=[Penny, Sheldon]");126 Assert.assertEquals(getRow("CNT_EPISODES", rows).toString(), "CNT_EPISODES=[9999]");127 Assert.assertEquals(action.getExtractVariables().size(), 1);128 Assert.assertEquals(action.getExtractVariables().entrySet().iterator().next().toString(), "CNT_EPISODES=cntEpisodes");129 Assert.assertEquals(action.getStatements().size(), 2);130 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS, SELECT COUNT(*) as CNT_EPISODES FROM EPISODES]");131 Assert.assertNull(action.getScriptValidationContext());132 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);133 Assert.assertNull(action.getValidator());134 }135 @Test136 public void testExecuteSQLQueryWithTransaction() {137 List<Map<String, Object>> results = new ArrayList<>();138 results.add(Collections.<String, Object>singletonMap("NAME", "Penny"));139 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));140 reset(jdbcTemplate, transactionManager);141 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);142 when(jdbcTemplate.queryForList("SELECT COUNT(*) as CNT_EPISODES FROM EPISODES")).thenReturn(Collections.singletonList(Collections.<String, Object>singletonMap("CNT_EPISODES", "9999")));143 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {144 @Override145 public void execute() {146 query(builder -> builder.jdbcTemplate(jdbcTemplate)147 .transactionManager(transactionManager)148 .transactionTimeout(5000)149 .transactionIsolationLevel("ISOLATION_READ_COMMITTED")150 .statement("SELECT NAME FROM ACTORS")151 .statement("SELECT COUNT(*) as CNT_EPISODES FROM EPISODES")152 .validate("NAME", "Penny", "Sheldon")153 .validate("CNT_EPISODES", "9999")154 .extract("CNT_EPISODES", "cntEpisodes"));155 }156 };157 TestContext context = builder.getTestContext();158 Assert.assertNotNull(context.getVariable("NAME"));159 Assert.assertNotNull(context.getVariable("CNT_EPISODES"));160 Assert.assertNotNull(context.getVariable("cntEpisodes"));161 Assert.assertEquals(context.getVariable("NAME"), "Penny");162 Assert.assertEquals(context.getVariable("CNT_EPISODES"), "9999");163 Assert.assertEquals(context.getVariable("cntEpisodes"), "9999");164 TestCase test = builder.getTestCase();165 Assert.assertEquals(test.getActionCount(), 1);166 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);167 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);168 Assert.assertEquals(action.getName(), "sql-query");169 Assert.assertEquals(action.getControlResultSet().size(), 2);170 Set<Map.Entry<String, List<String>>> rows = action.getControlResultSet().entrySet();171 Assert.assertEquals(getRow("NAME", rows).toString(), "NAME=[Penny, Sheldon]");172 Assert.assertEquals(getRow("CNT_EPISODES", rows).toString(), "CNT_EPISODES=[9999]");173 Assert.assertEquals(action.getExtractVariables().size(), 1);174 Assert.assertEquals(action.getExtractVariables().entrySet().iterator().next().toString(), "CNT_EPISODES=cntEpisodes");175 Assert.assertEquals(action.getStatements().size(), 2);176 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS, SELECT COUNT(*) as CNT_EPISODES FROM EPISODES]");177 Assert.assertNull(action.getScriptValidationContext());178 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);179 Assert.assertEquals(action.getTransactionManager(), transactionManager);180 Assert.assertEquals(action.getTransactionTimeout(), "5000");181 Assert.assertEquals(action.getTransactionIsolationLevel(), "ISOLATION_READ_COMMITTED");182 Assert.assertNull(action.getValidator());183 }184 @Test185 public void testValidationScript() {186 List<Map<String, Object>> results = new ArrayList<>();187 results.add(Collections.<String, Object>singletonMap("NAME", "Penny"));188 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));189 reset(jdbcTemplate);190 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);191 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {192 @Override193 public void execute() {194 query(builder -> builder.jdbcTemplate(jdbcTemplate)195 .statement("SELECT NAME FROM ACTORS")196 .validateScript("assert rows[0].NAME == 'Penny'\n" +197 "assert rows[1].NAME == 'Sheldon'", ScriptTypes.GROOVY));198 }199 };200 TestCase test = builder.getTestCase();201 Assert.assertEquals(test.getActionCount(), 1);202 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);203 204 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);205 206 Assert.assertEquals(action.getName(), "sql-query");207 Assert.assertEquals(action.getControlResultSet().size(), 0);208 Assert.assertEquals(action.getExtractVariables().size(), 0);209 Assert.assertNotNull(action.getScriptValidationContext());210 Assert.assertTrue(action.getScriptValidationContext().getValidationScript().startsWith("assert rows[0].NAME == 'Penny'"));211 Assert.assertNull(action.getScriptValidationContext().getValidationScriptResourcePath());212 Assert.assertEquals(action.getStatements().size(), 1);213 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS]");214 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);215 }216 217 @Test218 public void testValidationScriptResource() throws IOException {219 List<Map<String, Object>> results = new ArrayList<>();220 results.add(Collections.<String, Object>singletonMap("NAME", "Radj"));221 reset(jdbcTemplate, resource);222 when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("assert rows[0].NAME == 'Radj'".getBytes()));223 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);224 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {225 @Override226 public void execute() {227 query(builder -> builder.jdbcTemplate(jdbcTemplate)228 .statement("SELECT NAME FROM ACTORS")229 .validateScript(resource, ScriptTypes.GROOVY));230 }231 };232 TestCase test = builder.getTestCase();233 Assert.assertEquals(test.getActionCount(), 1);234 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);235 236 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);237 238 Assert.assertEquals(action.getName(), "sql-query");239 Assert.assertEquals(action.getControlResultSet().size(), 0);240 Assert.assertEquals(action.getExtractVariables().size(), 0);241 Assert.assertNotNull(action.getScriptValidationContext());242 Assert.assertEquals(action.getScriptValidationContext().getValidationScript(), "assert rows[0].NAME == 'Radj'");243 Assert.assertNull(action.getScriptValidationContext().getValidationScriptResourcePath());244 Assert.assertEquals(action.getStatements().size(), 1);245 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS]");246 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);247 }248 249 @Test250 public void testGroovyValidationScript() {251 List<Map<String, Object>> results = new ArrayList<>();252 results.add(Collections.<String, Object>singletonMap("NAME", "Howard"));253 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));254 reset(jdbcTemplate);255 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);256 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {257 @Override258 public void execute() {259 query(builder -> builder.jdbcTemplate(jdbcTemplate)260 .statement("SELECT NAME FROM ACTORS")261 .groovy("assert rows[0].NAME == 'Howard'"));262 }263 };264 TestCase test = builder.getTestCase();265 Assert.assertEquals(test.getActionCount(), 1);266 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);267 268 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);269 270 Assert.assertEquals(action.getName(), "sql-query");271 Assert.assertEquals(action.getControlResultSet().size(), 0);272 Assert.assertEquals(action.getExtractVariables().size(), 0);273 Assert.assertNotNull(action.getScriptValidationContext());274 Assert.assertEquals(action.getScriptValidationContext().getValidationScript(), "assert rows[0].NAME == 'Howard'");275 Assert.assertNull(action.getScriptValidationContext().getValidationScriptResourcePath());276 Assert.assertEquals(action.getStatements().size(), 1);277 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS]");278 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);279 }280 281 @Test282 public void testGroovyValidationScriptResource() throws IOException {283 List<Map<String, Object>> results = new ArrayList<>();284 results.add(Collections.<String, Object>singletonMap("NAME", "Penny"));285 results.add(Collections.<String, Object>singletonMap("NAME", "Howard"));286 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));287 reset(jdbcTemplate, resource);288 when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("assert rows[1].NAME == 'Howard'".getBytes()));289 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);290 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {291 @Override292 public void execute() {293 query(builder -> builder.jdbcTemplate(jdbcTemplate)294 .statement("SELECT NAME FROM ACTORS")295 .groovy(resource));296 }297 };298 299 TestCase test = builder.getTestCase();300 Assert.assertEquals(test.getActionCount(), 1);301 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);302 303 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);304 305 Assert.assertEquals(action.getName(), "sql-query");306 Assert.assertEquals(action.getControlResultSet().size(), 0);307 Assert.assertEquals(action.getExtractVariables().size(), 0);308 Assert.assertNotNull(action.getScriptValidationContext());309 Assert.assertEquals(action.getScriptValidationContext().getValidationScript(), "assert rows[1].NAME == 'Howard'");310 Assert.assertNull(action.getScriptValidationContext().getValidationScriptResourcePath());311 Assert.assertEquals(action.getStatements().size(), 1);312 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS]");313 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);314 }315 @Test316 public void testCustomScriptValidator() {317 List<Map<String, Object>> results = new ArrayList<>();318 results.add(Collections.<String, Object>singletonMap("NAME", "Howard"));319 results.add(Collections.<String, Object>singletonMap("NAME", "Penny"));320 results.add(Collections.<String, Object>singletonMap("NAME", "Sheldon"));321 reset(jdbcTemplate, validator);322 when(jdbcTemplate.queryForList("SELECT NAME FROM ACTORS")).thenReturn(results);323 MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {324 @Override325 public void execute() {326 query(builder -> builder.jdbcTemplate(jdbcTemplate)327 .statement("SELECT NAME FROM ACTORS")328 .groovy("assert rows[0].NAME == 'Howard'")329 .validator(validator));330 }331 };332 TestCase test = builder.getTestCase();333 Assert.assertEquals(test.getActionCount(), 1);334 Assert.assertEquals(test.getActions().get(0).getClass(), ExecuteSQLQueryAction.class);335 ExecuteSQLQueryAction action = (ExecuteSQLQueryAction)test.getActions().get(0);336 Assert.assertEquals(action.getName(), "sql-query");337 Assert.assertEquals(action.getControlResultSet().size(), 0);338 Assert.assertEquals(action.getExtractVariables().size(), 0);339 Assert.assertNotNull(action.getScriptValidationContext());340 Assert.assertEquals(action.getScriptValidationContext().getValidationScript(), "assert rows[0].NAME == 'Howard'");341 Assert.assertNull(action.getScriptValidationContext().getValidationScriptResourcePath());342 Assert.assertEquals(action.getStatements().size(), 1);343 Assert.assertEquals(action.getStatements().toString(), "[SELECT NAME FROM ACTORS]");344 Assert.assertEquals(action.getJdbcTemplate(), jdbcTemplate);345 Assert.assertEquals(action.getValidator(), validator);346 verify(validator).validateSqlResultSet(any(List.class), any(ScriptValidationContext.class), any(TestContext.class));347 }348 /**349 * Gets row from result set with given column name.350 * @param columnName351 * @param rows352 * @return353 */354 private Map.Entry<String, List<String>> getRow(String columnName, Set<Map.Entry<String, List<String>>> rows) {355 for (Map.Entry<String, List<String>> row : rows) {356 if (row.getKey().equals(columnName)) {357 return row;358 }359 }360 throw new AssertionError(String.format("Missing column in result set for name '%s'", columnName));361 }362}...

Full Screen

Full Screen

getRow

Using AI Code Generation

copy

Full Screen

1 public void getRowWithQuery() {2 sql(new SqlActionBuilder()3 .query("SELECT * FROM books")4 .row(new SqlRowBuilder()5 .column("id", "1")6 .column("title", "Citrus Rocks!")7 .column("author", "Lukas Eder")));8 }9 public void getRowWithQuery() {10 sql(new SqlActionBuilder()11 .query("SELECT * FROM books")12 .row(new SqlRowBuilder()13 .column("id", "1")14 .column("title", "Citrus Rocks!")15 .column("author", "Lukas Eder")));16 }17 public void getRowWithQuery() {18 sql(new SqlActionBuilder()19 .query("SELECT * FROM books")20 .row(new SqlRowBuilder()21 .column("id", "1")22 .column("title", "Citrus Rocks!")23 .column("author", "Lukas Eder")));24 }25 public void getRowWithQuery() {26 sql(new SqlActionBuilder()27 .query("SELECT * FROM books")28 .row(new SqlRowBuilder()29 .column("id", "1")30 .column("title", "Citrus Rocks!")31 .column("author", "Lukas Eder")));32 }33 public void getRowWithQuery() {34 sql(new SqlActionBuilder()35 .query("SELECT * FROM books")36 .row(new SqlRowBuilder()37 .column("id", "1")38 .column("title", "Citrus Rocks!")39 .column("author", "Lukas Eder")));40 }41 public void getRowWithQuery() {42 sql(new SqlActionBuilder()43 .query("SELECT * FROM books")44 .row(new SqlRowBuilder()45 .column("id

Full Screen

Full Screen

getRow

Using AI Code Generation

copy

Full Screen

1 def "Test getRow"() {2 def runner = new ExecuteSQLQueryTestRunner()3 runner.dataSource(dataSource)4 runner.sqlQuery("select * from users")5 runner.validate("id", "1001")6 runner.validate("name", "John")7 runner.validate("age", "23")8 runner.validate("address", "London")9 runner.run()10 runner.sqlResult().size() == 111 }12}13 at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:132)14 at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:124)15 at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.injectDependencies(DependencyInjectionTestExecutionListener.java:117)16 at org.springframework.test.context.support.DependencyInjectionTestExecutionListener.prepareTestInstance(DependencyInjectionTestExecutionListener.java:83)17 at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:244)18 at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:227)19 at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:289)20 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)21 at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:291)22 at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:249)23 at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:89)24 at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)25 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)26 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)27 at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)28 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)29 at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)30 at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(R

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful