Method query

statement.go:104–150

(args []driver.Value)

}

func (stmt *mysqlStmt) query(args []driver.Value) (*binaryRows, error) {
	if stmt.mc.closed.Load() {
		return nil, driver.ErrBadConn
	}
	// Send command
	err := stmt.writeExecutePacket(args)
	if err != nil {
		return nil, stmt.mc.markBadConn(err)
	}

	mc := stmt.mc

	// Read Result
	handleOk := stmt.mc.clearResult()
	resLen, metadataFollows, err := handleOk.readResultSetHeaderPacket()
	if err != nil {
		return nil, err
	}

	rows := new(binaryRows)

	if resLen > 0 {
		rows.mc = mc
		if metadataFollows {
			if rows.rs.columns, err = mc.readColumns(resLen, stmt.columns); err != nil {
				return nil, err
			}
			stmt.columns = rows.rs.columns
		} else {
			if err = mc.skipEof(); err != nil {
				return nil, err
			}
			rows.rs.columns = stmt.columns
		}
	} else {
		rows.rs.done = true

		switch err := rows.NextResultSet(); err {
		case nil, io.EOF:
			return rows, nil
		default:
			return nil, err
		}
	}

	return rows, err
}

var jsonType = reflect.TypeFor[json.RawMessage]()