MySQLテーブルの更新と更新

Question

私は数千のアドレスを格納するMySQLテーブルを持っています。私はそれらを解析してGeolocation APIに渡し、緯度と経度を取得し、対応するアドレス行に戻す必要があります（私は特別な列を作成しました）。問題はそれを行う最も効率的な方法は何ですか？現在、私はpythonをmysql.connectorとgeopyをgeolocationsに使用しています。したがって、ジオコーディングに使用する簡単なコードは次のとおりです。

cursor = conn.cursor() 

cursor.execute("SELECT description FROM contacts WHERE kind = 'Home adress'") 

    row = cursor.fetchone() 
    while row is not None: 
     geocoded = geolocator.geocode(row, exactly_one=True) 
     if geocoded is not None: 
      lat = geocoded.latitude 
      lon = geocoded.longitude 
     row = cursor.fetchone() 

私はSQLデータベースにはまったく新しいものなので、助けていただければ幸いです。前もって感謝します。

Answer 1

cursor.executemany()を使用すると、一度にテーブルを更新できます。これには、更新パラメータのリストを作成してからexecutemany()に渡す必要があります。パラメータリストは、最初のSELECTクエリの結果から作成できます。例では、私はcontactsテーブルのkey_idという名前のいくつかの主キーがあることを前提としているの下：

cursor = conn.cursor() 
cursor.execute("SELECT key_id, description FROM contacts WHERE kind = 'Home adress'") 

update_params = [] 
for key_id, description in cursor: 
    geocoded = geolocator.geocode(description, exactly_one=True) 
    if geocoded is not None: 
     lat = geocoded.latitude 
     lon = geocoded.longitude 
     update_params.append((lat, lon, key_id)) 

c.executemany("update contacts set lat = %s, lon = %s where key_id = %s", update_params) 

この上述したように、主キーが存在することを前提としています。 1つで、descriptionがテーブル内の一意のフィールドであれば、それを使用できます。 SELECTクエリからkey_idを削除し、update_paramsリストとupdateクエリの両方についてkey_idをフィールドに置き換えてください。

Answer 2

@mhavke、ありがとう！ちょうど私が必要なもの。ここに最終的に動作するコードがあります（私はいくつかの調整を行いました）。また、 '％s'を使用するのは安全ではないことに気付いていますが、これは内部使用のみのため、実際には心配していません。

cursor = conn.cursor() 
cursor.execute("SELECT key_id, description FROM contacts WHERE kind = 'Home address'") 
update_params = [] 
for key_id, description in cursor: 
    geocoded = geolocator.geocode(description, exactly_one=True) 
    if geocoded is not None: 
     lat = geocoded.latitude 
     lon = geocoded.longitude 
     update_params.append((lat, lon, key_id)) 

cursor.executemany("update contacts set latitude = %s, longitude = %s where key_id = %s", update_params) 
conn.commit()