Method GetStats

pkg/memory/logic/store_mysql.go:342–413

GetStats 获取统计信息

(ctx context.Context, namespace string)

// GetStats 获取统计信息
func (s *MySQLStore) GetStats(ctx context.Context, namespace string) (*MemoryStats, error) {
	if s.closed {
		return nil, ErrStoreClosed
	}

	stats := &MemoryStats{
		CountByType:  make(map[string]int),
		CountByScope: make(map[MemoryScope]int),
	}

	// 总数和平均置信度
	query := fmt.Sprintf(`
		SELECT COUNT(*), COALESCE(AVG(confidence), 0), COALESCE(MAX(updated_at), NOW())
		FROM %s
		WHERE (? = '' OR namespace = ?)
	`, s.tableName)

	var lastUpdated time.Time
	err := s.db.QueryRowContext(ctx, query, namespace, namespace).Scan(&stats.TotalCount, &stats.AverageConfidence, &lastUpdated)
	if err != nil {
		return nil, NewStoreError("QUERY_ERROR", "failed to get stats", err)
	}
	stats.LastUpdated = lastUpdated

	// 按类型统计
	query = fmt.Sprintf(`
		SELECT type, COUNT(*)
		FROM %s
		WHERE (? = '' OR namespace = ?)
		GROUP BY type
	`, s.tableName)

	rows, err := s.db.QueryContext(ctx, query, namespace, namespace)
	if err != nil {
		return nil, NewStoreError("QUERY_ERROR", "failed to get type stats", err)
	}
	defer func() { _ = rows.Close() }()

	for rows.Next() {
		var memType string
		var count int
		if err := rows.Scan(&memType, &count); err != nil {
			continue
		}
		stats.CountByType[memType] = count
	}

	// 按作用域统计
	query = fmt.Sprintf(`
		SELECT scope, COUNT(*)
		FROM %s
		WHERE (? = '' OR namespace = ?)
		GROUP BY scope
	`, s.tableName)

	rows, err = s.db.QueryContext(ctx, query, namespace, namespace)
	if err != nil {
		return nil, NewStoreError("QUERY_ERROR", "failed to get scope stats", err)