Python使用MySQL数据库的方法以及一个实例

冷不防 2022-05-23 09:59 163阅读 0赞

使用环境：Windows+python3.4+MySQL5.5+Navicat

一、创建连接

1.准备工作，想要使用Python操作MySQL，首先需要安装MySQL-Python的包，在Python 3.x下，该包已经改名为MySQLClient。可以使用pip方式安装：

pip install MySQLClient

或者下载包文件，进行安装也可以。

2.Python使用MySQL的流程：

![795592-20160724120952669-1336852438.png][]

3.启动MySQL服务器：以管理员身份启动“cmd”，输入命令：’net start mysql‘

Python中使用MySQL导入方法：import MySQLdb

4.创建Connection

Connection：创建了Python客户端与数据库之间的网络通路。他的参数如下

<table style="width:478px;height:138px;"> 
 <tbody> 
  <tr> 
   <td>参数名</td> 
   <td>类型</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>host</td> 
   <td>String</td> 
   <td>MySQL的服务器地址</td> 
  </tr> 
  <tr> 
   <td>port</td> 
   <td>int</td> 
   <td>MySQL的端口号</td> 
  </tr> 
  <tr> 
   <td>user</td> 
   <td>String</td> 
   <td>用户名</td> 
  </tr> 
  <tr> 
   <td>passwd</td> 
   <td>String</td> 
   <td>密码</td> 
  </tr> 
  <tr> 
   <td>db</td> 
   <td>String</td> 
   <td>使用的数据库</td> 
  </tr> 
  <tr> 
   <td>charset</td> 
   <td>String</td> 
   <td>连接字符集</td> 
  </tr> 
 </tbody> 
</table>

Connection支持的方法：

<table style="width:419px;height:100px;"> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>cursor（）</td> 
   <td>创建并且返回游标</td> 
  </tr> 
  <tr> 
   <td>commit（）</td> 
   <td>提交当前事物</td> 
  </tr> 
  <tr> 
   <td>rollback()</td> 
   <td>回滚当前事物r()</td> 
  </tr> 
  <tr> 
   <td>close()</td> 
   <td>关闭Connection</td> 
  </tr> 
 </tbody> 
</table>

5.获取Cursor.

Cursor:游标对象，用于执行查询和获取结果，它支持的方法如下：

<table style="width:508px;height:179px;"> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>execute()</td> 
   <td>用于执行一个数据库的查询命令</td> 
  </tr> 
  <tr> 
   <td>fetchone()</td> 
   <td>获取结果集中的下一行</td> 
  </tr> 
  <tr> 
   <td><p>fetchmany(size)</p></td> 
   <td>获取结果集中的下（size）行</td> 
  </tr> 
  <tr> 
   <td>fetchall()</td> 
   <td>获取结果集中剩下的所有行</td> 
  </tr> 
  <tr> 
   <td>rowcount</td> 
   <td>最近一次execute返回数据/影响的行数</td> 
  </tr> 
  <tr> 
   <td>close()</td> 
   <td>关闭游标</td> 
  </tr> 
 </tbody> 
</table>

下面我们在Python中创建一个实例：

![复制代码][copycode.gif]

import MySQLdb
    
    conn=MySQLdb.connect(host='127.0.0.1',port=3306,user='root',passwd='199331',db='test',charset='utf8')
    
    cursor=conn.cursor()
    
    print(conn)
    print(cursor)
    
    cursor.close()
    conn.close()

![复制代码][copycode.gif]

运行程序结果如下：![795592-20160724125949357-317288545.png][]

从结果中我们可以看见成功创建了一个Connection和Cursor对象。

二、建立数据库，进行一些简单操作

1.简单的创建一个’user‘表，并且插入一些数据。user表中只有两个字段：userid和username。代码如下：

![复制代码][copycode.gif]

import MySQLdb
    conn=MySQLdb.connect(host='127.0.0.1',port=3306,user='root',passwd='199331',db='test',charset='utf8')
    cur=conn.cursor()
    
    cur.execute("""
    create table if not EXISTS user
    (
      userid int(11) PRIMARY KEY ,
      username VARCHAR(20)
    )
    """)
    for i in range(1,10):
        cur.execute("insert into user(userid,username) values('%d','%s')" %(int(i),'name'+str(i)))
    conn.commit()
    
    cur.close()
    conn.close()

![复制代码][copycode.gif]

我们用Navicat打开数据库，查看一下结果，，可以看到成功创建表，并且插入了十个数据。

2.我们操作一下Cursor里面的一些方法。

execute()方法：执行SQL，将一个结果从数据库获取到客户端

fetch\*（）方法：移动rownumber，返回数据。

例如我们有如下代码：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <span style="font-family:NSimsun;"><code>sql</code><code>=</code><code>'select * from user'</code></span> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">cursor.execute(sql)</span></code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(cursor.rowcount)</code></span> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>rs</code><code>=</code><code>cursor.fetchone()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(rs)</code></span> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>rs</code><code>=</code><code>cursor.fetchmany(</code><code>3</code><code>)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(rs)</code></span> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

