You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/07/09 00:18:16 UTC
[03/20] incubator-gearpump git commit: Implement Connection class
Implement Connection class
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/156bfd08
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/156bfd08
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/156bfd08
Branch: refs/heads/sql
Commit: 156bfd087331f57af339d6305c67046a874ff866
Parents: eb3caec
Author: Buddhi Ayesha <bu...@cse.mrt.ac.lk>
Authored: Fri Jun 2 10:33:30 2017 +0530
Committer: manuzhang <ow...@gmail.com>
Committed: Sun Jul 9 07:50:24 2017 +0800
----------------------------------------------------------------------
.../org/apache/calcite/planner/Connection.java | 295 ++++++++++++++++++-
1 file changed, 291 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/156bfd08/experiments/sql/src/main/java/org/apache/calcite/planner/Connection.java
----------------------------------------------------------------------
diff --git a/experiments/sql/src/main/java/org/apache/calcite/planner/Connection.java b/experiments/sql/src/main/java/org/apache/calcite/planner/Connection.java
index 894327d..1b8648d 100644
--- a/experiments/sql/src/main/java/org/apache/calcite/planner/Connection.java
+++ b/experiments/sql/src/main/java/org/apache/calcite/planner/Connection.java
@@ -1,7 +1,294 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
package org.apache.calcite.planner;
-/**
- * Created by Buddhi on 6/1/2017.
- */
-public class Connection {
+import org.apache.calcite.adapter.java.JavaTypeFactory;
+import org.apache.calcite.config.CalciteConnectionConfig;
+import org.apache.calcite.jdbc.CalciteConnection;
+import org.apache.calcite.linq4j.Enumerator;
+import org.apache.calcite.linq4j.Queryable;
+import org.apache.calcite.linq4j.tree.Expression;
+import org.apache.calcite.schema.SchemaPlus;
+import org.apache.calcite.tools.Frameworks;
+import org.apache.log4j.Logger;
+
+import java.lang.reflect.Type;
+import java.sql.*;
+import java.util.Map;
+import java.util.Properties;
+import java.util.concurrent.Executor;
+
+public class Connection implements CalciteConnection {
+
+ private final static Logger logger = Logger.getLogger(Connection.class);
+ private final SchemaPlus rootSchema = Frameworks.createRootSchema(true);
+ private String schema = null;
+
+ public SchemaPlus getRootSchema() {
+ return rootSchema;
+ }
+
+ public JavaTypeFactory getTypeFactory() {
+ return null;
+ }
+
+ public Properties getProperties() {
+ return null;
+ }
+
+ public Statement createStatement() throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql) throws SQLException {
+ return null;
+ }
+
+ public CallableStatement prepareCall(String sql) throws SQLException {
+ return null;
+ }
+
+ public String nativeSQL(String sql) throws SQLException {
+ return null;
+ }
+
+ public void setAutoCommit(boolean autoCommit) throws SQLException {
+
+ }
+
+ public boolean getAutoCommit() throws SQLException {
+ return false;
+ }
+
+ public void commit() throws SQLException {
+
+ }
+
+ public void rollback() throws SQLException {
+
+ }
+
+ public void close() throws SQLException {
+
+ }
+
+ public boolean isClosed() throws SQLException {
+ return false;
+ }
+
+ public DatabaseMetaData getMetaData() throws SQLException {
+ return null;
+ }
+
+ public void setReadOnly(boolean readOnly) throws SQLException {
+
+ }
+
+ public boolean isReadOnly() throws SQLException {
+ return false;
+ }
+
+ public void setCatalog(String catalog) throws SQLException {
+
+ }
+
+ public String getCatalog() throws SQLException {
+ return null;
+ }
+
+ public void setTransactionIsolation(int level) throws SQLException {
+
+ }
+
+ public int getTransactionIsolation() throws SQLException {
+ return 0;
+ }
+
+ public SQLWarning getWarnings() throws SQLException {
+ return null;
+ }
+
+ public void clearWarnings() throws SQLException {
+
+ }
+
+ public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
+ return null;
+ }
+
+ public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
+ return null;
+ }
+
+ public Map<String, Class<?>> getTypeMap() throws SQLException {
+ return null;
+ }
+
+ public void setTypeMap(Map<String, Class<?>> map) throws SQLException {
+
+ }
+
+ public void setHoldability(int holdability) throws SQLException {
+
+ }
+
+ public int getHoldability() throws SQLException {
+ return 0;
+ }
+
+ public Savepoint setSavepoint() throws SQLException {
+ return null;
+ }
+
+ public Savepoint setSavepoint(String name) throws SQLException {
+ return null;
+ }
+
+ public void rollback(Savepoint savepoint) throws SQLException {
+
+ }
+
+ public void releaseSavepoint(Savepoint savepoint) throws SQLException {
+
+ }
+
+ public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
+ return null;
+ }
+
+ public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException {
+ return null;
+ }
+
+ public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException {
+ return null;
+ }
+
+ public Clob createClob() throws SQLException {
+ return null;
+ }
+
+ public Blob createBlob() throws SQLException {
+ return null;
+ }
+
+ public NClob createNClob() throws SQLException {
+ return null;
+ }
+
+ public SQLXML createSQLXML() throws SQLException {
+ return null;
+ }
+
+ public boolean isValid(int timeout) throws SQLException {
+ return false;
+ }
+
+ public void setClientInfo(String name, String value) throws SQLClientInfoException {
+
+ }
+
+ public void setClientInfo(Properties properties) throws SQLClientInfoException {
+
+ }
+
+ public String getClientInfo(String name) throws SQLException {
+ return null;
+ }
+
+ public Properties getClientInfo() throws SQLException {
+ return null;
+ }
+
+ public Array createArrayOf(String typeName, Object[] elements) throws SQLException {
+ return null;
+ }
+
+ public Struct createStruct(String typeName, Object[] attributes) throws SQLException {
+ return null;
+ }
+
+ public void setSchema(String s) throws SQLException {
+ schema = s;
+ }
+
+ public String getSchema() throws SQLException {
+ return schema;
+ }
+
+ public void abort(Executor executor) throws SQLException {
+
+ }
+
+ public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException {
+
+ }
+
+ public int getNetworkTimeout() throws SQLException {
+ return 0;
+ }
+
+ public CalciteConnectionConfig config() {
+ return null;
+ }
+
+ public <T> T unwrap(Class<T> iface) throws SQLException {
+ return null;
+ }
+
+ public boolean isWrapperFor(Class<?> iface) throws SQLException {
+ return false;
+ }
+
+ public <T> Queryable<T> createQuery(Expression expression, Class<T> aClass) {
+ return null;
+ }
+
+ public <T> Queryable<T> createQuery(Expression expression, Type type) {
+ return null;
+ }
+
+ public <T> T execute(Expression expression, Class<T> aClass) {
+ return null;
+ }
+
+ public <T> T execute(Expression expression, Type type) {
+ return null;
+ }
+
+ public <T> Enumerator<T> executeQuery(Queryable<T> queryable) {
+ return null;
+ }
}