Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill, mail # dev - [20/21] Rename SQLParser to exec/jdbc. Rename jdbc-all to exec/jdbc-all


Copy link to this message
-
[20/21] Rename SQLParser to exec/jdbc. Rename jdbc-all to exec/jdbc-all
jacques@... 2014-05-04, 16:56
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/2ae4a5f0/exec/jdbc/src/main/java/org/apache/drill/jdbc/GlobalServiceSetReference.java
diff --git a/exec/jdbc/src/main/java/org/apache/drill/jdbc/GlobalServiceSetReference.java b/exec/jdbc/src/main/java/org/apache/drill/jdbc/GlobalServiceSetReference.java
new file mode 100644
index 0000000..9326283
+++ b/exec/jdbc/src/main/java/org/apache/drill/jdbc/GlobalServiceSetReference.java
@@ -0,0 +1,29 @@
+/**
+ * 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.drill.jdbc;
+
+import org.apache.drill.exec.server.RemoteServiceSet;
+
+public class GlobalServiceSetReference {
+  static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(GlobalServiceSetReference.class);
+  
+  public static final ThreadLocal<RemoteServiceSet> SETS = new ThreadLocal<RemoteServiceSet>();
+  
+  
+  
+}

http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/2ae4a5f0/exec/jdbc/src/main/java/org/apache/drill/jdbc/MetaImpl.java
diff --git a/exec/jdbc/src/main/java/org/apache/drill/jdbc/MetaImpl.java b/exec/jdbc/src/main/java/org/apache/drill/jdbc/MetaImpl.java
new file mode 100644
index 0000000..5d8b6a7
+++ b/exec/jdbc/src/main/java/org/apache/drill/jdbc/MetaImpl.java
@@ -0,0 +1,180 @@
+/**
+ * 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.drill.jdbc;
+
+import java.sql.ResultSet;
+import java.util.List;
+
+import net.hydromatic.avatica.AvaticaPrepareResult;
+import net.hydromatic.avatica.AvaticaResultSet;
+import net.hydromatic.avatica.AvaticaStatement;
+import net.hydromatic.avatica.Cursor;
+import net.hydromatic.avatica.Meta;
+import net.hydromatic.linq4j.Linq4j;
+
+public class MetaImpl implements Meta {
+  
+  static final Driver DRIVER = new Driver();
+
+  final DrillConnectionImpl connection;
+
+  public MetaImpl(DrillConnectionImpl connection) {
+    this.connection = connection;
+  }
+
+  public String getSqlKeywords() {
+    return "";
+  }
+
+  public String getNumericFunctions() {
+    return "";
+  }
+
+  public String getStringFunctions() {
+    return "";
+  }
+
+  public String getSystemFunctions() {
+    return "";
+  }
+
+  public String getTimeDateFunctions() {
+    return "";
+  }
+
+  public static ResultSet getEmptyResultSet() {
+    return null;
+  }
+
+  public ResultSet getTables(String catalog, final Pat schemaPattern, final Pat tableNamePattern,
+      final List<String> typeList) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getColumns(String catalog, Pat schemaPattern, Pat tableNamePattern, Pat columnNamePattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getSchemas(String catalog, Pat schemaPattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getCatalogs() {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getTableTypes() {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getProcedures(String catalog, Pat schemaPattern, Pat procedureNamePattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getProcedureColumns(String catalog, Pat schemaPattern, Pat procedureNamePattern,
+      Pat columnNamePattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getColumnPrivileges(String catalog, String schema, String table, Pat columnNamePattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getTablePrivileges(String catalog, Pat schemaPattern, Pat tableNamePattern) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getBestRowIdentifier(String catalog, String schema, String table, int scope, boolean nullable) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getVersionColumns(String catalog, String schema, String table) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getPrimaryKeys(String catalog, String schema, String table) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getImportedKeys(String catalog, String schema, String table) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getExportedKeys(String catalog, String schema, String table) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getCrossReference(String parentCatalog, String parentSchema, String parentTable,
+      String foreignCatalog, String foreignSchema, String foreignTable) {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getTypeInfo() {
+    return getEmptyResultSet();
+  }
+
+  public ResultSet getIndexInfo(String cat