Commit869920c

committed

Replace $1 notation in queries to %s as psycopg2 expects it

1 parent7594a7e commit869920cCopy full SHA for 869920c

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -210,7 +210,7 @@ def source_walsender(self):`
`210`	`210`	`sql="""`
`211`	`211`	`select pid`
`212`	`212`	`from pg_catalog.pg_stat_replication`
`213`		`- where application_name =$1`
	`213`	`+ where application_name =%s`
`214`	`214`	`"""`
`215`	`215`
`216`	`216`	`ifnotself.master:`
`@@ -322,7 +322,7 @@ def _create_recovery_conf(self, username, slot=None):`
`322`	`322`	`res=con.execute("""`
`323`	`323`	`select exists (`
`324`	`324`	`select from pg_catalog.pg_replication_slots`
`325`		`- where slot_name =$1`
	`325`	`+ where slot_name =%s`
`326`	`326`	`)`
`327`	`327`	`""",slot)`
`328`	`328`
`@@ -332,7 +332,7 @@ def _create_recovery_conf(self, username, slot=None):`
`332`	`332`
`333`	`333`	`# TODO: we should drop this slot after replica's cleanup()`
`334`	`334`	`con.execute("""`
`335`		`- select pg_catalog.pg_create_physical_replication_slot($1)`
	`335`	`+ select pg_catalog.pg_create_physical_replication_slot(%s)`
`336`	`336`	`""",slot)`
`337`	`337`
`338`	`338`	`line+="primary_slot_name={}\n".format(slot)`

Comments

(0)