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 <[email protected]> Authored: Fri Jun 2 10:33:30 2017 +0530 Committer: manuzhang <[email protected]> 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; + } }
