[ignite-extensions] branch master updated: IGNITE-19901 Fixed AbstractReplicationTest to use test parameters in SQL queries (#221)

[mpetrov]

This is an automated email from the ASF dual-hosted git repository.

mpetrov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new d7f2d031 IGNITE-19901 Fixed AbstractReplicationTest to use test 
parameters in SQL queries (#221)
d7f2d031 is described below

commit d7f2d0313639431a6663eab34ca827a719db5309
Author: Ilya Shishkov <shishkovi...@gmail.com>
AuthorDate: Mon Jul 10 12:48:30 2023 +0300

    IGNITE-19901 Fixed AbstractReplicationTest to use test parameters in SQL 
queries (#221)
---
 .../org/apache/ignite/cdc/AbstractReplicationTest.java   | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
index fb9bd0b2..84ccd3c8 100644
--- 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
+++ 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
@@ -319,6 +319,8 @@ public abstract class AbstractReplicationTest extends 
GridCommonAbstractTest {
 
     /** */
     public void doTestActivePassiveSqlDataReplicationComplexKey(String name, 
BiConsumer<IgniteEx, Integer> addData) throws Exception {
+        String backupsStr = mode == PARTITIONED ? "BACKUPS=" + backups + "," : 
"";
+
         String createTbl = "CREATE TABLE IF NOT EXISTS " + name + "(" +
             "    ID INT NOT NULL, " +
             "    SUBID VARCHAR NOT NULL, " +
@@ -328,7 +330,9 @@ public abstract class AbstractReplicationTest extends 
GridCommonAbstractTest {
             "    WITH \"CACHE_NAME=" + name + "," +
             "KEY_TYPE=" + TestKey.class.getName() + "," +
             "VALUE_TYPE=" + TestVal.class.getName() + "," +
-            "ATOMICITY=" + atomicity.name() + "\";";
+            "ATOMICITY=" + atomicity.name() + "," +
+            backupsStr +
+            "TEMPLATE=" + mode.name() + "\";";
 
         executeSql(srcCluster[0], createTbl);
         executeSql(destCluster[0], createTbl);
@@ -372,7 +376,15 @@ public abstract class AbstractReplicationTest extends 
GridCommonAbstractTest {
     /** Active/Passive mode means changes made only in one cluster. */
     @Test
     public void testActivePassiveSqlDataReplication() throws Exception {
-        String createTbl = "CREATE TABLE T1(ID BIGINT PRIMARY KEY, NAME 
VARCHAR) WITH \"CACHE_NAME=T1,VALUE_TYPE=T1Type\"";
+        String backupsStr = mode == PARTITIONED ? "BACKUPS=" + backups + "," : 
"";
+
+        String createTbl = "CREATE TABLE T1(ID BIGINT PRIMARY KEY, NAME 
VARCHAR) WITH \"" +
+            "CACHE_NAME=T1," +
+            "VALUE_TYPE=T1Type," +
+            "ATOMICITY=" + atomicity.name() + "," +
+            backupsStr +
+            "TEMPLATE=" + mode.name() + "\";";
+
         String insertQry = "INSERT INTO T1 VALUES(?, ?)";
         String deleteQry = "DELETE FROM T1";