python连接mysql代码_Python3连接MySQL(pymysql)转账代码

# coding:utf8

import sys

# Python3 采用pymysql 连接MySQL

import pymysql

class TransferMoney(object):

def __init__(self,conn):

self.conn=conn

def check_acct_available(self,acctid):

cursor = self.conn.cursor()

try:

sql="select * from account where acctid=%s" % acctid

cursor.execute(sql)

print ("check_acct_available:"+sql)

rs = cursor.fetchall()

if len(rs) != 1:

raise Exception("账号%s不存在"% acctid)

finally:

cursor.close()

def has_enough_money(self,acctid,money):

cursor = self.conn.cursor()

try:

sql="select * from account where acctid=%s and money>%s" % (acctid,money)

cursor.execute(sql)

print ("has_enough_money:"+sql)

rs = cursor.fetchall()

if len(rs) != 1:

raise Exception("账号%s余额不足"% acctid)

finally:

cursor.close()

def reduce_money(self,acctid,money):

cursor = self.conn.cursor()

try:

sql="update account set money=money-%s where acctid=%s" % (money,acctid)

cursor.execute(sql)

print ("reduce_money:"+sql)

if cursor.rowcount != 1:

raise Exception("账号%s减款失败" % acctid)

finally:

cursor.close()

def add_money(self,acctid,money):

cursor = self.conn.cursor()

try:

sql="update account set money=money+%s where acctid=%s" % (money,acctid)

cursor.execute(sql)

print ("add_money:"+sql)

if cursor.rowcount != 1:

raise Exception("账号%s加款失败" % acctid)

finally:

cursor.close()

def transfer(self,source_acctid,target_acctid,money):

try:

self.check_acct_available(source_acctid)

self.check_acct_available(target_acctid)

self.has_enough_money(source_acctid,money)

self.reduce_money(source_acctid,money)

self.add_money(target_acctid,money)

self.conn.commit()

except Exception as e:

self.conn.rollback()

raise e

if __name__=="__main__":

source_acctid=sys.argv[1]

target_acctid=sys.argv[2]

money=sys.argv[3]

conn = pymysql.Connect(

host='localhost',

unix_socket="/Applications/MAMP/tmp/mysql/mysql.sock",

port=3306,

user='root',

passwd='123456',

db='python_db',

)

tr_money=TransferMoney(conn)

try:

tr_money.transfer(source_acctid,target_acctid,money)

except Exception as e:

print ("出现问题"+str(e))

finally:

conn.close()

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/534125.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

gc java root_C#技术漫谈之垃圾回收机制(GC)

GC的前世与今生虽然本文是以.NET作为目标来讲述GC,但是GC的概念并非才诞生不久。早在1958年,由鼎鼎大名的图林奖得主John McCarthy所实现的Lisp语言就已经提供了GC的功能,这是GC的第一次出现。Lisp的程序员认为内存管理太重要了,所…

中信银行c语言笔试题库,中信银行笔试题型及题目

中信银行笔试题型及题目考试题型一:专业知识(2个小时)1.专业知识单选,60题,每题1分。2.专业知识多选,20题,每题1分,未选全即少选得0.5分,错选、漏选得0分。3.英语阅读,20分&#xff…

北航软件工程硕士_21考研择校 | 北京航空航天大学软件工程怎么样?

☝☝☝ 软件工程考研独家平台撰稿 | 康康哥编辑 | 丽丽姐本文由懂计算机、软件工程的博士师哥原创01学校名气北京航空航天大学,简称“北航”,是一所把“985”、“211”、“双一流”写进骨子里的学校。为什么这么说呢?这得从源头说起&#xff…

kettle同步数据到hive 巨慢_超详细教程,kettle ETL mysql到hadoop hive数据抽取,值得收藏...

那么如何将mysql数据导入到hive里呢,kettle里有自带方法,可以通过表输入和表输出来实现,不过自带的方法载入数据极其缓慢,不推荐使用这种方法。1、hive建表注意hive表使用“^”作为分隔符,这个可以更具实际情况来。2、…

linux 查看path文件,linux入门之环境变量与文件查找

环境变量分类当前 Shell 进程私有用户自定义变量,如上面我们创建的 temp 变量,只在当前 Shell 中有效。Shell 本身内建的变量。从自定义变量导出的环境变量。declare tmp;tmp"shiyanlou i love y";echo $tmp ; **不要忘记$**实验楼…

python手机编译器可以干什么_世界上最好的Python编辑器是什么?

在这种情况下,你需要使用一个 IDE(集成开发环境)或专用的代码编辑器。由于 Python 是最流行的编程语言之一,IDE 的选择也非常多。那么问题来了:「究竟什么样的 IDE 最适合 Python?」 很明显,没有…

c是过程化语言吗数据库,A.数据库语言B.过程化语言C.宿主语言D.数据库管理系统...

A.数据库语言B.过程化语言C.宿主语言D.数据库管理系统更多相关问题[填空题] 为了安全起见,起动发动机前要检查()有无行人。---叉车操作和保养手册第2-77.在起动叉车前()以警告周围的人。[单选] 制造厂规定叉车走合期一…

python读取xlsx文件pandas_用Python的pandas框架操作Excel文件中的数据教程

