Method List

pkg/memory/logic/store_postgres.go:231–309

List 列出符合条件的 Memory

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

// List 列出符合条件的 Memory
func (s *PostgreSQLStore) 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{}
	argIndex := 1

	if namespace != "" {
		query += fmt.Sprintf(" AND namespace = $%d", argIndex)
		args = append(args, namespace)
		argIndex++
	}

	if opts.Type != "" {
		query += fmt.Sprintf(" AND type = $%d", argIndex)
		args = append(args, opts.Type)
		argIndex++
	}

	if opts.Scope != "" {
		query += fmt.Sprintf(" AND scope = $%d", argIndex)
		args = append(args, opts.Scope)
		argIndex++
	}

	if opts.MinConfidence > 0 {
		query += fmt.Sprintf(" AND confidence >= $%d", argIndex)
		args = append(args, opts.MinConfidence)
		// argIndex++ 不需要，后续没有使用
	}

	// 排序
	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"
	}

	// 限制数量