lukehuang
diff --git a/‎_mysql.c
Copy file name to clipboardExpand all lines: _mysql.c
+5-1Lines changed: 5 additions & 1 deletion b/‎_mysql.c
Copy file name to clipboardExpand all lines: _mysql.c
+5-1Lines changed: 5 additions & 1 deletion
@@ -827,9 +827,13 @@ _mysql_ConnectionObject_affected_rows(
 	_mysql_ConnectionObject *self,
 	PyObject *args)
 {
+	my_ulonglong ret;
 	if (!PyArg_ParseTuple(args, "")) return NULL;
 	check_connection(self);
-	return PyLong_FromUnsignedLongLong(mysql_affected_rows(&(self->connection)));
+	ret = mysql_affected_rows(&(self->connection));
+	if (ret == (my_ulonglong)-1)
+		return PyInt_FromLong(-1);
+	return PyLong_FromUnsignedLongLong(ret);
 }
 
 static char _mysql_debug__doc__[] =