From 65e0787d5f71310e32ee5c41fced1559def6af17 Mon Sep 17 00:00:00 2001 From: "Meir Shpilraien (Spielrein)" Date: Tue, 14 Apr 2020 12:02:09 +0300 Subject: [PATCH] Fix issue with snowflake Connector (#13) * Fix issue with snowflake Connector * More fixes --- rgsync/Connectors/sql_connectors.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/rgsync/Connectors/sql_connectors.py b/rgsync/Connectors/sql_connectors.py index d9a1446..fb1496b 100644 --- a/rgsync/Connectors/sql_connectors.py +++ b/rgsync/Connectors/sql_connectors.py @@ -40,8 +40,8 @@ def __init__(self, user, passwd, db, account): self.account = account def _getConnectionStr(self): - return 'snowflake://{user}:{password}@{account}/{db}'.format(user=self.username, - password=self.password, + return 'snowflake://{user}:{password}@{account}/{db}'.format(user=self.user, + password=self.passwd, account=self.account, db=self.db) @@ -182,5 +182,5 @@ def GetUpdateQuery(table, pkey, values_with_pkey, values): self.exactlyOnceQuery = GetUpdateQuery(self.exactlyOnceTableName, 'id', ['id', 'val'], ['val']) class SnowflakeSqlConnector(OracleSqlConnector): - def __init__(self, OracleSqlConnector, tableName, pk, exactlyOnceTableName=None): - OracleSqlBackend.__init__(self, OracleSqlConnector, tableName, pk, exactlyOnceTableName) + def __init__(self, connection, tableName, pk, exactlyOnceTableName=None): + OracleSqlConnector.__init__(self, connection, tableName, pk, exactlyOnceTableName)