python-mysql
Oct 23, 2018 09:54 · 209 words · 1 minute read
flask中推荐使用SQLAlchemy来操作数据库，再来看一下python标准数据库接口的使用。
安装模块
pip install mysql-python
需要的依赖
sudo apt-get install libmysqlclient-dev libmysqld-dev python-dev python-setuptools
使用
导入模块
#!/usr/bin/env python
# encoding: utf-8
import MySQLdb as mdb
连接数据库
conn = mdb.connect('localhost', 'root', 'root')
conn = mdb.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='test', charset='utf8')
常用方法
cursor用来执行命令的方法:
callproc(self, procname, args) 用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数
execute(self, query, args) 执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数
executemany(self, query, args) 执行单挑sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数
nextset(self) 移动到下一个结果集
cursor用来接收返回值的方法:
fetchall(self) 接收全部的返回结果行.
fetchmany(self, size=None) 接收size条返回结果行.如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据.
fetchone(self) 返回一条结果行.
rowcount 这是一个只读属性,并返回执行execute() 方法后影响的行数。
scroll(self, value, mode=‘relative’) 移动指针到某一行; 如果mode=‘relative’,则表示从当前所在行移动value条,如果 mode=‘absolute’,则表示从结果集的第一行移动value条.
使用cursor()方法获取操作游标
cursor = conn.cursor()
# 因该模块底层其实是调用CAPI的，所以，需要先得到当前指向数据库的指针。
选择数据库
DB_NAME = 'test'
cursor = conn.cursor()
cursor.execute('DROP DATABASE IF EXISTS %s' %DB_NAME)
cursor.execute('CREATE DATABASE IF NOT EXISTS %s' %DB_NAME)
conn.select_db(DB_NAME)
增删改查
要注意的是 在进行更改数据库内容的时候，必须使用commit方法，不然执行没有结果。
查
cursor.execute('select table_name from information_schema.tables limit 0,1') # 取出一条数据 print cursor.fetchone() # 取出5条数据 results = cursor.fetchmany(5) for r in results: print r增
sql = 'INSERT INTO user values("%d","%s")' %(1,"jack") value = [2,'John'] # 不建议直接拼接sql，占位符方面可能会出问题，execute提供了直接传值 cursor.execute('INSERT INTO test values(%s,%s)',value)改
cursor.execute('UPDATE %s SET name = "%s" WHERE id = %s' %(TABLE_NAME,'Jack',1))删
cursor.execute('DELETE FROM %s WHERE id = %s' %(TABLE_NAME,2))
事务方法
- commit
- rollback
网上的例子
import MySQLdb
#包的导入
db = MySQLdb.connect("ip地址，本机为localhost"，"用户名","密码","表名")
#打开数据库的连接
cursor = db.cursor()
#使用cursor()方法获得操作游标
try:
# 执行sql语句
cursor.execute("update account set money=money-600 where name='zhangsan'")
cursor.execute("update account set money=money+600 where name='lisi'")
# 提交到数据库执行
db.commit()
except:
# 发生错误时回滚 回滚到获取游标的位置开始重新执行 看代码上面的文字有说明
db.rollback()
db.close()
简单来事务方法使用就是使数据库的操作更安全。例子中的sql语句是张三给李四转了600元，数据库需要更新他们的信息，这两条sql语句是紧紧关联在一起的，如果不使用事务方法，那么如果给李四转钱的sql语句发生错误，但是第一条也就是扣除张三金钱的sql语句已经执行了，那么这样就会严重影响业务，这个时候事务方法的作用就体现出来了，如果这两天sql语句没有成功执行的话，那么就会执行db.rollback方法，使数据库的内容恢复原样。
如果使用事务引擎，可以设置自动提交事务，或者在每次操作完成后手动提交事务conn.commit()
conn.autocommit(1) # conn.autocommit(True)