Method Prune

pkg/memory/logic/store_mysql.go:416–458

Prune 清理低价值 Memory

(ctx context.Context, criteria PruneCriteria)

// Prune 清理低价值 Memory
func (s *MySQLStore) Prune(ctx context.Context, criteria PruneCriteria) (int, error) {
	if s.closed {
		return 0, ErrStoreClosed
	}

	// 构建条件
	conditions := []string{}
	args := []any{}

	if criteria.MinConfidence > 0 {
		conditions = append(conditions, "confidence < ?")
		args = append(args, criteria.MinConfidence)
	}

	if criteria.SinceLastAccess > 0 {
		conditions = append(conditions, "last_accessed < ?")
		args = append(args, time.Now().Add(-criteria.SinceLastAccess))
	}

	if criteria.MinAccessCount > 0 && criteria.MaxAge > 0 {
		conditions = append(conditions, "(access_count < ? AND created_at < ?)")
		args = append(args, criteria.MinAccessCount, time.Now().Add(-criteria.MaxAge))
	}

	if len(conditions) == 0 {
		return 0, nil
	}

	query := fmt.Sprintf("DELETE FROM %s WHERE %s", s.tableName, conditions[0])
	var querySb443 strings.Builder
	for i := 1; i < len(conditions); i++ {
		querySb443.WriteString(" OR " + conditions[i])
	}
	query += querySb443.String()

	result, err := s.db.ExecContext(ctx, query, args...)
	if err != nil {
		return 0, NewStoreError("DELETE_ERROR", "failed to prune memories", err)
	}

	rowsAffected, _ := result.RowsAffected()
	return int(rowsAffected), nil
}

// Close 关闭存储
func (s *MySQLStore) Close() error {