Method HandleQuery

cmd/cql-mysql-adapter/cursor.go:295–339

HandleQuery handle COM_QUERY comamnd, like SELECT, INSERT, UPDATE, etc... if Result has a Resultset (SELECT, SHOW, etc...), we will send this as the response, otherwise, we will send Result.

(query string)

// HandleQuery handle COM_QUERY comamnd, like SELECT, INSERT, UPDATE, etc...
// if Result has a Resultset (SELECT, SHOW, etc...), we will send this as the response, otherwise, we will send Result.
func (c *Cursor) HandleQuery(query string) (r *my.Result, err error) {
	var processed bool

	log.WithField("query", query).Info("received query")

	if r, processed, err = c.handleSpecialQuery(query); processed {
		return
	}

	var conn *sql.DB

	if conn, err = c.ensureDatabase(); err != nil {
		return
	}

	// as normal query
	if readQuery.MatchString(query) {
		var rows *sql.Rows
		if rows, err = conn.Query(query); err != nil {
			err = my.NewError(my.ER_UNKNOWN_ERROR, err.Error())
			return
		}

		// build result set
		return c.buildResultSet(rows)
	}

	var result sql.Result
	if result, err = conn.Exec(query); err != nil {
		err = my.NewError(my.ER_UNKNOWN_ERROR, err.Error())
		return
	}

	lastInsertID, _ := result.LastInsertId()
	affectedRows, _ := result.RowsAffected()

	r = &my.Result{
		Status:       0,
		InsertId:     uint64(lastInsertID),
		AffectedRows: uint64(affectedRows),
		Resultset:    nil,
	}

	return
}

// HandleFieldList handle COM_FILED_LIST command.
func (c *Cursor) HandleFieldList(table string, fieldWildcard string) (fields []*my.Field, err error) {