Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 7 additions & 6 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
# e6data Python Connector

![version](https://img.shields.io/badge/version-1.1.7-blue.svg)
![version](https://img.shields.io/badge/version-1.1.8-blue.svg)

## Introduction

Expand Down Expand Up @@ -79,8 +79,8 @@ for item in records_iterator:
To get the execution plan after query execution:
```python
import json

query_planner = json.loads(cursor.explain_analyse())
explain_response = cursor.explain_analyse()
query_planner = json.loads(explain_response.get('planner'))
```

To abort a running query:
Expand All @@ -103,8 +103,8 @@ query = 'SELECT * FROM <TABLE_NAME>'
cursor = conn.cursor(catalog_name)
query_id = cursor.execute(query) # execute function returns query id, can be use for aborting the query.
all_records = cursor.fetchall()

query_planner = json.loads(cursor.explain_analyse())
explain_response = cursor.explain_analyse()
query_planner = json.loads(explain_response.get('planner'))

execution_time = query_planner.get("total_query_time") # In milliseconds
queue_time = query_planner.get("executionQueueingTime") # In milliseconds
Expand Down Expand Up @@ -173,7 +173,8 @@ conn = Connection(
cursor = conn.cursor(db_name=database, catalog_name=catalog_name)
query_id = cursor.execute(sql_query)
all_records = cursor.fetchall()
planner_result = json.loads(cursor.explain_analyse())
explain_response = cursor.explain_analyse()
planner_result = json.loads(explain_response.get('planner'))
execution_time = planner_result.get("total_query_time") / 1000 # Converting into seconds.
row_count = planner_result.get('row_count_out')
columns = [col[0] for col in cursor.description] # Get the column names and merge them with the results.
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@

import setuptools

VERSION = [1, 1, 7]
VERSION = [1, 1, 8]


def get_long_desc():
Expand Down