Method parseSqlInsert

rel/parse_sql.go:281–334

First keyword was INSERT, REPLACE

()

// First keyword was INSERT, REPLACE
func (m *Sqlbridge) parseSqlInsert() (*SqlInsert, error) {

	// insert into mytable (id, str) values (0, "a")
	req := NewSqlInsert()
	req.kw = m.Cur().T
	m.Next() // Consume Insert or Replace

	// INTO
	if m.Cur().T != lex.TokenInto {
		return nil, fmt.Errorf("expected INTO but got: %v", m.Cur())
	}
	m.Next() // Consume INTO

	// table name
	switch m.Cur().T {
	case lex.TokenTable:
		req.Table = m.Cur().V
		m.Next()
	default:
		return nil, fmt.Errorf("expected table name but got : %v", m.Cur().V)
	}

	// list of fields
	cols, err := m.parseFieldList()
	if err != nil {
		return nil, err
	}
	req.Columns = cols

	m.Next() // left paren starts lisf of values
	switch m.Cur().T {
	case lex.TokenValues:
		m.Next() // Consume Values keyword
	case lex.TokenSelect:
		sel, err := m.parseSqlSelect()
		if err != nil {
			return nil, err
		}
		if len(sel.From) == 0 {
			return nil, m.ErrMsg("Expected FROM <sources>")
		}
		req.Select = sel
		return req, nil
	default:
		return nil, m.ErrMsg("expected INSERT (columns) VALUES <values>")
	}

	colVals, err := m.parseValueList()
	if err != nil {
		return nil, err
	}
	req.Rows = colVals
	return req, nil
}

// First keyword was UPDATE
func (m *Sqlbridge) parseSqlUpdate() (*SqlUpdate, error) {