in shardingsphere-operator/pkg/distsql/visitor_parser/read_write_splitting/rdlstatement_parser.go [395:464]
func (p *RDLStatementParser) CreateReadwriteSplittingRule() (localctx ICreateReadwriteSplittingRuleContext) {
localctx = NewCreateReadwriteSplittingRuleContext(p, p.GetParserRuleContext(), p.GetState())
p.EnterRule(localctx, 0, RDLStatementParserRULE_createReadwriteSplittingRule)
var _la int
defer func() {
p.ExitRule()
}()
defer func() {
if err := recover(); err != nil {
if v, ok := err.(antlr.RecognitionException); ok {
localctx.SetException(v)
p.GetErrorHandler().ReportError(p, v)
p.GetErrorHandler().Recover(p, v)
} else {
panic(err)
}
}
}()
p.EnterOuterAlt(localctx, 1)
{
p.SetState(48)
p.Match(RDLStatementParserCREATE)
}
{
p.SetState(49)
p.Match(RDLStatementParserREADWRITE_SPLITTING)
}
{
p.SetState(50)
p.Match(RDLStatementParserRULE)
}
p.SetState(52)
p.GetErrorHandler().Sync(p)
_la = p.GetTokenStream().LA(1)
if _la == RDLStatementParserIF {
{
p.SetState(51)
p.IfNotExists()
}
}
{
p.SetState(54)
p.ReadwriteSplittingRuleDefinition()
}
p.SetState(59)
p.GetErrorHandler().Sync(p)
_la = p.GetTokenStream().LA(1)
for _la == RDLStatementParserCOMMA_ {
{
p.SetState(55)
p.Match(RDLStatementParserCOMMA_)
}
{
p.SetState(56)
p.ReadwriteSplittingRuleDefinition()
}
p.SetState(61)
p.GetErrorHandler().Sync(p)
_la = p.GetTokenStream().LA(1)
}
return localctx
}