1 files changed, 105 insertions, 0 deletions
diff --git a/mdbc-server/src/test/java/org/onap/music/mdbc/query/QueryProcessorTest.java b/mdbc-server/src/test/java/org/onap/music/mdbc/query/QueryProcessorTest.java
new file mode 100644
index 0000000..63147e3
--- /dev/null
+++ b/mdbc-server/src/test/java/org/onap/music/mdbc/query/QueryProcessorTest.java
@@ -0,0 +1,105 @@
+/*
+ * ============LICENSE_START==================================================== org.onap.music.mdbc
+ * ============================================================================= Copyright (C) 2018 AT&T Intellectual
+ * Property. All rights reserved. ============================================================================= Licensed
+ * under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
+ * License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ * ============LICENSE_END======================================================
+ */
+
+package org.onap.music.mdbc.query;
+
+import static org.junit.Assert.*;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import org.apache.calcite.sql.parser.SqlParseException;
+import org.junit.Test;
+import org.onap.music.mdbc.tables.MusicTxDigest;
+import org.onap.music.mdbc.tables.StagingTable;
+
+
+public class QueryProcessorTest {
+
+    @Test
+    public void tableQuery() throws Exception {
+        String sqlQuery = "CREATE TABLE pet (name VARCHAR(20), owner VARCHAR(20))";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> op = new ArrayList<>();
+        // no table ops for now
+        // op.add(Operation.TABLE);
+        // expectedOut.put("pet", op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+    @Test
+    public void selectQuery() throws SqlParseException {
+        String sqlQuery = "SELECT name, age FROM table1 t1";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> t1op = new ArrayList<>();
+        t1op.add(Operation.SELECT);
+        expectedOut.put("TABLE1", t1op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+    @Test
+    public void selectQuery2Table() throws SqlParseException {
+        String sqlQuery = "SELECT name, age FROM table1 t1, table2 t2 WHERE t1.id = t2.id";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> t1op = new ArrayList<>();
+        List<Operation> t2op = new ArrayList<>();
+        t1op.add(Operation.SELECT);
+        t2op.add(Operation.SELECT);
+        expectedOut.put("TABLE1", t1op);
+        expectedOut.put("TABLE2", t2op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+
+        sqlQuery = "SELECT name, age FROM table1, table2 t2 WHERE id = t2.id";
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+    @Test
+    public void insertQuery() throws SqlParseException {
+        String sqlQuery = "INSERT INTO Employees (id, name) values ('1','Vikram')";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> t1op = new ArrayList<>();
+        t1op.add(Operation.INSERT);
+        expectedOut.put("EMPLOYEES", t1op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+    @Test
+    public void updateQuery() throws SqlParseException {
+        String sqlQuery = "UPDATE Employees SET id = 1 WHERE id = 2";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> t1op = new ArrayList<>();
+        t1op.add(Operation.UPDATE);
+        expectedOut.put("EMPLOYEES", t1op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+
+        sqlQuery = "UPDATE Employees SET id = 1";
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+    @Test
+    public void insertSelect() throws SqlParseException {
+        String sqlQuery =
+                "INSERT INTO table1 (CustomerName, City, Country) SELECT SupplierName, City, Country FROM table2";
+        HashMap<String, List<Operation>> expectedOut = new HashMap<>();
+        List<Operation> t1op = new ArrayList<>();
+        List<Operation> t2op = new ArrayList<>();
+        t1op.add(Operation.INSERT);
+        t2op.add(Operation.SELECT);
+        expectedOut.put("TABLE1", t1op);
+        expectedOut.put("TABLE2", t2op);
+        assertEquals(expectedOut, QueryProcessor.parseSqlQuery(sqlQuery));
+    }
+
+}