Method interpolateParams

connection.go:248–431

(query string, args []driver.Value)

}

func (mc *mysqlConn) interpolateParams(query string, args []driver.Value) (string, error) {
	noBackslashEscapes := (mc.status & statusNoBackslashEscapes) != 0
	const (
		stateNormal = iota
		stateString
		stateEscape
		stateEOLComment
		stateSlashStarComment
		stateBacktick
	)

	const (
		QUOTE_BYTE         = byte('\'')
		DBL_QUOTE_BYTE     = byte('"')
		BACKSLASH_BYTE     = byte('\\')
		QUESTION_MARK_BYTE = byte('?')
		SLASH_BYTE         = byte('/')
		STAR_BYTE          = byte('*')
		HASH_BYTE          = byte('#')
		MINUS_BYTE         = byte('-')
		LINE_FEED_BYTE     = byte('\n')
		BACKTICK_BYTE      = byte('`')
	)

	buf, err := mc.buf.takeCompleteBuffer()
	if err != nil {
		mc.cleanup()
		return "", driver.ErrBadConn
	}
	buf = buf[:0]
	state := stateNormal
	singleQuotes := false
	lastChar := byte(0)
	argPos := 0
	lenQuery := len(query)
	lastIdx := 0

	for i := range lenQuery {
		currentChar := query[i]
		if state == stateEscape && !((currentChar == QUOTE_BYTE && singleQuotes) || (currentChar == DBL_QUOTE_BYTE && !singleQuotes)) {
			state = stateString
			lastChar = currentChar
			continue
		}
		switch currentChar {
		case STAR_BYTE:
			if state == stateNormal && lastChar == SLASH_BYTE {
				state = stateSlashStarComment
			}
		case SLASH_BYTE:
			if state == stateSlashStarComment && lastChar == STAR_BYTE {
				state = stateNormal
				// Clear lastChar so the '/' that closed the comment isn't
				// reused to start a new comment with a following '*'.
				lastChar = 0
				continue
			}
		case HASH_BYTE: