Method parseAlterConnectorStatement

pkg/sql/parser/alter.go:273–327

parseAlterConnectorStatement parses ALTER CONNECTOR statements

(stmt *ast.AlterStatement)

// parseAlterConnectorStatement parses ALTER CONNECTOR statements
func (p *Parser) parseAlterConnectorStatement(stmt *ast.AlterStatement) (*ast.AlterStatement, error) {
	stmt.Name = p.parseIdentAsString()
	if !p.matchType(models.TokenTypeSet) {
		return nil, p.expectedError("SET")
	}

	op := &ast.AlterConnectorOperation{}

	switch {
	case p.matchType(models.TokenTypeDcproperties):
		if !p.matchType(models.TokenTypeLParen) {
			return nil, p.expectedError("(")
		}
		op.Properties = make(map[string]string)
		for {
			// DCPROPERTIES keys are arbitrary user-defined names that may
			// coincide with SQL keywords (e.g. "key", "url").  Accept any
			// word-like token as a bare identifier here.
			key := p.parseBareWordAsString()
			if !p.matchType(models.TokenTypeEq) {
				return nil, p.expectedError("=")
			}
			value := p.parseStringLiteral()
			op.Properties[key] = value

			if !p.matchType(models.TokenTypeComma) {
				break
			}
		}
		if !p.matchType(models.TokenTypeRParen) {
			return nil, p.expectedError(")")
		}

	case p.matchType(models.TokenTypeUrl):
		op.URL = p.parseStringLiteral()

	case p.matchType(models.TokenTypeOwner):
		owner := &ast.AlterConnectorOwner{}
		if p.matchType(models.TokenTypeUser) {
			owner.IsUser = true
		} else if p.matchType(models.TokenTypeRole) {
			owner.IsUser = false
		} else {
			return nil, p.expectedError("USER or ROLE")
		}
		owner.Name = p.parseIdentAsString()
		op.Owner = owner

	default:
		return nil, p.expectedError("DCPROPERTIES, URL, or OWNER")
	}

	stmt.Operation = op
	return stmt, nil
}

// parseRoleOption parses a role option
func (p *Parser) parseRoleOption() (*ast.RoleOption, error) {