#coding:utf-8
import MySQLdb #调用MySQL数据库模块
conn=MySQLdb.Connect(
host='.........', #输入数据库的IP地址
port=3306, #输入数据库的使用端口
user='......', #输入数据库用户账号
passwd='......', #输入数据库用户密码
db='......', #输入数据库名称
charset='utf8' #输入数据库编码
)
#转账函数
def transfer(s_id,d_id,num):
conn.autocommit(False)
a=id_avi(s_id) #调用账号确认函数
b=id_avi(d_id)
c=money_avi(s_id,num) #调用余额确认函数
if a and b and c:
money_reduce(s_id,num) #调用减钱函数
money_add(d_id,num) #调用加钱函数
conn.commit()
print u'转账成功!'
else:
print u'转账失败!'
conn.rollback()
#存钱函数
def add_in(id,num):
a=id_avi(id)
if a:
money_add(id,num) #调用加钱函数
conn.commit()
else:
print u'账号%s不存在，请核对!'%id
conn.rollback()
#取钱函数
def reduce_out(id,num):
a=id_avi(id)
b=money_avi(id,num)
if a and b:
money_reduce(id,num) #调用减钱函数
conn.commit()
else:
print u'取钱失败!请核对!'
conn.rollback()
#账号确认函数
def id_avi(id):
curr=conn.cursor()
sql='select * from money where uid=%s'%id
curr.execute(sql)
row=curr.rowcount
if row==1:
print u'账户%s确认成功!'%id
return True
else:
print u'账户%s确认失败!'%id
return False
curr.close()
#账户余额确认函数
def money_avi(id,num):
curr=conn.cursor()
sql='select money from money where uid=%s'%id
curr.execute(sql)
n=curr.fetchone()
nn=n[0]
if nn>=num:
print u'账户%s余额足够!'%id
return True
else:
print u'账户%s余额不足!'%id
return False
curr.close()
#减钱函数
def money_reduce(id,num):
curr=conn.cursor()
sql='update money set money=money-%s where uid=%s'%(num,id)
curr.execute(sql)
print u'转出确认!'
curr.close()
#加钱函数
def money_add(id,num):
curr=conn.cursor()
sql='update money set money=money+%s where uid=%s'%(num,id)
curr.execute(sql)
print u'转入确认!'
curr.close()
#实例：
reduce_out(1,2000)
transfer(2,1,1999)
