Compare commits

...

2 Commits

Author SHA1 Message Date
Sasha Krassovsky
36b8bb89d3 Add migration that gives REPLICATION again 2024-03-27 11:38:07 -07:00
Sasha Krassovsky
7fac6e954a Revert "Revert "Revoke REPLICATION" (#7261)"
This reverts commit 24c5a5ac16.
2024-03-27 11:29:46 -07:00
2 changed files with 25 additions and 3 deletions

View File

@@ -806,8 +806,30 @@ $$;"#,
"",
"",
"",
"",
// Add new migrations below.
r#"
DO $$
DECLARE
role_name TEXT;
BEGIN
FOR role_name IN SELECT rolname FROM pg_roles WHERE rolreplication IS TRUE
LOOP
RAISE NOTICE 'EXECUTING ALTER ROLE % NOREPLICATION', quote_ident(role_name);
EXECUTE 'ALTER ROLE ' || quote_ident(role_name) || ' NOREPLICATION';
END LOOP;
END
$$;"#,
r#"
DO $$
DECLARE
role_name TEXT;
BEGIN
FOR role_name IN SELECT rolname FROM pg_roles WHERE pg_has_role(rolname, 'neon_superuser', 'member')
LOOP
RAISE NOTICE 'EXECUTING ALTER ROLE % REPLICATION', quote_ident(role_name);
EXECUTE 'ALTER ROLE ' || quote_ident(role_name) || ' REPLICATION';
END LOOP;
END
$$;"#,
];
let mut query = "CREATE SCHEMA IF NOT EXISTS neon_migration";

View File

@@ -15,7 +15,7 @@ def test_migrations(neon_simple_env: NeonEnv):
endpoint.wait_for_migrations()
num_migrations = 9
num_migrations = 10
with endpoint.cursor() as cur:
cur.execute("SELECT id FROM neon_migration.migration_id")