python操作MySQL 模擬簡(jiǎn)單銀行轉(zhuǎn)賬操作

更新時(shí)間：2017年09月27日 11:17:53 作者：幸福清風(fēng)

這篇文章主要介紹了python操作MySQL 模擬簡(jiǎn)單銀行轉(zhuǎn)賬操作,需要的朋友可以參考下

一、基礎(chǔ)知識(shí)

1、MySQL-python的安裝

下載，然后 pip install 安裝包

2、python編寫(xiě)通用數(shù)據(jù)庫(kù)程序的API規(guī)范

（1）、數(shù)據(jù)庫(kù)連接對(duì)象 connection，建立python客戶(hù)端與數(shù)據(jù)庫(kù)的網(wǎng)絡(luò)連接，創(chuàng)建方法為 MySQLdb.Connect(參數(shù))

參數(shù)有六個(gè): host（MySQL服務(wù)器地址，一般本地為127.0.0.1）

                            port（MySQL服務(wù)器端口號(hào)）
                            user（用戶(hù)名）
                            passwd（密碼）
                            db（數(shù)據(jù)庫(kù)名稱(chēng)）
                            charset（連接編碼）

connection的方法: cursor（）使用該連接并返回游標(biāo)

                                      commit（）提交當(dāng)前事務(wù)
                                      rollback（）回滾當(dāng)前事務(wù)
                                      close（）關(guān)閉連接

（2）、數(shù)據(jù)庫(kù)游標(biāo)對(duì)象cursor，用于執(zhí)行查詢(xún)和獲取結(jié)果

方法：execute（op[,args]）執(zhí)行一個(gè)數(shù)據(jù)庫(kù)查詢(xún) 和命令

              fetchone（）取得結(jié)果集的下一行
              fetchmany（size）獲取結(jié)果集的下幾行
              fetchall（）獲取結(jié)果集中剩下的所有行
              rowcount 最近一次execute返回?cái)?shù)據(jù)的行數(shù)或影響行數(shù)
              close（）關(guān)閉游標(biāo)對(duì)象

connection與cursor：connection相當(dāng)于python與MySQL之間的路，而cursor相當(dāng)于路上的運(yùn)輸車(chē)來(lái)傳送命令與結(jié)果。

3、簡(jiǎn)單命令：

select 查詢(xún)數(shù)據(jù)：sql="select * from 表名所查項(xiàng)目"
insert 插入數(shù)據(jù)：sql=“insert into 表名所插項(xiàng)目”
update 更改數(shù)據(jù)： sql=“updata 表名 set 所改項(xiàng)目 ”
delete 刪除數(shù)據(jù)： sql=“delete from 表名所刪項(xiàng)目”
where也是sql命令的關(guān)鍵存在，通常是 where 表頭=列名來(lái)定位那一列

4、事務(wù)

訪問(wèn)和更新數(shù)據(jù)庫(kù)的一個(gè)程序執(zhí)行單元，所執(zhí)行的命令，都可以稱(chēng)為事務(wù)

具有原子性，一致性，隔離性，持久性

事務(wù)執(zhí)行：

conn.commit() 正常結(jié)束事務(wù)
conn.rollback() 異常結(jié)束事務(wù)，對(duì)事務(wù)進(jìn)行回滾，若程序執(zhí)行單元中的連續(xù)的操作在進(jìn)行中出錯(cuò)，之前的操作還原。

簡(jiǎn)單操作過(guò)程：開(kāi)始 → 創(chuàng)建connection →獲取cursor → 程序執(zhí)行單元 → 關(guān)閉cursor → 關(guān)閉connection → 結(jié)束

二、模擬銀行轉(zhuǎn)賬系統(tǒng)代碼

