Method scanMemory

pkg/memory/logic/store_mysql.go:467–536

scanMemory 从单行扫描 Memory

(row *sql.Row)

// scanMemory 从单行扫描 Memory
func (s *MySQLStore) scanMemory(row *sql.Row) (*LogicMemory, error) {
	mem := &LogicMemory{}
	var valueJSON, metadataJSON, sourcesJSON []byte
	var sourceType sql.NullString
	var confidence float64
	var provenanceCreatedAt, provenanceUpdatedAt sql.NullTime
	var provenanceVersion int
	var category sql.NullString
	var description sql.NullString
	var lastAccessed sql.NullTime

	err := row.Scan(
		&mem.ID, &mem.Namespace, &mem.Scope, &mem.Type, &category, &mem.Key, &valueJSON, &description,
		&sourceType, &confidence, &sourcesJSON, &provenanceCreatedAt, &provenanceUpdatedAt, &provenanceVersion,
		&mem.AccessCount, &lastAccessed, &metadataJSON, &mem.CreatedAt, &mem.UpdatedAt,
	)

	if err == sql.ErrNoRows {
		return nil, ErrMemoryNotFound
	}
	if err != nil {
		return nil, NewStoreError("SCAN_ERROR", "failed to scan memory", err)
	}

	// 反序列化
	if len(valueJSON) > 0 {
		if err := json.Unmarshal(valueJSON, &mem.Value); err != nil {
			return nil, NewStoreError("UNMARSHAL_ERROR", "failed to unmarshal value", err)
		}
	}
	if len(metadataJSON) > 0 {
		if err := json.Unmarshal(metadataJSON, &mem.Metadata); err != nil {
			// metadata 反序列化失败不是致命错误，使用空 map
			mem.Metadata = make(map[string]any)
		}
	}

	if category.Valid {
		mem.Category = category.String
	}
	if description.Valid {
		mem.Description = description.String
	}
	if lastAccessed.Valid {
		mem.LastAccessed = lastAccessed.Time
	}

	// 构建 Provenance
	if sourceType.Valid {
		var sources []string
		if len(sourcesJSON) > 0 {
			_ = json.Unmarshal(sourcesJSON, &sources) // sources 反序列化失败使用空切片
		}

		mem.Provenance = &memory.MemoryProvenance{
			SourceType: memory.SourceType(sourceType.String),
			Confidence: confidence,
			Sources:    sources,