psycopg/psycopg2
1
1
Fork 0
mirror of https://github.com/psycopg/psycopg2.git synced 2024-11-26 10:53:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Remove IDENTIFY_SYSTEM wrapper method (it can't work with async anyway).

Browse Source
This commit is contained in:
Oleksandr Shulgin 2015-10-13 18:05:33 +02:00
parent ea2b87eade
commit 6ad299945f
2 changed files with 1 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
doc/src/extras.rst
View File

@ -222,16 +222,6 @@ The individual messages in the replication stream are presented by
.. autoclass:: ReplicationCursor .. autoclass:: ReplicationCursor
.. method:: identify_system()
Execute ``IDENTIFY_SYSTEM`` command of the streaming replication
protocol and return the result as a dictionary.
Example::
>>> cur.identify_system()
{'timeline': 1, 'systemid': '1234567890123456789', 'dbname': 'test', 'xlogpos': '0/1ABCDEF'}
.. method:: create_replication_slot(slot_name, slot_type=None, output_plugin=None) .. method:: create_replication_slot(slot_name, slot_type=None, output_plugin=None)
Create streaming replication slot. Create streaming replication slot.

9
lib/extras.py
View File

@ -506,13 +506,6 @@ class PhysicalReplicationConnection(ReplicationConnectionBase):
class ReplicationCursor(_cursor): class ReplicationCursor(_cursor):
"""A cursor used for communication on the replication protocol.""" """A cursor used for communication on the replication protocol."""
def identify_system(self):
"""Get information about the cluster status."""
self.execute("IDENTIFY_SYSTEM")
return dict(zip([_.name for _ in self.description],
self.fetchall()[0]))
def create_replication_slot(self, slot_name, slot_type=None, output_plugin=None): def create_replication_slot(self, slot_name, slot_type=None, output_plugin=None):
"""Create streaming replication slot.""" """Create streaming replication slot."""
@ -594,7 +587,7 @@ class ReplicationCursor(_cursor):
command += "%s %s" % (self.connection.quote_ident(k), _A(str(v))) command += "%s %s" % (self.connection.quote_ident(k), _A(str(v)))
command += ")" command += ")"
return self.start_replication_expert(command) self.start_replication_expert(command)
def send_feedback_message(self, written_lsn=0, sync_lsn=0, apply_lsn=0, reply_requested=False): def send_feedback_message(self, written_lsn=0, sync_lsn=0, apply_lsn=0, reply_requested=False):
return self.send_replication_feedback(written_lsn, sync_lsn, apply_lsn, reply_requested) return self.send_replication_feedback(written_lsn, sync_lsn, apply_lsn, reply_requested)