Method Save

pkg/memory/logic/store_mysql.go:101–193

Save 保存或更新 Memory

(ctx context.Context, mem *LogicMemory)

// Save 保存或更新 Memory
func (s *MySQLStore) Save(ctx context.Context, mem *LogicMemory) error {
	if s.closed {
		return ErrStoreClosed
	}

	if mem.Namespace == "" {
		return ErrInvalidNamespace
	}

	// 序列化 Value
	valueJSON, err := json.Marshal(mem.Value)
	if err != nil {
		return NewStoreError("MARSHAL_ERROR", "failed to marshal value", err)
	}

	// 序列化 Metadata
	metadataJSON, err := json.Marshal(mem.Metadata)
	if err != nil {
		metadataJSON = []byte("{}")
	}

	// 处理 Provenance
	var sourceType string
	var confidence float64
	var sourcesJSON []byte
	var provenanceCreatedAt, provenanceUpdatedAt sql.NullTime
	var provenanceVersion int

	if mem.Provenance != nil {
		sourceType = string(mem.Provenance.SourceType)
		confidence = mem.Provenance.Confidence
		sourcesJSON, _ = json.Marshal(mem.Provenance.Sources)
		if !mem.Provenance.CreatedAt.IsZero() {
			provenanceCreatedAt = sql.NullTime{Time: mem.Provenance.CreatedAt, Valid: true}
		}
		if !mem.Provenance.UpdatedAt.IsZero() {
			provenanceUpdatedAt = sql.NullTime{Time: mem.Provenance.UpdatedAt, Valid: true}
		}
		provenanceVersion = mem.Provenance.Version
	} else {
		sourcesJSON = []byte("[]")
	}

	// 处理时间
	now := time.Now()
	if mem.CreatedAt.IsZero() {
		mem.CreatedAt = now
	}
	mem.UpdatedAt = now
	if mem.LastAccessed.IsZero() {
		mem.LastAccessed = now
	}

	query := fmt.Sprintf(`
		INSERT INTO %s (
			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