1. python DB api简介
python DB api python访问数据库的统一接口规范，详细可参考https://www.python.org/dev/peps/pep-0249/
python DB api中主要包括三个重要的对象 数据库连接对象 connection，数据库交互对象 cursor和数据库异常类 exceptions
2. 使用python DB API访问数据库的流程
3. python+MYSQL开发环境的配置
python-mysql connector 用于python和mysql服务器进行连接，下载地址 https://sourceforge.net/projects/mysql-python/
syslog是一个Mysql可视化的管理工具， 下载地址 https://sqlyog.en.softonic.com/
4 connection对象
使用方法MySQLdb.connection(host,port,user,passwd,db,charset)返回一个connection对象
connection对象支持的方法有
| 方法 | 说明 |
| cursor() | 使用该连接创建并返回的游标 |
| commit() | 提交当前事务 |
| rollback() | 回滚当前事务 |
| close() | 关闭连接 |
连接数据库
1 import MySQLdb 2 conn = MySQLdb.Connect(host = '127.0.0.1', 3 port = 3306, 4 user = 'root', 5 passwd = '123456', 6 db = 'test', 7 charset='utf8') 8 cur = conn.cursor() 9 cur.close() 10 conn.close()
5. 数据库游标对象cursor
cursor对象的方法
execute(op[,args]) 执行一个数据库查询和命令
fetchone() 取得结果集中下一行
fetchmany(size) 获取结果集中下几行
fetchall() 获取结果集剩下的所有行
rowcount 最近一次execute返回的数据的行数或影响的行数
close() 关闭游标对象
我们在数据库中建立了一个test数据库，在其中建立了一个user表如下图所示
利用cursor对象来执行简单的查询语句1 import MySQLdb 2 conn = MySQLdb.Connect(host = '127.0.0.1', 3 port = 3306, 4 user = 'root', 5 passwd = '123456', 6 db = 'test', 7 charset='utf8') 8 cur = conn.cursor() 9 sql = 'select * from user' 10 cur.execute(sql) 11 print cur.rowcount 12 print cur.fetchone() 13 print cur.fetchmany(3) 14 print cur.fetchall() 15 cur.close() 16 conn.close()
输出
9 (1L, u'name1') ((2L, u'name2'), (3L, u'name3'), (4L, u'name4')) ((5L, u'name5'), (6L, u'name6'), (7L, u'name7'), (8L, u'name8'), (9L, u'name9'))
6. 事务处理事务：访问和更新数据库的一个程序执行单元
原子性：事务中包括的诸操作要么都做，要么都不做
一致性：事务必须使数据库从一致性状态变到另一个一致性状态
隔离性：一个事务的执行不能被其他事务干扰
持久性：事务一旦提交，它对数据库的改变是永久性的
开发中怎样使用事务？
关闭自动commit:设置conn.autocommit(False)
正常结束事务：conn.commit()
异常结束事务：conn.rollback()
代码示例
1 import MySQLdb 2 conn = MySQLdb.Connect(host = '127.0.0.1', 3 port = 3306, 4 user = 'root', 5 passwd = '123456', 6 db = 'test', 7 charset='utf8') 8 cur = conn.cursor() 9 sql_insert = "insert into user(usrid, usrname) values(10, 'name10')" 10 sql_delete = "delete from user where usrid<3" 11 sql_update = "update user set usrname = 'name91' where usrid=9" 12 try: 13 cur.execute(sql_insert) 14 cur.execute(sql_update) 15 cur.execute(sql_delete) 16 conn.commit() 17 except Exception as e: 18 print e 19 conn.rollback() 20 cur.close() 21 conn.close()
7. 银行转账实例
假设张三要向王五转账100元，其转账流程如下图所示
代码实现
1 import MySQLdb 2 def checkAccountAvailable(conn,username): 3 cur = conn.cursor() 4 sql = "select * from account where username='%s'"%username 5 print sql 6 cur.execute(sql) 7 r = cur.rowcount 8 print r 9 cur.close() 10 return r 11 12 def account(conn, username): 13 cur=conn.cursor() 14 sql = "select * from account where username='%s'"%username 15 print sql 16 cur.execute(sql) 17 account = cur.fetchone()[1] 18 cur.close 19 return account 20 def main(): 21 conn = MySQLdb.Connect(host = '127.0.0.1', 22 port = 3306, 23 user = 'root', 24 passwd = '123456', 25 db = 'test', 26 charset='utf8') 27 if checkAccountAvailable(conn,'zhangsan') and checkAccountAvailable(conn,'wangwu'): 28 if account(conn,"zhangsan") >= 100: 29 try: 30 cur = conn.cursor() 31 cur.execute("update account set account=account-100 where username='zhangsan'") 32 cur.execute("update account set account=account+100 where username='wangwu'") 33 conn.commit() 34 except Exception as e: 35 print e 36 conn.rollback() 37 finally: 38 cur.close() 39 else: 40 print "zhangsan has not enough money" 41 else: 42 print "account not existed" 43 44 conn.close() 45 main()
null
