Fix issue with snowflake Connector (#13)

* Fix issue with snowflake Connector * More fixes
RedisGears · Apr 14, 2020 · 65e0787 · 65e0787
1 parent 7070b45
commit 65e0787
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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)