rs=cursor.fetchall()print(rs)

结果如下：

我们可以看出执行查询全部数据后，rowcount为10

执行fetchone（）方法后返回一个数据，执行fetchmany(3)后返回3条数据，执行fetchall（）后返回剩下的所有数据。

再有如下代码：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <span style="font-family:NSimsun;"><code>res</code><code>=</code><code>cursor.fetchall()</code></span> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">for</span></code> 
      <span style="font-family:NSimsun;"><code>row </code><code>in</code></span> 
      <code><span style="font-family:NSimsun;">res:</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'userid=%s,userna=%s'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>row)</code></span> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

此时的执行结果为：

3.上面介绍的便是数据库中常说的Select操作，下面我们介绍数据的更新，即：insert、update、delete操作。值得注意的是在这部分操作时需要注意的是是否数据发生异常，如果数据没有发生异常，我们便可以直接使用commit()进行提交（注：如没有使用commit，则数据库不会发生任何变化）。但是如果出现了异常，那么久需要使用rollback()进行回滚。

3.1先来看一个没有异常，正常提交的例子：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <span style="font-family:NSimsun;"><code>sql_insert</code><code>=</code><code>'insert into user(userid,username) values(10,"name10")'</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>sql_update</code><code>=</code><code>'update user set username="name91" where userid=9'</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>sql_delete</code><code>=</code><code>'delete from user where userid=3'</code></span> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">cursor.execute(sql_insert)</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(cursor.rowcount)</code></span> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">cursor.execute(sql_update)</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(cursor.rowcount)</code></span> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">cursor.execute(sql_delete)</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>print</code><code>(cursor.rowcount)</code></span> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

conn.commit()

上面的操作即是：添加一条（10，’name10‘）的数据、将userid=9的username修改为’name91‘，删除userid=3的数据，执行上面代码后我们来用Navicat查看一下数据：

从结果可以看到代码执行正常。

3.2.再来看一个有异常的数据

[?][Link 1]

这里的insert和update操作一样，只不过把delete里面的userid字段错误的写成了useri，执行代码：

可以看到显示出异常，这时我们来看一下数据库数据：

数据没有任何改变。这就是rollback（）的作用

因此，我们以后再写增删改查操作时，最好把操作放入一个try控制块中，来避免一些不必要的错误。

