1. 代碼

import pymysql.cursorsif __name__ == "__main__":# 連接數(shù)據(jù)庫connect = pymysql.Connect(host='28.104.87.149', port=3306, user='root', passwd='123456', db='weekreport', charset='utf8')# 獲取游標(biāo)cursor = connect.cursor()# 插入數(shù)據(jù)sql = "INSERT INTO trade (name, account, saving) VALUES ( '%s', '%s', %.2f )"data = ('雷軍', '13512345678', 10000)cursor.execute(sql % data)connect.commit()print('成功插入', cursor.rowcount, '條數(shù)據(jù)')# 修改數(shù)據(jù)sql = "UPDATE trade SET saving = %.2f WHERE account = '%s' "data = (8888, '13512345678')cursor.execute(sql % data)connect.commit()print('成功修改', cursor.rowcount, '條數(shù)據(jù)')# 查詢數(shù)據(jù)sql = "SELECT name,saving FROM trade WHERE account = '%s' "data = ('13512345678',)cursor.execute(sql % data)for row in cursor.fetchall():print("Name:%s\tSaving:%.2f" % row)print('共查找出', cursor.rowcount, '條數(shù)據(jù)')# 刪除數(shù)據(jù)sql = "DELETE FROM trade WHERE account = '%s' LIMIT %d"data = ('13512345678', 1)cursor.execute(sql % data)connect.commit()print('成功刪除', cursor.rowcount, '條數(shù)據(jù)')# 事務(wù)處理sql_1 = "UPDATE trade SET saving = saving + 1000 WHERE account = '18012345678' "sql_2 = "UPDATE trade SET expend = expend + 1000 WHERE account = '18012345678' "sql_3 = "UPDATE trade SET income = income + 2000 WHERE account = '18012345678' "try:cursor.execute(sql_1) # 儲(chǔ)蓄增加1000cursor.execute(sql_2) # 支出增加1000cursor.execute(sql_3) # 收入增加2000except Exception as e:connect.rollback() # 事務(wù)回滾print('事務(wù)處理失敗', e)else:connect.commit() # 事務(wù)提交print('事務(wù)處理成功', cursor.rowcount)# 關(guān)閉連接cursor.close()connect.close()

總結(jié)

以上是生活随笔為你收集整理的python 检测数据库是否可以正常连接的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。