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