Skip to content

Commit

Permalink
feat: select columns explicitly (#102)
Browse files Browse the repository at this point in the history
  • Loading branch information
byrnedo authored Jan 8, 2025
1 parent 55f53cc commit 9707f2b
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 19 deletions.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

39 changes: 24 additions & 15 deletions src/actions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -593,30 +593,39 @@ pub async fn remove_filtered_policy(

#[cfg(feature = "postgres")]
pub(crate) async fn load_policy(conn: &ConnectionPool) -> Result<Vec<CasbinRule>> {
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(CasbinRule, "SELECT * FROM casbin_rule")
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 FROM casbin_rule"
)
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;

Ok(casbin_rule)
}

#[cfg(feature = "sqlite")]
pub(crate) async fn load_policy(conn: &ConnectionPool) -> Result<Vec<CasbinRule>> {
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(CasbinRule, "SELECT * FROM casbin_rule")
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 FROM casbin_rule"
)
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;

Ok(casbin_rule)
}

#[cfg(feature = "mysql")]
pub(crate) async fn load_policy(conn: &ConnectionPool) -> Result<Vec<CasbinRule>> {
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(CasbinRule, "SELECT * FROM casbin_rule")
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;
let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 FROM casbin_rule"
)
.fetch_all(conn)
.await
.map_err(|err| CasbinError::from(AdapterError(Box::new(Error::SqlxError(err)))))?;

Ok(casbin_rule)
}
Expand All @@ -630,7 +639,7 @@ pub(crate) async fn load_filtered_policy<'a>(

let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT * from casbin_rule WHERE (
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 from casbin_rule WHERE (
ptype LIKE 'g%' AND v0 LIKE $1 AND v1 LIKE $2 AND v2 LIKE $3 AND v3 LIKE $4 AND v4 LIKE $5 AND v5 LIKE $6 )
OR (
ptype LIKE 'p%' AND v0 LIKE $7 AND v1 LIKE $8 AND v2 LIKE $9 AND v3 LIKE $10 AND v4 LIKE $11 AND v5 LIKE $12 );
Expand All @@ -653,7 +662,7 @@ pub(crate) async fn load_filtered_policy<'a>(

let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT * from casbin_rule WHERE (
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 from casbin_rule WHERE (
ptype LIKE 'g%' AND v0 LIKE $1 AND v1 LIKE $2 AND v2 LIKE $3 AND v3 LIKE $4 AND v4 LIKE $5 AND v5 LIKE $6 )
OR (
ptype LIKE 'p%' AND v0 LIKE $7 AND v1 LIKE $8 AND v2 LIKE $9 AND v3 LIKE $10 AND v4 LIKE $11 AND v5 LIKE $12 );
Expand All @@ -676,7 +685,7 @@ pub(crate) async fn load_filtered_policy<'a>(

let casbin_rule: Vec<CasbinRule> = sqlx::query_as!(
CasbinRule,
"SELECT * from casbin_rule WHERE (
"SELECT id, ptype, v0, v1, v2, v3, v4, v5 from casbin_rule WHERE (
ptype LIKE 'g%' AND v0 LIKE ? AND v1 LIKE ? AND v2 LIKE ? AND v3 LIKE ? AND v4 LIKE ? AND v5 LIKE ? )
OR (
ptype LIKE 'p%' AND v0 LIKE ? AND v1 LIKE ? AND v2 LIKE ? AND v3 LIKE ? AND v4 LIKE ? AND v5 LIKE ? );
Expand Down

0 comments on commit 9707f2b

Please sign in to comment.