Function NewMySQLStore

pkg/memory/logic/store_mysql.go:35–62

NewMySQLStore 创建 MySQL 存储

(config *MySQLStoreConfig)

// NewMySQLStore 创建 MySQL 存储
func NewMySQLStore(config *MySQLStoreConfig) (*MySQLStore, error) {
	if config == nil {
		return nil, errors.New("config is required")
	}

	if config.DB == nil {
		return nil, errors.New("database connection is required")
	}

	tableName := config.TableName
	if tableName == "" {
		tableName = "logic_memories"
	}

	store := &MySQLStore{
		db:        config.DB,
		tableName: tableName,
	}

	// 自动创建表
	if config.AutoMigrate {
		if err := store.migrate(); err != nil {
			return nil, fmt.Errorf("failed to migrate: %w", err)
		}
	}

	return store, nil
}

// migrate 创建表结构
func (s *MySQLStore) migrate() error {