#coding=utf-8 
import sys 
import MySQLdb 
''''' 
python操作MySQL數(shù)據(jù)庫(kù)，模擬銀行轉(zhuǎn)賬 
''' 
class Trans_for_Money(object): 
 #初始化 類(lèi) 
 def __init__(self,conn): 
  self.conn = conn 
 #### 1、檢查所輸入的賬號(hào)是否存在 #### 
 def check_acct_available(self,source_acctid): 
  #使用與數(shù)據(jù)庫(kù)的鏈接并返回游標(biāo) 
  cursor=self.conn.cursor() 
  try: 
   #數(shù)據(jù)庫(kù)命令 
   sql="select * from tr_money where acctid=%s" %source_acctid 
   #執(zhí)行命令 
   cursor.execute(sql) 
   #為方便觀察執(zhí)行過(guò)程 
   print "check_acct_available:" + sql 
   #講結(jié)果集放入變量result中，若result不等于1，則沒(méi)有這個(gè)賬號(hào)，輸出異常 
   result=cursor.fetchall() 
   if len(result)!=1: 
    raise Exception("賬號(hào)%s不存在" %source_acctid) 
  finally: 
   #若過(guò)程出現(xiàn)問(wèn)題，仍需要關(guān)閉游標(biāo)對(duì)象 
   cursor.close() 
 #### 2、檢查減款人余額是否充足，方法與上一個(gè)函數(shù)一樣，只是多加了一個(gè)money參數(shù) ### 
 def has_enough_money(self,source_acctid,money): 
  cursor=self.conn.cursor() 
  try: 
   sql="select * from tr_money where acctid=%s and money>%s" %(source_acctid,money) 
   cursor.execute(sql) 
   print "has_enough_money:" + sql 
   result=cursor.fetchall() 
   if len(result)!=1: 
    raise Exception("賬號(hào)%s余額不足" %source_acctid) 
  finally: 
   cursor.close() 
 #### 3、減款操作 ### 
 def reduce_money(self,source_acctid,money): 
  cursor=self.conn.cursor() 
  try: 
   #數(shù)據(jù)庫(kù)命令，減去對(duì)應(yīng)減款人的金額數(shù) 
   sql="update tr_money set money=money-%s where acctid=%s" %(money,source_acctid) 
   cursor.execute(sql) 
   print "reduce_money:" + sql 
   #操作的execute()數(shù)據(jù)行數(shù)不等于1則減款失敗 
   if cursor.rowcount!=1: 
    raise Exception("賬號(hào)%s減款失敗" %source_acctid) 
  finally: 
   cursor.close() 
 #### 4、收款操作，與減款方法相同 ### 
 def add_money(self,target_acctid,money): 
  cursor=self.conn.cursor() 
  try: 
   sql="update tr_money set money=money+%s where acctid =%s" %(money,target_acctid) 
   cursor.execute(sql) 
   print "add_money:" + sql 
   if cursor.rowcount!=1: 
    raise Exception("賬號(hào)%s收款失敗" %target_acctid) 
  finally: 
   cursor.close() 
 #### 5、分別傳入?yún)?shù)，代入上方函數(shù)，執(zhí)行操作 ### 
 def trans_for(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) 
   #提交當(dāng)前事務(wù) 
   self.conn.commit() 
  except Exception as e: 
   #若出錯(cuò)，回滾當(dāng)前事務(wù) 
   self.conn.rollback() 
   raise e 
if __name__=="__main__": 
 # source_acctid=sys.argv[1] 
 # target_acctid=sys.argv[2] 
 # money=sys.argv[3] 
 #建立與數(shù)據(jù)庫(kù)的鏈接 
 conn = MySQLdb.Connect( 
       host='127.0.0.1', 
       port=3306, 
       user='root', 
       passwd='12345678', 
       db='tt', 
       charset='utf8' 
       ) 
 #手動(dòng)輸入減款人、收款人、轉(zhuǎn)款數(shù) 
 source_acctid=raw_input("請(qǐng)輸入減款人： ") 
 target_acctid=raw_input("請(qǐng)輸入收款人： ") 
 money=raw_input("請(qǐng)輸入轉(zhuǎn)款數(shù)： ") 
 #將參數(shù)傳入類(lèi)中 
 tr_money=Trans_for_Money(conn) 
 try: 
  tr_money.trans_for(source_acctid,target_acctid,money) 
 except Exception as e: 
  print"出現(xiàn)問(wèn)題："+str(e) 
 finally: 
  conn.close() 
  #關(guān)閉鏈接

三、問(wèn)題解決

1、sys.argv[ ]

因?yàn)榻虒W(xué)視頻中用的IDE是MyEclipse，最后用run.Configuration 輸入?yún)?shù)，而我用的是pycharm，表示笨的找不到還是其實(shí)它沒(méi)有！

所以選擇用raw_input() 在執(zhí)行過(guò)程中輸入?yún)?shù)

其實(shí)有去了解sys.argv[ ]，但還是懂不太清楚。

2、 mysql_exceptions.IntegrityError: (1062, "Duplicate entry '7' for key 'PRIMARY'")

這個(gè)錯(cuò)誤表示你所要插入的數(shù)據(jù)已經(jīng)存在，最好去觀察一下數(shù)據(jù)庫(kù)的數(shù)據(jù)與自己的程序操作是否有矛盾

3、MySql 建表或輸入數(shù)值時(shí)出錯(cuò)：1170-BLOB/TEXT column‘name'used in key specification without a key length

錯(cuò)誤信息為BLOB或者TEXT字段使用了未指定鍵值長(zhǎng)度的鍵

解決方法：設(shè)置其他為主鍵或將數(shù)據(jù)形式改為varchar

具體解釋網(wǎng)址：http://myhblog1989.blog.163.com/blog/static/183225376201110875818884/

4、TypeError: 'post' is an invalid keyword argument for this function