diff options
| author | Asko Tiidumaa | 2010-11-26 12:33:33 +0000 |
|---|---|---|
| committer | Marko Kreen | 2010-11-29 12:56:19 +0000 |
| commit | 89aea74e57a42f33bb345e327bdffdad52dea4d2 (patch) | |
| tree | d3a0d40f1e27480953be57594dc72bdc505aca36 /python/londiste | |
| parent | d5e9c441c7a31b10c703aac3013eaf0764fbd1c7 (diff) | |
sql/*: Simplify queries to be able to run greenplum as leaf
execute:
Move session_replication_role setting out of db functions.
Diffstat (limited to 'python/londiste')
| -rw-r--r-- | python/londiste/playback.py | 5 | ||||
| -rw-r--r-- | python/londiste/setup.py | 2 |
2 files changed, 6 insertions, 1 deletions
diff --git a/python/londiste/playback.py b/python/londiste/playback.py index ed892c36..fce32dbb 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -559,6 +559,9 @@ class Replicator(CascadedWorker): sql = ev.data # fixme: curs? + pgver = dst_curs.connection.server_version + if pgver >= 80300: + curs.execute("set local session_replication_role = 'local'") q = "select * from londiste.execute_start(%s, %s, %s, false)" res = self.exec_cmd(dst_curs, q, [self.queue_name, fname, sql], commit = False) ret = res[0]['ret_code'] @@ -569,6 +572,8 @@ class Replicator(CascadedWorker): dst_curs.execute(stmt) q = "select * from londiste.execute_finish(%s, %s)" self.exec_cmd(dst_curs, q, [self.queue_name, fname], commit = False) + if pgver >= 80300: + curs.execute("set local session_replication_role = 'replica'") def apply_sql(self, sql, dst_curs): diff --git a/python/londiste/setup.py b/python/londiste/setup.py index 9ea44bbb..e8b20310 100644 --- a/python/londiste/setup.py +++ b/python/londiste/setup.py @@ -353,7 +353,7 @@ class LondisteSetup(CascadeAdmin): # set replica role for EXECUTE transaction if db.server_version >= 80300: - curs.execute("set local session_replication_role = 'replica'") + curs.execute("set local session_replication_role = 'local'") for fn in files: fname = os.path.basename(fn) |