Method parseMigration

runtime/parser/parse_migration.go:13–39

parseMigration parses a migration definition and adds the resulting resource to p.Resources.

(node *Node)

// parseMigration parses a migration definition and adds the resulting resource to p.Resources.
func (p *Parser) parseMigration(node *Node) error {
	// Parse YAML
	tmp := &MigrationYAML{}
	err := p.decodeNodeYAML(node, false, tmp)
	if err != nil {
		return err
	}

	// Add resource
	r, err := p.insertResource(ResourceKindMigration, node.Name, node.Paths, node.Refs...)
	if err != nil {
		return err
	}
	// NOTE: After calling insertResource, an error must not be returned. Any validation should be done before calling it.

	if node.Connector != "" {
		r.MigrationSpec.Connector = node.Connector
	}
	if node.SQL != "" {
		r.MigrationSpec.Sql = strings.TrimSpace(node.SQL)
	}
	if tmp.MaxVersion > 0 {
		r.MigrationSpec.Version = uint32(tmp.MaxVersion)
	}

	return nil
}