refactor SQLContext

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parser/sql/context/AbstractSQLContext.java

@@ -20,13 +20,13 @@ package com.dangdang.ddframe.rdb.sharding.parser.sql.context;
 import com.dangdang.ddframe.rdb.sharding.parser.result.router.Condition;
 import com.dangdang.ddframe.rdb.sharding.parser.result.router.ConditionContext;
 import com.dangdang.ddframe.rdb.sharding.parser.result.router.SQLBuilder;
+import com.dangdang.ddframe.rdb.sharding.parser.result.router.SQLStatementType;
 import com.dangdang.ddframe.rdb.sharding.parser.sql.expr.SQLExpr;
 import com.dangdang.ddframe.rdb.sharding.parser.sql.expr.SQLIdentifierExpr;
 import com.dangdang.ddframe.rdb.sharding.parser.sql.expr.SQLPropertyExpr;
 import com.dangdang.ddframe.rdb.sharding.util.SQLUtil;
 import com.google.common.base.Optional;
 import lombok.Getter;
-import lombok.RequiredArgsConstructor;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -41,18 +41,29 @@ import java.util.List;
  *
  * @author zhangliang
  */
-@RequiredArgsConstructor
 @Getter
 public abstract class AbstractSQLContext implements SQLContext {
     
     private final String originalSQL;
     
-    private List<TableContext> tables = new ArrayList<>();
+    private final SQLStatementType type;
+    
+    private final List<TableContext> tables = new ArrayList<>();
     
     private final Collection<ConditionContext> conditionContexts = new LinkedList<>();
     
     private final List<SQLToken> sqlTokens = new LinkedList<>();
     
+    public AbstractSQLContext(final String originalSQL, final SQLStatementType type) {
+        this.originalSQL = originalSQL;
+        this.type = type;
+    }
+    
+    @Override
+    public final SQLStatementType getType() {
+        return type;
+    }
+    
     @Override
     public Optional<Condition.Column> findColumn(final SQLExpr expr) {
         if (expr instanceof SQLPropertyExpr) {

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parser/sql/context/DeleteSQLContext.java

@@ -29,11 +29,6 @@ import lombok.Getter;
 public final class DeleteSQLContext extends AbstractSQLContext {
     
     public DeleteSQLContext(final String originalSQL) {
-        super(originalSQL);
-    }
-    
-    @Override
-    public SQLStatementType getType() {
-        return SQLStatementType.DELETE;
+        super(originalSQL, SQLStatementType.DELETE);
     }
 }

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parser/sql/context/InsertSQLContext.java

@@ -32,12 +32,7 @@ public final class InsertSQLContext extends AbstractSQLContext {
     private final GeneratedKeyContext generatedKeyContext;
     
     public InsertSQLContext(final String originalSQL) {
-        super(originalSQL);
+        super(originalSQL, SQLStatementType.INSERT);
         generatedKeyContext = new GeneratedKeyContext();
     }
-    
-    @Override
-    public SQLStatementType getType() {
-        return SQLStatementType.INSERT;
-    }
 }

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parser/sql/context/SelectSQLContext.java

@@ -47,16 +47,7 @@ public final class SelectSQLContext extends AbstractSQLContext {
     
     private LimitContext limitContext;
     
-    private SelectSQLContext parent;
-    
-    private List<SelectSQLContext> children = new LinkedList<>();
-    
     public SelectSQLContext(final String originalSQL) {
-        super(originalSQL);
-    }
-    
-    @Override
-    public SQLStatementType getType() {
-        return SQLStatementType.SELECT;
+        super(originalSQL, SQLStatementType.SELECT);
     }
 }

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parser/sql/context/UpdateSQLContext.java

@@ -27,11 +27,6 @@ import com.dangdang.ddframe.rdb.sharding.parser.result.router.SQLStatementType;
 public final class UpdateSQLContext extends AbstractSQLContext {
     
     public UpdateSQLContext(final String originalSQL) {
-        super(originalSQL);
-    }
-    
-    @Override
-    public SQLStatementType getType() {
-        return SQLStatementType.UPDATE;
+        super(originalSQL, SQLStatementType.UPDATE);
     }
 }