From f8eb9e421e907301204431dad2e094e2fee52f1c Mon Sep 17 00:00:00 2001 From: Vishal Anand Date: Fri, 17 Nov 2023 14:06:28 +0530 Subject: [PATCH 1/2] README.md updated and minor improvements. --- README.md | 8 +++++++- e6data_python_connector/e6data_grpc.py | 6 +++--- setup.py | 2 +- 3 files changed, 11 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index 9c23f6f..75c645c 100644 --- a/README.md +++ b/README.md @@ -1,11 +1,17 @@ # e6data Python Connector -![version](https://img.shields.io/badge/version-1.1.9-blue.svg) +![version](https://img.shields.io/badge/version-1.1.10-blue.svg) ## Introduction The e6data Connector for Python provides an interface for writing Python applications that can connect to e6data and perform operations. +#### Amazon Linux Wheel dependency +Make sure to install wheel before install e6data-python-connector. +```shell +pip install wheel +``` + To install the Python package, use the command below: ```shell pip install e6data-python-connector diff --git a/e6data_python_connector/e6data_grpc.py b/e6data_python_connector/e6data_grpc.py index 952e831..bb42560 100644 --- a/e6data_python_connector/e6data_grpc.py +++ b/e6data_python_connector/e6data_grpc.py @@ -358,14 +358,14 @@ def close(self): def get_tables(self): schema = self.connection.database - return self.connection.get_tables(database=schema) + return self.connection.get_tables(catalog=self._catalog_name, database=schema) def get_columns(self, table): schema = self.connection.database - return self.connection.get_columns(database=schema, table=table) + return self.connection.get_columns(catalog=self._catalog_name, database=schema, table=table) def get_schema_names(self): - return self.connection.get_schema_names() + return self.connection.get_schema_names(catalog=self._catalog_name) def clear(self): clear_request = e6x_engine_pb2.ClearRequest( diff --git a/setup.py b/setup.py index dcb6002..09590c6 100644 --- a/setup.py +++ b/setup.py @@ -12,7 +12,7 @@ import setuptools -VERSION = [1, 1, 9] +VERSION = [1, 1, 10] def get_long_desc(): From 11ca69b60f7b4834dacf5c0e7f3414f18bd0a7d3 Mon Sep 17 00:00:00 2001 From: Vishal Anand Date: Mon, 20 Nov 2023 23:14:28 +0530 Subject: [PATCH 2/2] Added optional query id while clearing the cursor. --- e6data_python_connector/e6data_grpc.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/e6data_python_connector/e6data_grpc.py b/e6data_python_connector/e6data_grpc.py index bb42560..ecf443f 100644 --- a/e6data_python_connector/e6data_grpc.py +++ b/e6data_python_connector/e6data_grpc.py @@ -367,10 +367,12 @@ def get_columns(self, table): def get_schema_names(self): return self.connection.get_schema_names(catalog=self._catalog_name) - def clear(self): + def clear(self, query_id=None): + if not query_id: + query_id = self._query_id clear_request = e6x_engine_pb2.ClearRequest( sessionId=self.connection.get_session_id, - queryId=self._query_id, + queryId=query_id, engineIP=self._engine_ip ) return self.connection.client.clear(clear_request)