Function parseSubscriptionSQL

pgserver/subscription_handler.go:72–110

ParseSubscriptionSQL parses the given SQL statement and returns a SubscriptionConfig.

(sql string)

// ParseSubscriptionSQL parses the given SQL statement and returns a SubscriptionConfig.
func parseSubscriptionSQL(sql string) (*SubscriptionConfig, error) {
	var config SubscriptionConfig
	switch {
	case createRegex.MatchString(sql):
		matches := createRegex.FindStringSubmatch(sql)
		config.Action = Create
		config.SubscriptionName = matches[1]
		if len(matches) > 3 {
			config.PublicationName = matches[3]
		}
		conn, err := parseConnectionString(matches[2])
		if err != nil {
			return nil, err
		}
		config.Connection = conn

	case alterRegex.MatchString(sql):
		matches := alterRegex.FindStringSubmatch(sql)
		config.SubscriptionName = matches[1]
		switch strings.ToUpper(matches[2]) {
		case string(AlterDisable):
			config.Action = AlterDisable
		case string(AlterEnable):
			config.Action = AlterEnable
		default:
			return nil, fmt.Errorf("invalid ALTER SUBSCRIPTION action: %s", matches[2])
		}

	case dropRegex.MatchString(sql):
		matches := dropRegex.FindStringSubmatch(sql)
		config.Action = Drop
		config.SubscriptionName = matches[1]

	default:
		return nil, nil
	}

	return &config, nil
}

// parseConnectionString parses the given connection string and returns a ConnectionDetails.
func parseConnectionString(connStr string) (*ConnectionDetails, error) {