Merge pull request #67 from navashiva/feature/mysql-5.x-ssl-mode

Added optional ssl_disabled property
dbeatty10 · Feb 19, 2022 · bd4770e · bd4770e
2 parents cde8555 + 7351f9b
commit bd4770e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -97,6 +97,7 @@ your_profile_name:
       schema: analytics
       username: your_mysql_username
       password: your_mysql_password
+      ssl_disabled: True
 ```
 
 | Option          | Description                                                                         | Required?                                                          | Example                                        |
@@ -107,6 +108,7 @@ your_profile_name:
 | schema          | Specify the schema (database) to build models into                                  | Required                                                           | `analytics`                                    |
 | username        | The username to use to connect to the server                                        | Required                                                           | `dbt_admin`                                    |
 | password        | The password to use for authenticating to the server                                | Required                                                           | `correct-horse-battery-staple`                 |
+| ssl_disabled    | Set to enable or disable TLS connectivity to mysql5.x                               | Optional                                                           | `True` or `False`                              |
 
 ### Notes
 

diff --git a/dbt/adapters/mysql5/connections.py b/dbt/adapters/mysql5/connections.py
@@ -21,6 +21,7 @@ class MySQLCredentials(Credentials):
     username: Optional[str]
     password: Optional[str]
     charset: Optional[str]
+    ssl_disabled: Optional[bool]
 
     _ALIASES = {
         "UID": "username",
@@ -76,6 +77,9 @@ def open(cls, connection):
         kwargs["user"] = credentials.username
         kwargs["passwd"] = credentials.password
 
+        if credentials.ssl_disabled:
+            kwargs["ssl_disabled"] = credentials.ssl_disabled
+
         if credentials.port:
             kwargs["port"] = credentials.port