Skip to content

Commit e61db57

Browse files
committed
Add dbname=replication for physical replication type.
1 parent fbcf99a commit e61db57

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

psycopg/replication_connection_type.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,10 @@ replicationConnection_init(PyObject *obj, PyObject *args, PyObject *kwargs)
110110
if (!PyMapping_HasKeyString(kwargs, "replication")) {
111111
PyMapping_SetItemString(kwargs, "replication", Text_FromUTF8(repl));
112112
}
113+
/* with physical specify dbname=replication for .pgpass lookup */
114+
if (self->type == REPLICATION_PHYSICAL) {
115+
PyMapping_SetItemString(kwargs, "dbname", Text_FromUTF8("replication"));
116+
}
113117

114118
Py_DECREF(dsn);
115119
if (!(dsn = psyco_make_dsn(NULL, NULL, kwargs))) { goto exit; }

0 commit comments

Comments
 (0)