[Rel v0.2] Migrate Java SDK files (#46)

Author: gkastrinis

rai-sdk-examples/src/test/resources/hello.rel

@@ -1 +1 @@
-def R = "hello", "world"
+def R {("hello", "world")}

rai-sdk/src/main/java/com/relationalai/Client.java

@@ -973,16 +973,16 @@ static void genSchemaConfig(StringBuilder builder, CsvOptions options) {
         if (schema == null || schema.isEmpty())
             return;
         var count = 0;
-        builder.append("def config:schema =");
+        builder.append("def config[:schema]: {");
         for (var entry : schema.entrySet()) {
             if (count > 0)
                 builder.append(';');
             var k = entry.getKey();
             var v = entry.getValue();
-            builder.append(String.format("\n    :%s, \"%s\"", k, v));
+            builder.append(String.format("\n    (:%s, \"%s\")", k, v));
             count++;
         }
-        builder.append('\n');
+        builder.append("}\n");
     }
 
     // Returns a Rel literal for the given value.
@@ -1013,7 +1013,7 @@ static void genSyntaxOption(StringBuilder builder, String name, Object value) {
         if (value == null)
             return;
         var lit = genLiteral(value);
-        var def = String.format("def config:syntax:%s = %s\n", name, lit);
+        var def = String.format("def config[:syntax, :%s]: %s\n", name, lit);
         builder.append(def);
     }
 
@@ -1032,8 +1032,8 @@ static String genLoadCsv(String relation, CsvOptions options) {
         var builder = new StringBuilder();
         genSchemaConfig(builder, options);
         genSyntaxConfig(builder, options);
-        builder.append("def config:data = data\n");
-        builder.append(String.format("def insert:%s = load_csv[config]", relation));
+        builder.append("def config[:data]: data\n");
+        builder.append(String.format("def insert[:%s]: load_csv[config]", relation));
         return builder.toString();
     }
 
@@ -1071,8 +1071,8 @@ public TransactionResult loadCsv(
     // Generate the Rel to load JSON data into a relation.
     static String genLoadJson(String relation) {
         var builder = new StringBuilder();
-        builder.append("def config:data = data\n");
-        builder.append(String.format("def insert:%s = load_json[config]", relation));
+        builder.append("def config[:data]: data\n");
+        builder.append(String.format("def insert[:%s]: load_json[config]", relation));
         return builder.toString();
     }
 

rai-sdk/src/test/java/com/relationalai/DatabaseTest.java

@@ -107,7 +107,7 @@ void testDatabase() throws HttpError, InterruptedException, IOException {
     }
 
     static final String testModel =
-            "def R = \"hello\", \"world\"";
+            "def R {(\"hello\", \"world\")}";
 
     static final String testJson = "{" +
             "\"name\":\"Amira\",\n" +
@@ -159,7 +159,7 @@ void testDatabase() throws HttpError, InterruptedException, IOException {
         assertEquals(databaseCloneName, createRsp.name);
         assertEquals("CREATED", createRsp.state);
 
-        // Make sure the data was cloned 
+        // Make sure the data was cloned
         var rsp = client.executeV1(databaseCloneName, engineName, "test_data", true);
 
         Relation rel;

rai-sdk/src/test/java/com/relationalai/LoadCsvTest.java

@@ -49,7 +49,7 @@ public class LoadCsvTest extends UnitTest {
         assertEquals(0, loadRsp.output.length);
         assertEquals(0, loadRsp.problems.length);
 
-        var rsp = client.executeV1(databaseName, engineName, "def output = sample");
+        var rsp = client.executeV1(databaseName, engineName, "def output {sample}");
 
         Relation rel;
 
@@ -105,7 +105,7 @@ public class LoadCsvTest extends UnitTest {
         assertEquals(0, loadRsp.output.length);
         assertEquals(0, loadRsp.problems.length);
 
-        var rsp = client.executeV1(databaseName, engineName, "def output = sample_no_header");
+        var rsp = client.executeV1(databaseName, engineName, "def output {sample_no_header}");
 
         Relation rel;
 
@@ -162,7 +162,7 @@ public class LoadCsvTest extends UnitTest {
         assertEquals(0, loadRsp.output.length);
         assertEquals(0, loadRsp.problems.length);
 
-        var rsp = client.executeV1(databaseName, engineName, "def output = sample_alt_syntax");
+        var rsp = client.executeV1(databaseName, engineName, "def output {sample_alt_syntax}");
 
         Relation rel;
 
@@ -216,7 +216,7 @@ public class LoadCsvTest extends UnitTest {
         assertEquals(0, loadRsp.output.length);
         assertEquals(0, loadRsp.problems.length);
 
-        var rsp = client.executeV1(databaseName, engineName, "def output = sample");
+        var rsp = client.executeV1(databaseName, engineName, "def output {sample}");
 
         Relation rel;
 

rai-sdk/src/test/java/com/relationalai/LoadJsonTest.java

@@ -47,7 +47,7 @@ public class LoadJsonTest extends UnitTest {
         assertEquals(0, loadRsp.output.length);
         assertEquals(0, loadRsp.problems.length);
 
-        var rsp = client.executeV1(databaseName, engineName, "def output = sample");
+        var rsp = client.executeV1(databaseName, engineName, "def output {sample}");
 
         Relation rel;
 

rai-sdk/src/test/java/com/relationalai/ModelsTest.java

@@ -32,7 +32,7 @@
 @TestInstance(Lifecycle.PER_CLASS)
 @ExtendWith({TestExtension.class})
 public class ModelsTest extends UnitTest {
-    static final String testModel = "def R = \"hello\", \"world\"";
+    static final String testModel = "def R {(\"hello\", \"world\")}";
 
     @Test void testModels() throws HttpError, InterruptedException, IOException {
         var client = createClient();