# HG changeset patch # User emmet@emmet-mbp-8.local # Date 1516957187 28800 # Fri Jan 26 00:59:47 2018 -0800 # Branch snowflake # Node ID 50baa52bcd93d33334fc5647bb6176cf830e8a69 # Parent 95a69fd6653633a56d698a9cd7b9d90ce05d70c6 fix SnowflakeBackend diff --git a/yoyo/backends.py b/yoyo/backends.py --- a/yoyo/backends.py +++ b/yoyo/backends.py @@ -459,17 +459,21 @@ yield self.connection.autocommit = saved + class SnowflakeBackend(DatabaseBackend): driver_module = 'snowflake.connector' def connect(self, dburi): - connargs = [] + database, schema = dburi.database.split('/') + return self.driver.connect(user=dburi.username, password=dburi.password, account=dburi.hostname, + database=database, schema=schema, warehouse=dburi.args['warehouse']) - if dburi.username is not None: - connargs.append('user=%s' % dburi.username) - if dburi.password is not None: - connargs.append('password=%s' % dburi.password) - connargs.append('account=%s' % dburi.database) - return self.driver.connect(' '.join(connargs)) + def savepoint(self, id): + pass + def savepoint_release(self, id): + pass + + def savepoint_rollback(self, id): + pass \ No newline at end of file