下面是一个银行转账的实例：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div> 
    <div>
      31 
    </div> 
    <div>
      32 
    </div> 
    <div>
      33 
    </div> 
    <div>
      34 
    </div> 
    <div>
      35 
    </div> 
    <div>
      36 
    </div> 
    <div>
      37 
    </div> 
    <div>
      38 
    </div> 
    <div>
      39 
    </div> 
    <div>
      40 
    </div> 
    <div>
      41 
    </div> 
    <div>
      42 
    </div> 
    <div>
      43 
    </div> 
    <div>
      44 
    </div> 
    <div>
      45 
    </div> 
    <div>
      46 
    </div> 
    <div>
      47 
    </div> 
    <div>
      48 
    </div> 
    <div>
      49 
    </div> 
    <div>
      50 
    </div> 
    <div>
      51 
    </div> 
    <div>
      52 
    </div> 
    <div>
      53 
    </div> 
    <div>
      54 
    </div> 
    <div>
      55 
    </div> 
    <div>
      56 
    </div> 
    <div>
      57 
    </div> 
    <div>
      58 
    </div> 
    <div>
      59 
    </div> 
    <div>
      60 
    </div> 
    <div>
      61 
    </div> 
    <div>
      62 
    </div> 
    <div>
      63 
    </div> 
    <div>
      64 
    </div> 
    <div>
      65 
    </div> 
    <div>
      66 
    </div> 
    <div>
      67 
    </div> 
    <div>
      68 
    </div> 
    <div>
      69 
    </div> 
    <div>
      70 
    </div> 
    <div>
      71 
    </div> 
    <div>
      72 
    </div> 
    <div>
      73 
    </div> 
    <div>
      74 
    </div> 
    <div>
      75 
    </div> 
    <div>
      76 
    </div> 
    <div>
      77 
    </div> 
    <div>
      78 
    </div> 
    <div>
      79 
    </div> 
    <div>
      80 
    </div> 
    <div>
      81 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code><span style="font-family:NSimsun;">#-*- encoding:utf-8 -*-</span></code> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">import</span></code> 
      <code><span style="font-family:NSimsun;">sys</span></code> 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">import</span></code> 
      <code><span style="font-family:NSimsun;">MySQLdb</span></code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">class</span></code> 
      <span style="font-family:NSimsun;"><code>TransferMoney(</code><code>object</code><code>):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>__init__(</code><code>self</code><code>,conn):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.conn</code><code>=</code><code>conn</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>check_acct_available(</code><code>self</code><code>,accid):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor</code><code>=</code><code>self</code><code>.conn.cursor()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sql</code><code>=</code><code>'select * from account where accid=%s'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>accid</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.execute(sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'check_acct_available'</code><code>+</code><code>sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>rs</code><code>=</code><code>cursor.fetchall()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code></span> 
      <span style="font-family:NSimsun;"><code>len</code><code>(rs)!</code><code>=</code><code>1</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>raise</code></span> 
      <span style="font-family:NSimsun;"><code>Exception(</code><code>'账号%s 不存在'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>finally</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.close()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>has_enough_money(</code><code>self</code><code>,accid,money):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor</code><code>=</code><code>self</code><code>.conn.cursor()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sql</code><code>=</code><code>'select * from account where accid=%s and money&gt;%s'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>(accid,money)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.execute(sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'check_money_available'</code><code>+</code><code>sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>rs</code><code>=</code><code>cursor.fetchall()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code></span> 
      <span style="font-family:NSimsun;"><code>len</code><code>(rs)!</code><code>=</code><code>1</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>raise</code></span> 
      <span style="font-family:NSimsun;"><code>Exception(</code><code>'账号%s 没有足够钱'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>finally</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.close()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>reduce_money(</code><code>self</code><code>,accid,money):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor</code><code>=</code><code>self</code><code>.conn.cursor()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sql</code><code>=</code><code>'update account set money=money-%s where accid=%s'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>(money,accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.execute(sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'reduce money'</code><code>+</code><code>sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>rs</code><code>=</code><code>cursor.fetchall()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code></span> 
      <span style="font-family:NSimsun;"><code>cursor.rowcount!</code><code>=</code><code>1</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>raise</code></span> 
      <span style="font-family:NSimsun;"><code>Exception(</code><code>'账号%s 减款失败'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>finally</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.close()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>add_money(</code><code>self</code><code>,accid,money):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor</code><code>=</code><code>self</code><code>.conn.cursor()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sql</code><code>=</code><code>'update account set money=money+%s where accid=%s'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>(money,accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.execute(sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'reduce money'</code><code>+</code><code>sql)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>rs</code><code>=</code><code>cursor.fetchall()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code></span> 
      <span style="font-family:NSimsun;"><code>cursor.rowcount!</code><code>=</code><code>1</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>raise</code></span> 
      <span style="font-family:NSimsun;"><code>Exception(</code><code>'账号%s 加款失败'</code></span> 
      <span style="font-family:NSimsun;"><code>%</code><code>accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>finally</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.close()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code></span> 
      <span style="font-family:NSimsun;"><code>transfer(</code><code>self</code><code>,source_accid,target_accid,money):</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>###检测两个账号是否可用</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.check_acct_available(source_accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.check_acct_available(target_accid)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>####检测付款人是否有足够的钱</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.has_enough_money(source_accid,money)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.reduce_money(source_accid,money)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.add_money(target_accid,money)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.conn.commit()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>except</code></span> 
      <code><span style="font-family:NSimsun;">Exception as e:</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>self</code><code>.conn.rollback()</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>raise</code></span> 
      <code><span style="font-family:NSimsun;">e</span></code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code><span style="font-family:NSimsun;">if</span></code> 
      <span style="font-family:NSimsun;"><code>__name__</code><code>=</code><code>=</code><code>'__main__'</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>source_accid</code><code>=</code><code>sys.argv[</code><code>1</code><code>]</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>target_accid</code><code>=</code><code>sys.argv[</code><code>2</code><code>]</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>money</code><code>=</code><code>sys.argv[</code><code>3</code><code>]</code></span> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>conn</code><code>=</code><code>MySQLdb.connect(host</code><code>=</code><code>'127.0.0.1'</code><code>,port</code><code>=</code><code>3306</code><code>,user</code><code>=</code><code>'root'</code><code>,passwd</code><code>=</code><code>'199331'</code><code>,db</code><code>=</code><code>'test'</code><code>,charset</code><code>=</code><code>'utf8'</code><code>)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>tr_money</code><code>=</code><code>TransferMoney(conn)</code></span> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>tr_money.transfer(source_accid,target_accid,money)</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>except</code></span> 
      <code><span style="font-family:NSimsun;">Exception as e:</span></code> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'出现问题'</code><code>+</code><code>str</code><code>(e))</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>finally</code><code>:</code></span> 
     </div> 
     <div> 
      <span style="font-family:NSimsun;"><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>conn.close()</code></span> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

[795592-20160724120952669-1336852438.png]: /images/20220523/34657ac3441043068549c4fe457466d7.png
[copycode.gif]: /images/20220523/e54f908be7484af8bce63a114d7b3bcc.png
[795592-20160724125949357-317288545.png]: /images/20220523/3ebcd772a9204655a4fef1519de8db99.png
[Link 1]: https://www.cnblogs.com/itdyb/p/5700614.html#