d = 1000 try: query = "SELECT before_cal_ton FROM cargo_pile WHERE pile_name = %s" cursor.execute(query, (dh,)) result = cursor.fetchall() if result: print(result[0][0]) else: print("No results found") except Exception as e: print("Error:", e) try: query = "SELECT cur_cal_ton FROM cargo_pile WHERE pile_name = %s" cursor.execute(query, (dh,)) result = cursor.fetchall() if result: print(result[0][0]) else: print("No results found") except Exception as e: print("Error:", e) 继续用代码实现这段代码查询得到before_cal_ton和cur_cal_ton后,将cur_cal_ton赋值给before_cal_ton,将d复制给cur_cal_ton,并存入数据库中
时间: 2024-04-12 18:28:09 浏览: 129
你可以使用以下代码实现你的需求:
```python
d = 1000
try:
query = "SELECT before_cal_ton, cur_cal_ton FROM cargo_pile WHERE pile_name = %s"
cursor.execute(query, (dh,))
result = cursor.fetchall()
if result:
before_cal_ton = result[0][0]
cur_cal_ton = result[0][1]
print("before_cal_ton:", before_cal_ton)
print("cur_cal_ton:", cur_cal_ton)
# 更新数据
update_query = "UPDATE cargo_pile SET before_cal_ton = %s, cur_cal_ton = %s WHERE pile_name = %s"
cursor.execute(update_query, (cur_cal_ton, d, dh))
connection.commit()
print("Data updated successfully")
else:
print("No results found")
except Exception as e:
print("Error:", e)
```
以上代码会执行以下操作:
1. 执行查询语句,获取 `before_cal_ton` 和 `cur_cal_ton` 的值。
2. 打印 `before_cal_ton` 和 `cur_cal_ton` 的值。
3. 更新数据库中的数据,将 `cur_cal_ton` 的值更新为 `d`,将 `d` 的值更新为 `before_cal_ton`。
4. 提交事务,保存更新后的数据。
5. 打印成功更新数据的消息。
请确保你已经正确连接到数据库,并且在使用之前已经导入了相应的库和模块。
阅读全文