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

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

  • 相关阅读:
    slice()、substring()、substr()的区别用法
    程序员如何快速上手一个自己不太熟悉的新项目?有什么技巧?
    计算重复字符串长度
    计算机视觉算法研发岗招聘要求
    C++进阶STL-2
    C++进阶STL-1
    拼硬币
    序列找数
    寻找合法字符串
    字符串是否由子串拼接
  • 原文地址:https://www.cnblogs.com/ly570/p/11357433.html
Copyright © 2011-2022 走看看