Bug in _iud_query() when data is set and len(data) > chunksize

[JamieTaylor-TUOS]

When data is not None and len(data) > chunk_size, the value of affected will be the number of rows affected by the last chunked insert. Instead, need to keep a running total of cursor.rowcount when looping over chunks

MySQL-DBConnector/dbconnector/dbconnector.py

Lines 413 to 428 in f5dd972

	def _iud_query(cnx, **kwargs):
	"""Execute an insert/update/delete SQL statement."""
	chunk_size = kwargs.get("chunk_size", 1000)
	data = kwargs.get("data", None)
	sqlquery = kwargs.get("sqlquery", None)
	debug(f"insert/update/delete query: {sqlquery}")
	cursor = cnx.cursor()
	if data is None:
	cursor.execute(sqlquery)
	else:
	for i in range(0, len(data), chunk_size):
	cursor.executemany(sqlquery, data[i:(i+chunk_size)])
	cnx.commit()
	affected = cursor.rowcount
	cursor.close()
	return affected

Suggested fix:

def _iud_query(cnx, **kwargs):
    """Execute an insert/update/delete SQL statement."""
    chunk_size = kwargs.get("chunk_size", 1000)
    data = kwargs.get("data", None)
    sqlquery = kwargs.get("sqlquery", None)
    debug(f"insert/update/delete query: {sqlquery}")
    cursor = cnx.cursor()
    if data is None:
        cursor.execute(sqlquery)
        affected = cursor.rowcount
    else:
        affected = 0
        for i in range(0, len(data), chunk_size):
            cursor.executemany(sqlquery, data[i:(i+chunk_size)])
            affected += cursor.rowcount
    cnx.commit()
    cursor.close()
    return affected