From 2fd16141447c57b2229aff34f0eedd284819140b Mon Sep 17 00:00:00 2001 From: Alexander Kukushkin Date: Wed, 6 May 2015 17:52:39 +0200 Subject: [PATCH] query method now allow to execute sql with parameters --- helpers/postgresql.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/helpers/postgresql.py b/helpers/postgresql.py index 1de58303..ca59172d 100644 --- a/helpers/postgresql.py +++ b/helpers/postgresql.py @@ -49,11 +49,11 @@ class Postgresql: except: logger.exception('Error disconnecting') - def query(self, sql): + def query(self, sql, *params): max_attempts = 0 while True: try: - self.cursor().execute(sql) + self.cursor().execute(sql, params) break except psycopg2.OperationalError as e: if self.conn: @@ -191,8 +191,8 @@ primary_conninfo = 'user={username} password={password} host={hostname} port={po self.restart() def create_replication_user(self): - self.query("CREATE USER \"%s\" WITH REPLICATION ENCRYPTED PASSWORD '%s';" % - (self.replication['username'], self.replication['password'])) + self.query('CREATE USER "{}" WITH REPLICATION ENCRYPTED PASSWORD %s'.format( + self.replication['username']), self.replication['password']) def xlog_position(self): return self.query('SELECT pg_last_xlog_replay_location()').fetchone()[0]