Python一括update MySQLデータベーステーブルのフィールド

1280 ワード

import pymysql
#     
conn=pymysql.connect(host='127.0.0.1',
                             user='***',
                             passwd='***',
                             db='***',
                             port=3306,charset='utf8') 
#  update                              
def Item_Clean_Spu(item_combine_spu_re):
    item_clean_spu_id=item_combine_spu_re[['id','spu_id']]
    item_clean_spu_id=item_clean_spu_id[item_clean_spu_id['spu_id'].notnull()]
    item_clean_spu_id=item_clean_spu_id.reset_index(drop=True)
    for i in np.arange(len(item_clean_spu_id)+2)[1:-1]:       
        sql="""
            update item_clean ic set ic.spu_id = {0}
            where ic.item_id={1} and ic.spu_id IS NULL
            """.format(item_clean_spu_id[:i]['spu_id'].astype(str).tolist()[(i-1)],item_clean_spu_id[:i]['id'].astype(str).tolist()[(i-1)])
        conn.ping(reconnect=True)
        sqled= conn.query(sql)
        conn.commit()

低効率のforサイクルを取って、もっと良い方法があってお知らせを歓迎して、感謝します~~また1つの小さい問題を発見して、1つの間違いを報告します:1205-Lock wait timeout exceeded;try restarting transaction、結果は同僚が表hiahiahiahiahiaを変更して、私はまだ愚かに半日データベースを探して、killは1山のスレッドで、やはり多くアヒルを勉強します~