Merge pull request #51 from janantos/master

SSL Support

Author: vavrusa

README.rst

@@ -18,6 +18,12 @@ The DSN format is similar to that of regular Postgres::
     >>> import sqlalchemy as sa
     >>> sa.create_engine('clickhouse://username:password@hostname:port/database')
     Engine('clickhouse://username:password@hostname:port/database')
+    
+For SSL add ssl parameter to URL::
+
+    >>> import sqlalchemy as sa
+    >>> sa.create_engine('clickhouse://username:password@hostname:port/database?ssl=True')
+    Engine('clickhouse://username:password@hostname:port/database')
 
 It implements a dialect, so there's no user-facing API.
 

connector.py

@@ -125,7 +125,13 @@ class Connection(Database):
     """
         These objects are small stateless factories for cursors, which do all the real work.
     """
-    def __init__(self, db_name, db_url='http://localhost:8123/', username=None, password=None, readonly=False):
+    def __init__(self, db_name, db_url='http://localhost:8123/', username=None, password=None, readonly=False, ssl="False"):
+        if ssl.upper() == "TRUE":
+            db_url = db_url.replace("http", "https")
+        elif ssl.upper() == "FALSE":
+            pass
+        else:
+            raise ValueError("Not Supported value of ssl parameter, only True/False values are accepted")
         super(Connection, self).__init__(db_name, db_url, username, password, readonly)
         self.db_name = db_name
         self.db_url = db_url