Kieran/route96
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: delete query

Browse Source
This commit is contained in:
kieran 2024-05-29 15:57:11 +01:00
parent 19e995ac16
commit 0c49738395
No known key found for this signature in database
GPG Key ID: DE71CEB3925BE941
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/db.rs
View File

@ -87,7 +87,8 @@ impl Database {
pub async fn add_file(&self, file: &FileUpload, user_id: u64) -> Result<(), Error> { pub async fn add_file(&self, file: &FileUpload, user_id: u64) -> Result<(), Error> {
let mut tx = self.pool.begin().await?; let mut tx = self.pool.begin().await?;
let q = sqlx::query("insert ignore into uploads(id,name,size,mime_type,blur_hash,width,height) values(?,?,?,?,?,?,?)") let q = sqlx::query("insert ignore into \
uploads(id,name,size,mime_type,blur_hash,width,height) values(?,?,?,?,?,?,?)")
.bind(&file.id) .bind(&file.id)
.bind(&file.name) .bind(&file.name)
.bind(file.size) .bind(file.size)
@ -122,7 +123,9 @@ impl Database {
} }
pub async fn get_file_owners(&self, file: &Vec<u8>) -> Result<Vec<User>, Error> { pub async fn get_file_owners(&self, file: &Vec<u8>) -> Result<Vec<User>, Error> {
sqlx::query_as("select users.* from users, user_uploads where user.id = user_uploads.user_id and user_uploads.file = ?") sqlx::query_as("select users.* from users, user_uploads \
where users.id = user_uploads.user_id \
and user_uploads.file = ?")
.bind(file) .bind(file)
.fetch_all(&self.pool) .fetch_all(&self.pool)
.await .await
@ -130,7 +133,8 @@ impl Database {
#[cfg(feature = "labels")] #[cfg(feature = "labels")]
pub async fn get_file_labels(&self, file: &Vec<u8>) -> Result<Vec<FileLabel>, Error> { pub async fn get_file_labels(&self, file: &Vec<u8>) -> Result<Vec<FileLabel>, Error> {
sqlx::query_as("select upload_labels.* from uploads, upload_labels where uploads.id = ? and uploads.id = upload_labels.file") sqlx::query_as("select upload_labels.* from uploads, upload_labels \
where uploads.id = ? and uploads.id = upload_labels.file")
.bind(file) .bind(file)
.fetch_all(&self.pool) .fetch_all(&self.pool)
.await .await