sql >> Databáze >  >> RDS >> Mysql

Načítání dat z MySQL v dávkách přes Python

První bod:python db-api.cursor je iterátor, takže pokud to opravdu nepotřebujete Chcete-li načíst celou dávku do paměti najednou, můžete začít používat tuto funkci, tj. místo:

cursor.execute("SELECT * FROM mytable")
rows = cursor.fetchall()
for row in rows:
   do_something_with(row)

můžete jen:

cursor.execute("SELECT * FROM mytable")
for row in cursor:
   do_something_with(row)

Pokud pak implementace vašeho db konektoru stále nevyužívá správně tuto funkci, bude čas přidat do mixu LIMIT a OFFSET:

# 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)


  1. Golang ORDER BY problém s MySql

  2. Jak naplnit datovou sadu C# z databáze Oracle

  3. Databázový model pro online průzkum. Část 3

  4. MySQL LEFT JOIN pomocí MAX &GROUP BY na spojeném stole?