migrate to 1.25.3
This commit is contained in:
@@ -144,6 +144,9 @@ func (s *ShareTheBrutality) Processing(sender map[string]string) []model.Externa
|
||||
entries = append(entries, es)
|
||||
}
|
||||
|
||||
fmt.Println(entries)
|
||||
//os.Exit(0)
|
||||
|
||||
result, status := _table.BatchInsertOnDuplicate(entries, s.db, columns)
|
||||
if status != constant.StatusFailed {
|
||||
entriesBatched = append(entriesBatched, result...)
|
||||
|
||||
@@ -70,6 +70,7 @@ func (f *ExternalSources) GetTypeIds(entries []model.ExternalSources, db *sqlx.D
|
||||
var typeIds []int
|
||||
ids := thither.FieldValueToStrSlice(entries, "TypeId")
|
||||
query := fmt.Sprintf("SELECT type_id FROM %s WHERE `type` = '%s' AND type_id IN (%s) LIMIT %d", constant.ExternalSourcesTable, entries[0].Type, strings.Join(ids, ","), len(ids))
|
||||
fmt.Println(query)
|
||||
err := db.Select(&typeIds, query)
|
||||
if err != nil {
|
||||
slog.Error("getting type ids", "err", err)
|
||||
|
||||
Reference in New Issue
Block a user