-
def add_money(self,aim_id,money): cursor=self.conn.cursor() try: sql='update bank set money=money + %s where id = %s' % (money,aim_id) cursor.execute(sql) re=cursor.fetchall() print 'add_money:'+sql if cursor.rowcount!=1: raise Exception("加款失败") finally: cursor.close() def changeMoney(self,source_id,aim_id,money): try: self.checkSource(source_id) self.checkAim(aim_id) self.checkMoney(source_id, money) self.reduce_money(source_id, money) self.add_money(aim_id, money) self.conn.commit() except Exception as e: self.conn.rollback() raise e查看全部
-
def checkMoney(self,source_id,money): cursor = self.conn.cursor() try: sql='select %s from bank where id=%s' % (money,source_id) cursor.execute(sql) re = cursor.fetchall() print 'checkMoeny'+sql if len(re)!=1: raise Exception("%s没有足够的钱"% source_id) finally: cursor.close() def reduce_money(self,source_id,money): cursor = self.conn.cursor() try: sql='update bank set money=money-%s where id = %s' % (money,source_id) cursor.execute(sql) re=cursor.fetchall() print 'reduce_money:'+sql if cursor.rowcount !=1: raise Exception ("减款失败") finally: cursor.close()查看全部
-
import MySQLdb import sys class TransMoney(object): def __init__(self,conn): self.conn = conn def checkSource(self,source_id): cursor=self.conn.cursor() try: sql='select * from bank where id = %s' % source_id cursor.execute(sql) re = cursor.fetchall() print "checkSource:"+sql if len(re)!=1: raise Exception ('转出人%s不存在 ' % source_id) finally: cursor.close() def checkAim(self,aim_id): cursor = self.conn.cursor() try: sql='select * from bank where id = %s' % aim_id cursor.execute(sql) re = cursor.fetchall() print 'checkAimId:'+sql if len(re)!=1: raise Exception('转入人%s不存在'% aim_id) finally: cursor.close()查看全部
-
MySQLdb.Connect(参数) host port user passwd db charset cursor() 使用该连接创建返回游标 import MySQLdb conn=MySQLdb.Connect(host='127.0.0.1',port=3306,user='root',passwd='123456',db='imooc',charset='utf-8') cursor=conn.cursor() print conn print cursor cursor.close() conn.close()查看全部
-
import MySQLdb print MySQLdb sourceforge.net/projects/mysql-python 客户端工具 SQLyog查看全部
-
Python MySQL 开发环境 代码编辑器 Python -- Mysql connector 下载 MySQL服务器查看全部
-
没有Python DB API之前，接口程序混乱 Mysql oracle sqlserver有不同的访问接口 www.python.org/dev/peps/pep-0249 数据库连接对象 connection 数据库交互对象 cursor 开始 -- 创建 connection --- 获取cursor -- 执行查询 获取数据 处理数据 --- 关闭cursor --- 关闭connection -- 结束查看全部
-
数据库操作中事务的四大特点：原子性，一致性，隔离性，持久性查看全部
-
游标对象（用于执行查询和获取结果）cursor支持的方法查看全部
-
connection对象支持的方法查看全部
-
MySqldb的connection对象的创建方法查看全部
-
开发环境的组合查看全部
-
rs = cursor.fetchall() for row in rs: print "userid = %s, username = %s" % row查看全部
-
insert update delete更新数据库查看全部
-
rs是一个元组tuple，所以print里面只需要一个row，因为row就是一个list，有两个元素查看全部
举报
0/150
提交
取消