diff --git a/src/pallet/crate/postgres.clj b/src/pallet/crate/postgres.clj index c7a4144..ecb16f5 100644 --- a/src/pallet/crate/postgres.clj +++ b/src/pallet/crate/postgres.clj @@ -621,7 +621,8 @@ END$$;" "create or replace function pg_temp.createuser() returns void as $$ declare user_rec record; begin - if user_rec.usename is null then + select into user_rec * from pg_roles where rolname='%1$s'; + if user_rec.rolname is null then create role %1$s %2$s; end if; end;