From 7351f9b51f75b6f480231b5cedc2396878b9349d Mon Sep 17 00:00:00 2001 From: ShivaNaveen Ravi Date: Fri, 10 Dec 2021 21:27:45 +0000 Subject: [PATCH] Added optional ssl_disabled property --- README.md | 2 ++ dbt/adapters/mysql5/connections.py | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/README.md b/README.md index 37f243b..df73d1b 100644 --- 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 index 846c16d..de008a3 100644 --- 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