-
MYSQL连接测试
查看全部 -
好多个步骤
查看全部 -
老师讲得如行云流水般熟练~
我们要多加练习了
查看全部 -
还需要回滚和提交的异常判断
查看全部 -
查看全部
-
客户端-》业务逻辑-》数据访问层-》数据库
查看全部 -
raise e :抛出异常
查看全部 -
更新数据库
事务
查看全部 -
游标
execute
查看全部 -
db api
流程
查看全部 -
Python DB Api查看全部
-
银行转账 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 "reduce_money:" + sql if cursor.rowcount != 1: raise Exception("账号%s加款失败" % acctid) finally: cursor.close()查看全部 -
创建了connection和cursor之后，要关闭，防止资源浪费
查看全部 -
连接对象、创建方法
查看全部 -
游标对象cursor 支持的方法：
查看全部
举报
0/150
提交
取消