You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/07/25 09:45:08 UTC
[21/24] kylin git commit: KYLIN-2748 fix:register calcite driver when
the first query
KYLIN-2748 fix:register calcite driver when the first query
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/8009c2f3
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/8009c2f3
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/8009c2f3
Branch: refs/heads/2.1.x
Commit: 8009c2f3b4c9a0693dd928ab4b371b738f595fba
Parents: 9141bff
Author: yiming.xu <10...@qq.com>
Authored: Tue Jul 25 13:37:38 2017 +0800
Committer: YIMINGXU <10...@qq.com>
Committed: Tue Jul 25 13:56:50 2017 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/kylin/query/QueryConnection.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/8009c2f3/query/src/main/java/org/apache/kylin/query/QueryConnection.java
----------------------------------------------------------------------
diff --git a/query/src/main/java/org/apache/kylin/query/QueryConnection.java b/query/src/main/java/org/apache/kylin/query/QueryConnection.java
index bf8d970..f659533 100644
--- a/query/src/main/java/org/apache/kylin/query/QueryConnection.java
+++ b/query/src/main/java/org/apache/kylin/query/QueryConnection.java
@@ -24,6 +24,7 @@ import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
+import org.apache.calcite.jdbc.Driver;
import org.apache.kylin.common.KylinConfig;
import org.apache.kylin.metadata.project.ProjectInstance;
import org.apache.kylin.query.schema.OLAPSchemaFactory;
@@ -31,8 +32,13 @@ import org.apache.log4j.Logger;
public class QueryConnection {
private static final Logger logger = Logger.getLogger(QueryConnection.class);
+ private static Boolean isRegister = false;
public static Connection getConnection(String project) throws SQLException {
+ if (!isRegister) {
+ DriverManager.registerDriver(new Driver());
+ isRegister = true;
+ }
File olapTmp = OLAPSchemaFactory.createTempOLAPJson(ProjectInstance.getNormalizedProjectName(project),
KylinConfig.getInstanceFromEnv());
Properties info = new Properties();