mirror of
https://github.com/neondatabase/neon.git
synced 2026-05-28 10:30:40 +00:00
fix query usage
This commit is contained in:
@@ -1053,21 +1053,19 @@ LIMIT 100",
|
||||
}
|
||||
});
|
||||
let result = client
|
||||
.query(
|
||||
.batch_execute(&format!(
|
||||
"BEGIN;
|
||||
ALTER TABLE $1 ENABLE ROW LEVEL SECURITY;
|
||||
CREATE USER $2 WITH PASSWORD $3 IN GROUP $4;
|
||||
CREATE POLICY neon_row_level ON $1 TO $4
|
||||
USING ($5 = current_user);
|
||||
COMMIT;",
|
||||
&[
|
||||
¶ms.table_name,
|
||||
¶ms.user_name,
|
||||
¶ms.password,
|
||||
¶ms.role,
|
||||
¶ms.column_name,
|
||||
],
|
||||
)
|
||||
ALTER TABLE {0} ENABLE ROW LEVEL SECURITY;
|
||||
CREATE USER {1} WITH PASSWORD '{2}' IN GROUP {3};
|
||||
CREATE POLICY neon_row_level ON {0} TO {3}
|
||||
USING ({4} = current_user);
|
||||
COMMIT;",
|
||||
¶ms.table_name,
|
||||
¶ms.user_name,
|
||||
¶ms.password,
|
||||
¶ms.role,
|
||||
¶ms.column_name,
|
||||
))
|
||||
.await;
|
||||
Ok(result.is_ok())
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user