Method scanOneStmt

postgres/parser/parser/parse.go:132–172

(parse func(sqlStr string, tokens []sqlSymType) error)

}

func (p *Parser) scanOneStmt(parse func(sqlStr string, tokens []sqlSymType) error) bool {
	var lval sqlSymType
	tokens := p.tokBuf[:0]

	// Scan the first token.
	for {
		p.scanner.scan(&lval)
		if lval.id == 0 {
			return true
		}
		if lval.id != ';' {
			break
		}
	}

	startPos := lval.pos
	// We make the resulting token positions match the returned string.
	lval.pos = 0
	tokens = append(tokens, lval)
	for {
		if lval.id == ERROR {
			_ = parse(p.scanner.in[startPos:], tokens)
			return true
		}
		posBeforeScan := p.scanner.pos
		p.scanner.scan(&lval)
		if lval.id == 0 || lval.id == ';' {
			err := parse(p.scanner.in[startPos:posBeforeScan], tokens)
			if lval.id == 0 || (err != nil && !strings.Contains(err.Error(), "EOF")) {
				// done scanning all statements OR due to non EOF error
				return true
			} else if err == nil {
				// done scanning single statement
				return false
			}
			// continue scanning if it's EOF error
		}
		lval.pos -= startPos
		tokens = append(tokens, lval)
	}
}

func (p *Parser) parseWithDepth(depth int, sql string, nakedIntType *types.T) (Statements, error) {
	stmts := Statements(p.stmtBuf[:0])