Sync with Cloudera Impyla

CHANGELOG.md

@@ -1,6 +1,35 @@
 Changelog
 =========
 
+0.20a1
+------
+* **Improvements**
+  - Add Knox cookies in default cookies list (#525)
+  - Support CHAR type in SQLAlchemy (#516)
+  - Support Cursor.rowcount and close finished queries (#528)
+    Note that this is a potentially breaking change. See the PR
+    for details about the side-effects.
+    The old behavior can be restored by setting close_finished_queries=False
+    when creating a Cursor.
+    Also note that Cursor.rowcount only works with Impala server - with
+    Hive it will always return -1.
+
+* **Bug Fixes**
+  - Fix https connection with Python 3.12 (#531)
+    Note that Python 3.12 support is not complete yet.
+    A known issue is that installing with setuptools fails with Python 3.12.
+
+0.19.0
+------
+* **Improvements**
+  - Add get_view_name support to SQLAlchemy (#511)
+    SHOW VIEWS is expected to be supported in Impala soon.
+  - Add additional checks to ensure connection arguments (#515)
+
+* **Bug Fixes**
+  - Fix Cookie handling with Python 3 (#518)
+  - Fix numeric parameter substitution bug (#508)
+
 0.18.0
 ------
 * **Improvements**

README.md

@@ -103,6 +103,17 @@ py.test --connect impala
 
 Leave out the `--connect` option to skip tests for DB API compliance.
 
+To test impyla with different Python versions [tox] can be used.
+The commands below will run all impyla tests with all supported and
+installed Python versions:
+```bash
+cd path/to/impyla
+tox
+```
+To filter environments / tests use `-e` and [pytest] arguments after `--`:
+```bash
+tox -e py310 -- -ktest_utf8_strings
+```
 
 ### Usage
 
@@ -111,7 +122,7 @@ Impyla implements the [Python DB API v2.0 (PEP 249)][pep249] database interface
 
 ```python
 from impala.dbapi import connect
-conn = connect(host='my.host.com', port=21050)
+conn = connect(host='my.host.com', port=21050) # auth_mechanism='PLAIN' for unsecured Hive connection, see function doc
 cursor = conn.cursor()
 cursor.execute('SELECT * FROM mytable LIMIT 100')
 print cursor.description  # prints the result set's schema
@@ -160,6 +171,7 @@ df = as_pandas(cur)
 [pytest]: http://pytest.org/latest/
 [sqlalchemy]: http://www.sqlalchemy.org/
 [ibis]: http://www.ibis-project.org/
+[tox]: http://tox.wiki/
 
 # How do I contribute code?
 You need to first sign and return an

impala/_thrift_api.py

@@ -171,9 +171,15 @@ def open(self):
       self.__http = http_client.HTTPConnection(self.host, self.port,
                                                timeout=self.__timeout)
     elif self.scheme == 'https':
+      # (#529) From python 3.12 http_client.HTTPSConnection no longer
+      # expects certfile and key_file. Certfile is included in context
+      # while key_file can be used in SSLContext.load_verify_locations.
+      # As Impyla doesn't support server authentication (#362) both
+      # certfile and key_file are expected to be None here.
+      if self.certfile or self.keyfile:
+        raise NotSupportedError("Server authentication is not supported " +
+                                "with HTTP endpoints")
       self.__http = http_client.HTTPSConnection(self.host, self.port,
-                                                key_file=self.keyfile,
-                                                cert_file=self.certfile,
                                                 timeout=self.__timeout,
                                                 context=self.context)
     if self.using_proxy():

impala/_thrift_gen/ImpalaService/ImpalaHiveServer2Service-remote

@@ -26,6 +26,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
     print('Functions:')
     print('  TGetExecSummaryResp GetExecSummary(TGetExecSummaryReq req)')
     print('  TGetRuntimeProfileResp GetRuntimeProfile(TGetRuntimeProfileReq req)')
+    print('  TPingImpalaHS2ServiceResp PingImpalaHS2Service(TPingImpalaHS2ServiceReq req)')
+    print('  TCloseImpalaOperationResp CloseImpalaOperation(TCloseImpalaOperationReq req)')
     print('  TOpenSessionResp OpenSession(TOpenSessionReq req)')
     print('  TCloseSessionResp CloseSession(TCloseSessionReq req)')
     print('  TGetInfoResp GetInfo(TGetInfoReq req)')
@@ -137,6 +139,18 @@ elif cmd == 'GetRuntimeProfile':
         sys.exit(1)
     pp.pprint(client.GetRuntimeProfile(eval(args[0]),))
 
+elif cmd == 'PingImpalaHS2Service':
+    if len(args) != 1:
+        print('PingImpalaHS2Service requires 1 args')
+        sys.exit(1)
+    pp.pprint(client.PingImpalaHS2Service(eval(args[0]),))
+
+elif cmd == 'CloseImpalaOperation':
+    if len(args) != 1:
+        print('CloseImpalaOperation requires 1 args')
+        sys.exit(1)
+    pp.pprint(client.CloseImpalaOperation(eval(args[0]),))
+
 elif cmd == 'OpenSession':
     if len(args) != 1:
         print('OpenSession requires 1 args')