Function SqlSourceFromPb

rel/sql.go:1662–1693

(pb *SqlSourcePb)

	return &s
}
func SqlSourceFromPb(pb *SqlSourcePb) *SqlSource {
	s := SqlSource{
		final:       pb.GetFinal(),
		alias:       pb.GetAliasInner(),
		colIndex:    MapIntFromPb(pb.GetColIndex()),
		joinNodes:   expr.NodesFromNodesPbPtr(pb.GetJoinNodes()),
		Raw:         pb.GetRaw(),
		Name:        pb.GetName(),
		Alias:       pb.GetAlias(),
		Op:          lex.TokenType(pb.GetOp()),
		LeftOrRight: lex.TokenType(pb.GetLeftOrRight()),
		JoinType:    lex.TokenType(pb.GetJoinType()),
		JoinExpr:    expr.NodeFromNodePb(pb.GetJoinExpr()),
		Seekable:    pb.GetSeekable(),
	}
	if pb.Source != nil {
		s.Source = SqlSelectFromPb(pb.Source)
	} else {
		//u.Debugf("no source for SqlSource? %+v", pb)
	}
	if pb.SubQuery != nil {
		s.SubQuery = SqlSelectFromPb(pb.SubQuery)
	}
	if len(pb.Columns) > 0 {
		s.cols = make(map[string]*Column, len(pb.Columns))
		for _, pbc := range pb.Columns {
			col := columnFromPb(pbc)
			s.cols[col.As] = col
		}
	}
	return &s
}

func (m *SqlWhere) Keyword() lex.TokenType { return m.Op }
func (m *SqlWhere) writeDialectDepth(depth int, w expr.DialectWriter) {