Add test for infinite loop replication

sqrl-tools/sqrl-cli/src/test/java/com/datasqrl/cmd/TestCmd.java

@@ -31,6 +31,7 @@ public class TestCmd {
 
   private static final Path OUTPUT_DIR = Paths.get("src", "test", "resources", "output");
   private static final Path SUBSCRIPTION_PATH = Paths.get("src/test/resources/subscriptions");
+  private static final Path CC_PATH = Paths.get("src/test/resources/creditcard");
 
   protected Path buildDir = null;
   SnapshotTest.Snapshot snapshot;
@@ -174,6 +175,14 @@ public void discoverRetail() {
     createSnapshot();
   }
 
+  // SQRL #479 - Infinite loop replication
+  @Test
+  public void testCreditCardInfiniteLoop() {
+    Path basePath = CC_PATH;
+    execute(basePath,
+        "compile", basePath.resolve("creditcard.sqrl").toString(), basePath.resolve("creditcard.graphqls").toString());
+  }
+
   public static int execute(Path rootDir, String... args) {
     return execute(rootDir, AssertStatusHook.INSTANCE, args);
   }

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard.graphqls

@@ -0,0 +1,8 @@
+type Query {
+  CustomerSpending(customerid: Int!, fromTime: String!, toTime: String!, limit: Int = 10, offset: Int = 0): [CustomerSpending!]
+}
+
+type CustomerSpending {
+  category: String!
+  spending: Float!
+}

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard.sqrl

@@ -0,0 +1,19 @@
+IMPORT creditcard.Merchant;
+IMPORT creditcard.Assignment AS CardAssignment;
+IMPORT creditcard.Transaction;
+IMPORT time.*;
+
+Merchant := DISTINCT Merchant ON merchantId ORDER BY updatedTime DESC;
+CardAssignment := DISTINCT CardAssignment ON cardNo ORDER BY timestamp DESC;
+
+CustomerSpendingByDay := SELECT customerid, endOfDay(time) as timeDay, category, SUM(amount) as spending
+                         FROM Transaction t
+                         JOIN CardAssignment c ON t.cardNo = c.cardNo
+                         JOIN Merchant m ON t.merchantId = m.merchantid
+                         GROUP BY customerid, timeDay, category;
+
+CustomerSpending(@customerid: BIGINT, @fromTime: TIMESTAMP, @toTime: TIMESTAMP) :=
+    SELECT category, SUM(spending) as spending
+    FROM CustomerSpendingByDay WHERE customerid = @customerid AND @fromTime <= timeDay AND @toTime > timeDay
+    GROUP BY category ORDER BY category ASC;
+

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/assignment.schema.yml

@@ -0,0 +1,17 @@
+---
+name: "assignment"
+schema_version: "1"
+partial_schema: false
+columns:
+- name: "customerId"
+  type: "BIGINT"
+  tests:
+  - "not_null"
+- name: "cardNo"
+  type: "STRING"
+  tests:
+  - "not_null"
+- name: "timestamp"
+  type: "TIMESTAMP"
+  tests:
+  - "not_null"

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/assignment.table.json

@@ -0,0 +1,13 @@
+{
+  "format" : {
+    "name" : "json"
+  },
+  "schema" : "flexible",
+  "identifier" : "assignment",
+  "type" : "source",
+  "connector" : {
+    "name" : "file",
+    "directoryURI" : "../../sqrl-examples/creditcard/data"
+  },
+  "canonicalizer" : "system"
+}

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/merchant.schema.yml

@@ -0,0 +1,21 @@
+---
+name: "merchant"
+schema_version: "1"
+partial_schema: false
+columns:
+- name: "merchantId"
+  type: "BIGINT"
+  tests:
+  - "not_null"
+- name: "name"
+  type: "STRING"
+  tests:
+  - "not_null"
+- name: "category"
+  type: "STRING"
+  tests:
+  - "not_null"
+- name: "updatedTime"
+  type: "TIMESTAMP"
+  tests:
+  - "not_null"

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/merchant.table.json

@@ -0,0 +1,13 @@
+{
+  "format" : {
+    "name" : "json"
+  },
+  "schema" : "flexible",
+  "identifier" : "merchant",
+  "type" : "source",
+  "connector" : {
+    "name" : "file",
+    "directoryURI" : "../../sqrl-examples/creditcard/data"
+  },
+  "canonicalizer" : "system"
+}

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/transaction.schema.yml

@@ -0,0 +1,25 @@
+---
+name: "transaction"
+schema_version: "1"
+partial_schema: false
+columns:
+- name: "transactionId"
+  type: "BIGINT"
+  tests:
+  - "not_null"
+- name: "cardNo"
+  type: "STRING"
+  tests:
+  - "not_null"
+- name: "time"
+  type: "TIMESTAMP"
+  tests:
+  - "not_null"
+- name: "amount"
+  type: "DOUBLE"
+  tests:
+  - "not_null"
+- name: "merchantId"
+  type: "BIGINT"
+  tests:
+  - "not_null"

sqrl-tools/sqrl-cli/src/test/resources/creditcard/creditcard/transaction.table.json

@@ -0,0 +1,13 @@
+{
+  "format" : {
+    "name" : "json"
+  },
+  "schema" : "flexible",
+  "identifier" : "transaction",
+  "type" : "source",
+  "connector" : {
+    "name" : "file",
+    "directoryURI" : "../../sqrl-examples/creditcard/data"
+  },
+  "canonicalizer" : "system"
+}