paadi/dbHandler
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add relation to delete

Browse Source
This commit is contained in:
Adrian Zürcher
2025-11-19 22:49:22 +01:00
parent 2bcd8a5a08
commit 4f803b47a7
1 changed files with 25 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
dbHandler.go
View File

@@ -251,6 +251,7 @@ func (dH *DBHandler) UpdateValuesByKey(model any, relation string, key string, v
if err := dH.GetByKey(lookUpModel, "", key, value, false); err != nil { if err := dH.GetByKey(lookUpModel, "", key, value, false); err != nil {
return err return err
} }
query := dH.db query := dH.db
if relation != "" { if relation != "" {
@@ -259,7 +260,7 @@ func (dH *DBHandler) UpdateValuesByKey(model any, relation string, key string, v
return query.Model(lookUpModel).Updates(model).Error return query.Model(lookUpModel).Updates(model).Error
} }
func (dH *DBHandler) DeleteById(model any, ids ...uint) error { func (dH *DBHandler) DeleteById(model any, relation string, ids ...uint) error {
if len(ids) == 0 { if len(ids) == 0 {
return fmt.Errorf("no IDs provided") return fmt.Errorf("no IDs provided")
} }
@@ -272,7 +273,13 @@ func (dH *DBHandler) DeleteById(model any, ids ...uint) error {
dH.logger.Debug("deleteById", "delete ids "+fmt.Sprint(ids)) dH.logger.Debug("deleteById", "delete ids "+fmt.Sprint(ids))
if err := dH.db.Delete(model, ids).Error; err != nil { query := dH.db
if relation != "" {
query = query.Preload(relation)
}
if err := query.Delete(model, ids).Error; err != nil {
return fmt.Errorf("delete failed: %w", err) return fmt.Errorf("delete failed: %w", err)
} }
return nil return nil
@@ -295,7 +302,7 @@ func (dH *DBHandler) DeleteById(model any, ids ...uint) error {
// //
// Returns: // Returns:
// - error: Any deletion error. // - error: Any deletion error.
func (dH *DBHandler) DeleteByKey(model any, key string, value any, LikeSearch bool) error { func (dH *DBHandler) DeleteByKey(model any, relation string, key string, value any, LikeSearch bool) error {
if LikeSearch { if LikeSearch {
value = strings.ReplaceAll(fmt.Sprint(value), "*", "%") value = strings.ReplaceAll(fmt.Sprint(value), "*", "%")
dH.logger.Debug("deleteByKey", "delete like key "+key+" value "+fmt.Sprint(value)) dH.logger.Debug("deleteByKey", "delete like key "+key+" value "+fmt.Sprint(value))
@@ -303,10 +310,17 @@ func (dH *DBHandler) DeleteByKey(model any, key string, value any, LikeSearch bo
} }
dH.logger.Debug("deleteByKey", "delete equal key "+key+" value "+fmt.Sprint(value)) dH.logger.Debug("deleteByKey", "delete equal key "+key+" value "+fmt.Sprint(value))
return dH.db.Where(key+" = ?", value).Delete(model).Error
query := dH.db
if relation != "" {
query = query.Preload(relation)
} }
func (dH *DBHandler) Exists(model any, key string, value any, likeSearch bool) (found bool) { return query.Where(key+" = ?", value).Delete(model).Error
}
func (dH *DBHandler) Exists(model any, relation string, key string, value any, likeSearch bool) (found bool) {
var query string var query string
var args any var args any
@@ -335,7 +349,12 @@ func (dH *DBHandler) Exists(model any, key string, value any, likeSearch bool) (
dH.logger.Debug("exists", "checking existence for key "+query+" value "+fmt.Sprint(args)) dH.logger.Debug("exists", "checking existence for key "+query+" value "+fmt.Sprint(args))
tx := dH.db.Where(query, args).Find(model) datababase := dH.db
if relation != "" {
datababase = datababase.Preload(relation)
}
tx := datababase.Where(query, args).Find(model)
if tx.Error != nil { if tx.Error != nil {
dH.logger.Error("Exists", fmt.Sprintf("query failed: %v", tx.Error)) dH.logger.Error("Exists", fmt.Sprintf("query failed: %v", tx.Error))