Merge pull request #1 from databendcloud/fix-sdk

tune sdk behaviour on error

Author: hantmac

databend_py/__init__.py

@@ -1,7 +1,7 @@
 from .client import Client
 from .connection import Connection
 
-VERSION = (0, 1, 5)
+VERSION = (0, 1, 6)
 __version__ = '.'.join(str(x) for x in VERSION)
 
 __all__ = ['Client', 'Connection']

databend_py/connection.py

@@ -67,7 +67,7 @@ class Connection(object):
     #   'database': 'default'
     # }
     def __init__(self, host, port=None, user=defines.DEFAULT_USER, password=defines.DEFAULT_PASSWORD,
-                 database=defines.DEFAULT_DATABASE, secure=False, ):
+                 database=defines.DEFAULT_DATABASE, secure=True, ):
         self.host = host
         self.port = port
         self.user = user
@@ -121,7 +121,7 @@ def query(self, statement, session):
             return json.loads(response.content)
         except Exception as err:
             log.logger.error(
-                f"http error, SQL: {statement}\ncontent: {response.content}\nerror msg:{str(err)}"
+                f"http error on {url}, SQL: {statement} content: {response.content} error msg:{str(err)}"
             )
             raise
 

databend_py/util/helper.py

@@ -22,9 +22,8 @@ def get_error(self):
         if self.response['error'] is None:
             return None
 
-        # Wrap errno into msg, for result check
         return ServerException(message=self.response['error']['message'],
-                               code=self.response['error']['code'])
+                               code=self.response['error'].get('code'))
 
     def check_error(self):
         error = self.get_error()