Aug 24, 2022 · Aug 24, 2022 · Aug 26, 2022 · Aug 26, 2022 · Aug 30, 2022 · Aug 30, 2022
diff --git a/src/accel.c b/src/accel.c
            Py_XDECREF(py_n_rows);
        }
        else {
            // Unbuffered needs a new row every time.
            py_state->df_buffer = malloc(py_state->df_buffer_row_size);
            py_state->df_cursor = py_state->df_buffer;

            switch (py_state->options.output_type) {
            case MYSQL_ACCEL_OUT_PANDAS:
            case MYSQL_ACCEL_OUT_NUMPY:
                // Unbuffered needs a new row every time.
                py_state->df_buffer = malloc(py_state->df_buffer_row_size);
                py_state->df_cursor = py_state->df_buffer;

                // TODO: reshape?
                py_out = py_state->py_rows;
                Py_INCREF(py_out);
        }
    }
    else {
        switch (py_state->options.output_type) {
        case MYSQL_ACCEL_OUT_PANDAS:
        case MYSQL_ACCEL_OUT_NUMPY:
            py_out = py_state->py_rows;
            Py_INCREF(py_out);
            break;
        default:
            py_out = py_state->py_rows;
            Py_INCREF(py_out);
        }
        py_out = py_state->py_rows;
        Py_INCREF(py_out);
        PyObject *py_n_rows = PyLong_FromSsize_t(py_state->n_rows);
        PyObject_SetAttrString(py_res, "affected_rows", (py_n_rows) ? py_n_rows : Py_None);
        Py_XDECREF(py_n_rows);
Original file line number	Diff line number	Diff line change
Expand Up		@@ -2059,13 +2059,13 @@ static PyObject read_rowdata_packet(PyObject self, PyObject args, PyObject k
		Py_XDECREF(py_n_rows);
		}
		else {
		// Unbuffered needs a new row every time.
		py_state->df_buffer = malloc(py_state->df_buffer_row_size);
		py_state->df_cursor = py_state->df_buffer;

		switch (py_state->options.output_type) {
		case MYSQL_ACCEL_OUT_PANDAS:
		case MYSQL_ACCEL_OUT_NUMPY:
		// Unbuffered needs a new row every time.
		py_state->df_buffer = malloc(py_state->df_buffer_row_size);
		py_state->df_cursor = py_state->df_buffer;

		// TODO: reshape?
		py_out = py_state->py_rows;
		Py_INCREF(py_out);
Expand All		@@ -2077,16 +2077,8 @@ static PyObject read_rowdata_packet(PyObject self, PyObject args, PyObject k
		}
		}
		else {
		switch (py_state->options.output_type) {
		case MYSQL_ACCEL_OUT_PANDAS:
		case MYSQL_ACCEL_OUT_NUMPY:
		py_out = py_state->py_rows;
		Py_INCREF(py_out);
		break;
		default:
		py_out = py_state->py_rows;
		Py_INCREF(py_out);
		}
		py_out = py_state->py_rows;
		Py_INCREF(py_out);
		PyObject *py_n_rows = PyLong_FromSsize_t(py_state->n_rows);
		PyObject_SetAttrString(py_res, "affected_rows", (py_n_rows) ? py_n_rows : Py_None);
		Py_XDECREF(py_n_rows);
Expand Down