Function addBatch

server/controller/prometheus/encoder/db_operation.go:26–47

(db *metadb.DB, toAdd []*T, resourceType string)

)

func addBatch[T constraint.OperateBatchModel](db *metadb.DB, toAdd []*T, resourceType string) error {
	count := len(toAdd)
	offset := 1000
	pages := count/offset + 1
	if count%offset == 0 {
		pages = count / offset
	}
	for i := 0; i < pages; i++ {
		start := i * offset
		end := (i + 1) * offset
		if end > count {
			end = count
		}
		oneP := toAdd[start:end]
		err := db.Clauses(clause.Returning{}).Create(&oneP).Error
		if err != nil {
			return err
		}
		log.Infof("add %d %s success", len(oneP), resourceType, db.LogPrefixORGID)
	}
	return nil
}