Method parseSourceJoin

rel/parse_sql.go:1264–1300

(src *SqlSource)

}

func (m *Sqlbridge) parseSourceJoin(src *SqlSource) error {

	switch m.Cur().T {
	case lex.TokenLeft, lex.TokenRight:
		src.LeftOrRight = m.Cur().T
		m.Next()
	}

	// Optional Inner/Outer
	switch m.Cur().T {
	case lex.TokenInner, lex.TokenOuter:
		src.JoinType = m.Cur().T
		m.Next()
	}

	if m.Cur().T == lex.TokenJoin {
		m.Next() // Consume join keyword
	} else {
		return m.ErrMsg("Requires join")
	}

	switch m.Cur().T {
	case lex.TokenLeftParenthesis:
		// SELECT [columns] FROM [table] AS t1
		//   INNER JOIN (select a,b,c from users WHERE d is not null) u ON u.user_id = t1.user_id
		if err := m.parseSourceSubQuery(src); err != nil {
			return err
		}
	case lex.TokenIdentity:
		// Name of table
		src.Name = m.Cur().V
		m.Next()
	default:
		return m.ErrMsg("unrecognized kw in join")
	}
	return nil
}

func (m *Sqlbridge) parseInto(req *SqlSelect) error {