引言 本文的目的,是向您展示如何使用pandas来执行一些常见的Excel任务。有些例子比较琐碎,但我觉得展示这些简单的东西与那些你可以在其他地方找到的复杂功能同等重要。作为额外的福利,我将会进行一些模糊字符串匹配,以此来展示一…

delphi 生成 超大量xml_用OpenCV4实现图像的超分别率

用OpenCV4实现图像的超分别率本实验原文链接: f"https://arxiv.org/pdf/1807.06779.pdf">https://arxiv.org/pdf/1807.06779.pdf原文摘要单图像超分辨率(SISR)的主要挑战是如何恢复微小纹理等高频细节。然而,大多数最…

dubbo全局异常处理_基于spring aop的dubbo异常统一处理

dubbo统一异常处理,调用方只显示封装后的异常。1、返回封装后的Exception2、返回封装后的统一返回信息import org.aspectj.lang.annotation.AfterThrowing;import org.aspectj.lang.annotation.Aspect;import org.slf4j.Logger;import org.slf4j.LoggerFactory;impo…

python123平台作业答案第十一周_马哥2016全新Linux+Python高端运维班第十次作业

系统的INPUT和OUTPUT默认策略为DROP,请完成以下关于iptables的题目;iptables -A INPUT -d 10.18.11.13 -p tcp --dport 22 -j ACCEPT #允许ssh端口 iptables -A OUTPUT -s 10.18.11.13 -p tcp --sport 22 -j ACCEPT iptables -P OUTPUT DROP #设置OUTPUT…

义教志愿服务系统c语言,[志愿服务]以己为师 东科学子义教传爱心

为积极响应国家教育计划,丰富孩子们的暑期生活,进一步落实“春泥”课堂先进义教理念,7月12日,浙江海洋大学东海科学技术学院大学生“海岛征程十五载,红色基因永传承”赴蚂蚁岛实践团23名队员走进蚂蚁岛文化礼堂&#x…

主动断开socket链接_TCP连接与断开详解(socket通信)

http://blog.csdn.net/Ctrl_qun/article/details/52518479一、TCP数据报结构以及三次握手TCP(Transmission Control Protocol,传输控制协议)是一种面向连接的、可靠的、基于字节流的通信协议,数据在传输前要建立连接,传输完毕后还要断开连接。…

大整数算术求值 c语言 栈,用C语言实现 多位整数的四则运算,用栈,例如56*(12+20)-102/2...

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼gets(szExpression);// 中缀表达式转后缀表达式&#xff0c;结果保存在expression中for (int i 0; i < strlen(szExpression); i){if (isspace(szExpression[i])) // 空白字符{if (bFindBegin){expression[num].type 1;expres…

java可视化压缩_WEB可视化技术发展

EverCraft一直在关注Web可视化技术的发展&#xff0c;本文对国外一篇感觉很不错的综述性文章进行翻译&#xff0c;供这一领域的爱好者相互学习。这篇paper的信息为&#xff1a;“Mwalongo, F., et al., State-of-the-Art Report in Web-based Visualization. COMPUTER GRAPHICS…

thumbdata4删除后果_安卓手机上巨大的.thumbdata4图片预读缓存清理方法

以下是目前找到比较有效的帮 .thumbdata4-文件瘦身的好方法.下面的一大堆废话的核心就是进手机设置>应用程序>显示系统程序>媒体存储器>存储>清除数据/缓存.重启后会发现thumbdata还会出现但是没有数GB那么大了.How do I Reset the AndroidMedia Scan Database?…

android自定义alertdialog不现实输入法,自定义的dialog中的EditText无法弹出输入法解决方案...

1.解决无法弹出输入法&#xff1a;在show()方法调用之前&#xff0c;用dialog.setView(new EditText(context))添加一个空的EditText&#xff0c;由于是自定义的AlertDialog&#xff0c;有我们指定的布局&#xff0c;所以设置这个不会影响我们的功能&#xff0c;这样就可以弹出…

python爬取微博内容_请问该如何通过python调用新浪微博的API来爬取数据?

1&#xff1a;安装python(这个不多说啦) 2&#xff1a;下载新浪微博SDK的python包&#xff0c;解压为weibopy目录 3&#xff1a;申请AppKey&#xff0c; 流程&#xff1a; 1&#xff1a;通过oAuth认证 按我的理解简化如下&#xff1a; 用户在新浪微博给的页面输入账号密码&…

android 保活方案_Android 后台保活手段总结 (上篇)

Android 后台保活手段总结 (上篇)由于众所周知的限制&#xff0c;在国内无法使用GCM推送服务&#xff0c;想要自己搭建推送服务的话&#xff0c;有两个绕不开的技术点&#xff0c;一个是TCP长连的保活&#xff0c;另一个就是后台进程的保活。虽然看起来是老生常谈的问题&#x…

linux修改栈指针x86,为什么x86-64 Linux系统调用会修改RCX,这个值意味着什么?

我正在尝试使用sys_brk syscall在linux中分配一些内存.这是我尝试过的&#xff1a;BYTES_TO_ALLOCATE equ 0x08section .textglobal _start_start:mov rax, 12mov rdi, BYTES_TO_ALLOCATEsyscallmov rax, 60syscall根据linux调用约定,我希望返回值在rax寄存器中(指向已分配内存…