Working on execution part, main structure completed.

Author: pwwpche

Query/Engine/QueryExecution.java

@@ -2,10 +2,15 @@
 
 import Query.Entities.PlanTree;
 import Query.Execution.AllNodeScanExec;
+import Query.Execution.Execution;
 import Query.Execution.ResultTable;
-import Query.Plan.AllNodeScanPlan;
+import Query.Plan.*;
 import Utility.DBUtil;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Stack;
+
 /**
  * Created by liuche on 5/28/17.
  *
@@ -18,14 +23,61 @@ public class QueryExecution {
         this.dbUtil = util;
     }
 
-
     public void setTree(PlanTree tree){
          this.tree = tree;
     }
 
-    public ResultTable execute(AllNodeScanPlan plan){
-        AllNodeScanExec allNodeScanExec = new AllNodeScanExec(dbUtil, plan);
-        return allNodeScanExec.execute();
+    public ResultTable execute(){
+        List<Execution> executionList = new ArrayList<>();
+        for(Plan plan : tree.toList()){
+            if(plan instanceof AllNodeScanPlan){
+
+            }else if(plan instanceof ScanByLabelPlan){
+
+            }else if(plan instanceof ScanByPropertyPlan){
+
+            }else if(plan instanceof ScanByIdPlan){
+
+            }else if(plan instanceof ExpandIntoPlan){
+
+            }else if(plan instanceof ExpandAllPlan){
+
+            }else if(plan instanceof RangeExpandAllPlan){
+
+            }else if(plan instanceof RangeExpandIntoPlan){
+
+            }else if(plan instanceof NodeHashJoinPlan){
+
+            }else if(plan instanceof CartesianProductPlan){
+
+            }
+        }
+
+        Stack<ResultTable> resStack = new Stack<>();
+        for(Execution execution : executionList){
+            switch (execution.operandCount()){
+                case 0:
+                    resStack.push(execution.execute());
+                    break;
+                case 1:
+                    ResultTable table = resStack.peek();
+                    resStack.pop();
+                    resStack.push(execution.execute(table));
+                    break;
+                case 2:
+                    ResultTable table1 = resStack.peek();
+                    resStack.pop();
+                    ResultTable table2 = resStack.peek();
+                    resStack.pop();
+                    resStack.push(execution.execute(table1, table2));
+                    break;
+                default:
+                    break;
+            }
+        }
+        assert resStack.size() == 1;
+        return resStack.peek();
+
     }
 
 

Query/Execution/AllNodeScanExec.java

@@ -1,7 +1,6 @@
 package Query.Execution;
 
 import Query.Plan.AllNodeScanPlan;
-import Query.Plan.Plan;
 import Utility.DBUtil;
 
 /**
@@ -11,6 +10,17 @@ public class AllNodeScanExec extends Execution{
 
     public AllNodeScanExec(DBUtil util, AllNodeScanPlan plan) {
         super(util, plan);
+        this.isLeaf = true;
     }
-    
+
+    @Override
+    public ResultTable execute() {
+        this.dbUtil.startRecording();
+        ResultTable table = new ResultTable();
+        table.idTable.put(ResultTable.GID, getAllNodeGid());
+        this.dbUtil.stopRecording();
+        this.querySQL = this.dbUtil.getExecuteHistory();
+        return table;
+    }
+
 }

Query/Execution/Execution.java

@@ -4,6 +4,7 @@
 import Utility.DBUtil;
 import DataImport.FileParser;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -12,46 +13,64 @@
  * Created by liuche on 6/5/17.
  */
 public class Execution {
-    private ResultTable resultTable;
-    private Plan plan;
-    private DBUtil dbUtil;
+    protected ResultTable resultTable;
+    protected Plan plan;
+    protected int operandCount = 0;
+    protected DBUtil dbUtil;
+    protected List<String> querySQL = new ArrayList<>();
 
     public Execution(DBUtil util, Plan plan){
         this.dbUtil = util;
         this.resultTable = new ResultTable();
         this.plan = plan;
     }
 
+    public int operandCount(){
+        return operandCount();
+    }
+
+    public List<String> getQuerySQL(){
+        return this.querySQL;
+    }
+
     public ResultTable execute(){
         return resultTable;
     }
 
-    private List<String> getAllNodeGid(){
+    public ResultTable execute(ResultTable table1){
+        return resultTable;
+    }
+
+    public ResultTable execute(ResultTable table1, ResultTable table2){
+        return resultTable;
+    }
+
+    protected List<String> getAllNodeGid(){
         String statement = "SELECT COUNT(*) FROM ObjectType WHERE type != \"0\";";
         return dbUtil.getListFromSQL(statement);
     }
 
-    private List<String> getNodeGidBy(String field, String value){
+    protected List<String> getNodeGidBy(String field, String value){
         String statement = "SELECT gid FROM P_" + field + "WHERE " + field + " = \"" + value + "\";";
         return dbUtil.getListFromSQL(statement);
     }
 
-    private List<String> getEdgeIdByFromGid(String node1){
+    protected List<String> getEdgeIdByFromGid(String node1){
         String statement = "SELECT eid FROM Edge WHERE node1 = \"" + node1 + "\";";
         return dbUtil.getListFromSQL(statement);
     }
 
-    private List<String> getEdgeIdByToGid(String node1){
+    protected List<String> getEdgeIdByToGid(String node1){
         String statement = "SELECT eid FROM Edge WHERE node2 = \"" + node1 + "\";";
         return dbUtil.getListFromSQL(statement);
     }
 
-    private Map<String, String> expandEdge(String eid){
+    protected Map<String, String> expandEdge(String eid){
         String statement = "SELECT * FROM edge WHERE eid = \""  + eid + "\";";
         return dbUtil.getObjectFromSQL(statement);
     }
 
-    private Map<String, String> expandObject(Integer gid){
+    protected Map<String, String> expandObject(Integer gid){
         String statement = "SELECT type FROM ObjectType WHERE gid = \"" + gid.toString() + "\";";
         Integer nodeType = dbUtil.getIntegerFromSQL(statement);
         statement = "SELECT name FROM typeProperty WHERE id = \"" + nodeType.toString() + "\";";

Query/Execution/ResultTable.java

@@ -8,6 +8,7 @@
  * Created by liuche on 6/5/17.
  */
 public class ResultTable {
+    public static final String GID = "gid";
     public enum  ObjectType {OBJECT, STRING, LIST, ID}
 
     public Map<String, List<String>> idTable = new HashMap<>();

Query/Plan/ScanByIdPlan.java

@@ -20,6 +20,7 @@ public ScanByIdPlan(QueryIndexer queryIndexer, String node) {
     public void applyTo(PlanTable table) {
         table.nodes.add(variable);
         table.estimatedSize = estimatedSize;
+        table.cost += 1;
         table.plans.add(this);
     }
 

Query/Plan/ScanByLabelPlan.java

@@ -27,6 +27,7 @@ public ScanByLabelPlan(QueryIndexer queryIndexer, String node, List<String> labe
     public void applyTo(PlanTable table) {
         table.nodes.add(variable);
         table.estimatedSize = estimatedSize;
+        table.cost += estimatedSize;
         table.plans.add(this);
     }
 

Utility/DBUtil.java

@@ -22,7 +22,7 @@ public void startRecording(){
         this.recording = true;
     }
 
-    public void endRecording(){
+    public void stopRecording(){
         this.recording = false;
     }