diff options
author | emmet <emmet@emmet-mbp-8.local> | 2018-01-26 00:59:47 -0800 |
---|---|---|
committer | emmet <emmet@emmet-mbp-8.local> | 2018-01-26 00:59:47 -0800 |
commit | 70342c02960f9a5196728d0909762163541e1ac3 (patch) | |
tree | 631ef951b5f91703f83c2b1ed9c379eb4933d113 | |
parent | a73ac8a63683a3234fa05ee99db51b13ac04409f (diff) | |
download | yoyo-snowflake.tar.gz |
fix SnowflakeBackendsnowflake
-rw-r--r-- | yoyo/backends.py | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/yoyo/backends.py b/yoyo/backends.py index e8614be..4a8f14b 100644 --- a/yoyo/backends.py +++ b/yoyo/backends.py @@ -459,17 +459,21 @@ class PostgresqlBackend(DatabaseBackend): 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 |