5 Commits

Author SHA1 Message Date
Adrian Zürcher
98094abf3e fix delete function 2025-11-07 08:17:48 +01:00
Adrian Zürcher
97a3ebf3a0 remove refelect 2025-11-07 08:04:01 +01:00
Adrian Zürcher
f59d3e9b1b fix existing function add reflect, slow but safe 2025-11-07 08:02:19 +01:00
Adrian Zürcher
14cb20f306 fix existing function add reflect, slow but safe 2025-11-07 08:01:50 +01:00
Adrian Zürcher
2b18549f02 fix exist function for array of values and error handling delete 2025-10-29 22:14:07 +01:00

View File

@@ -218,39 +218,22 @@ func (dH *DBHandler) UpdateValuesByKey(model any, key string, value any) error {
return dH.db.Model(lookUpModel).Updates(model).Error return dH.db.Model(lookUpModel).Updates(model).Error
} }
// deleteById
//
// Description:
//
// Deletes records by their ID(s).
//
// Behavior:
// - If the first ID == 0, all records in the table are deleted.
// - Otherwise, deletes the provided IDs.
//
// Parameters:
// - model: Model struct type representing the table.
// - id: Variadic list of IDs to delete.
//
// Returns:
// - error: Any deletion error.
func (dH *DBHandler) DeleteById(model any, ids ...uint) error { func (dH *DBHandler) DeleteById(model any, ids ...uint) error {
if len(ids) == 0 { if len(ids) == 0 {
return fmt.Errorf("no IDs provided") return fmt.Errorf("no IDs provided")
} }
if ids[0] == 0 { if len(ids) == 1 && ids[0] == 0 {
dH.logger.Debug("deleteById", "delete all") dH.logger.Debug("deleteById", "delete ALL records!")
return dH.db.Where("1 = 1").Delete(model).Error return dH.db.Session(&gorm.Session{AllowGlobalUpdate: true}).
Delete(model).Error
} }
dH.logger.Debug("deleteById", "delete ids "+fmt.Sprint(ids)) dH.logger.Debug("deleteById", "delete ids "+fmt.Sprint(ids))
// Always use Model() to avoid GORMs “limit 1” safeguard if err := dH.db.Delete(model, ids).Error; err != nil {
if err := dH.db.Model(model).Where("id IN ?", ids).Delete(nil).Error; err != nil {
return fmt.Errorf("delete failed: %w", err) return fmt.Errorf("delete failed: %w", err)
} }
return nil return nil
} }
@@ -282,53 +265,40 @@ func (dH *DBHandler) DeleteByKey(model any, key string, value any, LikeSearch bo
return dH.db.Where(key+" = ?", value).Delete(model).Error return dH.db.Where(key+" = ?", value).Delete(model).Error
} }
// exists func (dH *DBHandler) Exists(model any, key string, value any, likeSearch bool) (found bool) {
//
// Description:
//
// Checks whether a record exists matching the specified key/value filter.
//
// Behavior:
// - Performs a `First` query on the database.
// - If `LikeSearch` is true, performs a LIKE query.
// - Returns an error if the record does not exist or query fails.
//
// Parameters:
// - model: Model struct type to search.
// - key: Column name to filter by.
// - value: Value to match.
// - LikeSearch: Whether to use wildcard search.
//
// Returns:
// - error: “no record found” or DB error.
func (dH *DBHandler) Exists(model any, key string, value any, likeSearch bool) (err error) {
var query string var query string
var args any
switch v := value.(type) { // Detect LIKE and IN behavior
case []string, []int, []uint, []int64, []uint64, []float64: val := reflect.ValueOf(value)
// Handle slice case — use IN clause isSlice := val.Kind() == reflect.Slice
switch {
case isSlice:
if val.Len() == 0 {
dH.logger.Error("Exists", fmt.Sprintf("empty slice for %s", key))
return false
}
query = fmt.Sprintf("%s IN ?", key) query = fmt.Sprintf("%s IN ?", key)
case string: args = value
if likeSearch {
v = strings.ReplaceAll(v, "*", "%") case likeSearch:
str := strings.ReplaceAll(fmt.Sprint(value), "*", "%")
query = fmt.Sprintf("%s LIKE ?", key) query = fmt.Sprintf("%s LIKE ?", key)
value = v args = str
} else {
query = fmt.Sprintf("%s = ?", key)
}
default: default:
// Handle any other single value (numbers, bools, etc.)
query = fmt.Sprintf("%s = ?", key) query = fmt.Sprintf("%s = ?", key)
args = value
} }
dH.logger.Debug("exists", "check if exists key "+query+" value "+fmt.Sprint(value)) dH.logger.Debug("exists", "checking existence for key "+query+" value "+fmt.Sprint(args))
err = dH.db.Where(query, value).First(model).Error tx := dH.db.Where(query, args).Find(model)
if errors.Is(err, gorm.ErrRecordNotFound) {
return fmt.Errorf("no record found for %s %v", key, value) if tx.Error != nil {
} else if err != nil { dH.logger.Error("Exists", fmt.Sprintf("query failed: %v", tx.Error))
return fmt.Errorf("query failed: %w", err) return false
} }
return tx.RowsAffected > 0
return nil
} }