KYLIN-3434 Support prepare statement in Kylin server side

core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java

@@ -1377,6 +1377,14 @@ public String getQueryAccessController() {
         return getOptional("kylin.query.access-controller", null);
     }
 
+    public int getQueryMaxCacheStatementNum() {
+        return Integer.parseInt(this.getOptional("kylin.query.statement-cache-max-num", String.valueOf(50000)));
+    }
+
+    public int getQueryMaxCacheStatementInstancePerKey() {
+        return Integer.parseInt(this.getOptional("kylin.query.statement-cache-max-num-per-key", String.valueOf(50)));
+    }
+
     public int getDimCountDistinctMaxCardinality() {
         return Integer.parseInt(getOptional("kylin.query.max-dimension-count-distinct", "5000000"));
     }

core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java

@@ -264,6 +264,7 @@ public CubeInstance updateCubeStatus(CubeInstance cube, RealizationStatusEnum ne
             cube = cube.latestCopyForWrite(); // get a latest copy
             CubeUpdate update = new CubeUpdate(cube);
             update.setStatus(newStatus);
+            ProjectManager.getInstance(config).touchProject(cube.getProject());
             return updateCube(update);
         }
     }

core-metadata/src/main/java/org/apache/kylin/metadata/project/ProjectManager.java

@@ -355,6 +355,18 @@ public void removeExtFilterFromProject(String filterName, String projectName) th
             save(projectInstance);
         }
     }
+
+    /**
+     * change the last project modify time
+     * @param projectName
+     * @throws IOException
+     */
+    public void touchProject(String projectName) throws IOException {
+        try (AutoLock lock = prjMapLock.lockForWrite()) {
+            ProjectInstance projectInstance = getProject(projectName);
+            save(projectInstance);
+        }
+    }
 
     private ProjectInstance save(ProjectInstance prj) throws IOException {
         crud.save(prj);

pom.xml

@@ -80,6 +80,7 @@
         <commons-upload.version>1.3.3</commons-upload.version>
         <commons-math3.version>3.1.1</commons-math3.version>
         <commons-collections.version>3.2.2</commons-collections.version>
+        <commons-pool.version>2.5.0</commons-pool.version>
 
         <!-- Calcite deps, keep compatible with calcite.version -->
         <jackson.version>2.9.5</jackson.version>
@@ -507,6 +508,11 @@
                 <version>${commons-collections.version}</version>
                 <scope>provided</scope>
             </dependency>
+            <dependency>
+                <groupId>org.apache.commons</groupId>
+                <artifactId>commons-pool2</artifactId>
+                <version>${commons-pool.version}</version>
+            </dependency>
 
             <!-- HBase2 dependencies -->
             <dependency>

server-base/pom.xml

@@ -85,6 +85,10 @@
             <groupId>net.sf.supercsv</groupId>
             <artifactId>super-csv</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.apache.kylin</groupId>

server-base/src/main/java/org/apache/kylin/rest/request/PrepareSqlRequest.java

@@ -28,6 +28,7 @@
  * 
  */
 public class PrepareSqlRequest extends SQLRequest {
+    private boolean enableStatementCache = true;
 
     public PrepareSqlRequest() {
         super();
@@ -43,6 +44,14 @@ public void setParams(StateParam[] params) {
         this.params = params;
     }
 
+    public boolean isEnableStatementCache() {
+        return enableStatementCache;
+    }
+
+    public void setEnableStatementCache(boolean enableStatementCache) {
+        this.enableStatementCache = enableStatementCache;
+    }
+
     public static class StateParam implements Serializable {
         private String className;
         private String value;