zoukankan      html  css  js  c++  java
  • 利用pymysql同时修改两张表的数据

    使用pymysql操作数据库中相关联的两张表
    需求:两张表中分别有一个字段是json格式,需要往json中再插入一个属性值’container_cloud’=’fasle’。

    import pymysql
    import json

    db = pymysql.connect("host","user","password","dbname")
    cursor1 = db.cursor()  #操作第一张表
    cursor2 = db.cursor()  #操作第二张表
    try:
    #通过第一张表,查询出需要修改的字段,和第二张表相关联的字段
    cursor1.execute("select id,resc_metadata,apply_id from approvedresc_rescdetail where resource_type='Job';")
    values = cursor1.fetchall()
    for id,resc_metadata,apply_id in values:
    resc_metadata = json.loads(resc_metadata)
    if resc_metadata.get('container_cloud') == None:
    resc_metadata['container_cloud']='false'
    resc_metadata = json.dumps(resc_metadata)
    sql_approved = "update approvedresc_rescdetail set resc_metadata=%s where id=%s;"
    cursor1.execute(sql_approved,(resc_metadata,id))

    sql_apply1 = "select resc_metadata from apply_rescdetail where id=%s;"
    cursor2.execute(sql_apply1, [apply_id])
    value = cursor2.fetchone()
    apply_resc_metadata = json.loads(value[0])
    if apply_resc_metadata.get('container_cloud') == None:
    apply_resc_metadata['container_cloud']='false'
    apply_resc_metadata = json.dumps(apply_resc_metadata)
    sql_apply2 = "update apply_rescdetail set resc_metadata=%s where id=%s;"
    cursor2.execute(sql_apply2,(apply_resc_metadata,apply_id))
    print(id,apply_id)
    db.commit()
    except Exception as e:
    print('error:',e)
    db.rollback(http://www.amjmh.com/v/BIBRGZ_558768/)
    cursor2.close()
    cursor1.close()
    db.close()

    ---------------------

  • 相关阅读:
    Android学习笔记——启动Activity及Activity生命周期
    TransposonPSI——转座子分析的入门自学
    关于 GraPhlAn 的孤独自学
    Javascript 正则表达式 子表达式
    关于set,list,map的理解
    js关于日期的操作
    JDBC和JTA事务区别
    远程调试本地服务或程序
    Fragment的数据传递
    记录自己的第一篇博客
  • 原文地址:https://www.cnblogs.com/ly570/p/11357433.html
Copyright © 2011-2022 走看看