Poin pertama:db-api.cursor
python adalah iterator, jadi kecuali jika Anda benar-benar membutuhkan untuk memuat seluruh batch dalam memori sekaligus, Anda bisa mulai menggunakan fitur ini, yaitu alih-alih:
cursor.execute("SELECT * FROM mytable")
rows = cursor.fetchall()
for row in rows:
do_something_with(row)
Anda bisa saja:
cursor.execute("SELECT * FROM mytable")
for row in cursor:
do_something_with(row)
Kemudian jika implementasi konektor db Anda masih belum memanfaatkan fitur ini dengan benar, sekarang saatnya untuk menambahkan LIMIT dan OFFSET ke dalam campuran:
# py2 / py3 compat
try:
# xrange is defined in py2 only
xrange
except NameError:
# py3 range is actually p2 xrange
xrange = range
cursor.execute("SELECT count(*) FROM mytable")
count = cursor.fetchone()[0]
batch_size = 42 # whatever
for offset in xrange(0, count, batch_size):
cursor.execute(
"SELECT * FROM mytable LIMIT %s OFFSET %s",
(batch_size, offset))
for row in cursor:
do_something_with(row)