Method List

pkg/memory/logic/store_mysql.go:225–298

List 列出符合条件的 Memory

(ctx context.Context, namespace string, filters ...Filter)

// List 列出符合条件的 Memory
func (s *MySQLStore) List(ctx context.Context, namespace string, filters ...Filter) ([]*LogicMemory, error) {
	if s.closed {
		return nil, ErrStoreClosed
	}

	opts := ApplyFilters(filters...)

	// 构建查询
	query := fmt.Sprintf(`
		SELECT id, namespace, scope, type, category, `+"`key`"+`, value, description,
			source_type, confidence, sources, provenance_created_at, provenance_updated_at, provenance_version,
			access_count, last_accessed, metadata, created_at, updated_at
		FROM %s
		WHERE 1=1
	`, s.tableName)

	args := []any{}

	if namespace != "" {
		query += " AND namespace = ?"
		args = append(args, namespace)
	}

	if opts.Type != "" {
		query += " AND type = ?"
		args = append(args, opts.Type)
	}

	if opts.Scope != "" {
		query += " AND scope = ?"
		args = append(args, opts.Scope)
	}

	if opts.MinConfidence > 0 {
		query += " AND confidence >= ?"
		args = append(args, opts.MinConfidence)
	}

	// 排序
	switch opts.OrderBy {
	case OrderByConfidence:
		query += " ORDER BY confidence DESC"
	case OrderByLastAccessed:
		query += " ORDER BY last_accessed DESC"
	case OrderByCreatedAt:
		query += " ORDER BY created_at DESC"
	case OrderByAccessCount:
		query += " ORDER BY access_count DESC"
	default:
		query += " ORDER BY confidence DESC"
	}

	// 限制数量
	if opts.MaxResults > 0 {
		query += fmt.Sprintf(" LIMIT %d", opts.MaxResults)
	}

	rows, err := s.db.QueryContext(ctx, query, args...)