You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by lu...@apache.org on 2015/09/06 09:39:28 UTC
[22/50] [abbrv] incubator-kylin git commit: KYLIN-945 Fix Exception when loading Connection from DataSource, contributed by Sébastien Jelsch
KYLIN-945 Fix Exception when loading Connection from DataSource, contributed by Sébastien Jelsch <mu...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/1a296f95
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/1a296f95
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/1a296f95
Branch: refs/heads/master
Commit: 1a296f9538abc8851941be684544716c2438153a
Parents: da73202
Author: shaofengshi <sh...@apache.org>
Authored: Thu Aug 13 16:22:16 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Thu Aug 13 16:22:16 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/jdbc/KylinConnection.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/1a296f95/jdbc/src/main/java/org/apache/kylin/jdbc/KylinConnection.java
----------------------------------------------------------------------
diff --git a/jdbc/src/main/java/org/apache/kylin/jdbc/KylinConnection.java b/jdbc/src/main/java/org/apache/kylin/jdbc/KylinConnection.java
index 8c53e60..d4f5337 100644
--- a/jdbc/src/main/java/org/apache/kylin/jdbc/KylinConnection.java
+++ b/jdbc/src/main/java/org/apache/kylin/jdbc/KylinConnection.java
@@ -31,6 +31,7 @@ import org.apache.calcite.avatica.AvaticaConnection;
import org.apache.calcite.avatica.AvaticaParameter;
import org.apache.calcite.avatica.AvaticaStatement;
import org.apache.calcite.avatica.ColumnMetaData;
+import org.apache.calcite.avatica.ConnectionPropertiesImpl;
import org.apache.calcite.avatica.Meta;
import org.apache.calcite.avatica.Meta.CursorFactory;
import org.apache.calcite.avatica.Meta.Signature;
@@ -80,6 +81,18 @@ public class KylinConnection extends AvaticaConnection {
Properties getConnectionProperties() {
return info;
}
+
+ public boolean getAutoCommit() throws SQLException {
+ if(meta.connectionSync(handle, new ConnectionPropertiesImpl()).isAutoCommit() == null)
+ setAutoCommit(true);
+ return super.getAutoCommit();
+ }
+
+ public boolean isReadOnly() throws SQLException {
+ if(meta.connectionSync(handle, new ConnectionPropertiesImpl()).isReadOnly() == null)
+ setReadOnly(true);
+ return super.isReadOnly();
+ }
@Override
public AvaticaStatement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {