Python 使用 MySQL

import MySQLdb

# 建立MySQL连接
connect = MySQL.connect(user=user, passwd=passwd, db=db, host=host, port=port)
cursor = connect.cursor() # 生成游标对象

try:
    cursor.execute('SQL %s', args) # 游标对象执行SQL语句，语句中有%s，则用args替换

    # 执行SELECT语句通过以下方法可获取到查询结果
    result = cursor.fetchall() # 结果为列表，列表每一项代表查询的一row，每行都是一个列表，列表顺序按照SELECT的字段顺序排序
    result = cursor.fetchone() # 获取查询到结果的第一行数据，返回列表，再次运行获取下一条

    cursor.description # 查询到字段定义信息

    [x[0] for x in cursor.description] # 序列的第一个值为字段名称

    # 执行INSERT DELETE操作获取受影响的行数
    r = cursor.rowcount

    # 获取INSERT行的主键值，一般是id
    id = cursor.lastrowid

    connect.commit() # 游标对象执行语句是以事务方式执行，所以需要提交
except: # 如果提交失败
    connect.rollback() # 回滚事务
finnally:
    # 最后关闭游标，连接
    cursor.close()
    connect.close()

from transwarp import db

# 创建数据库链接引擎，然后就可以直接调用数据操作
db.create_engine(user='root', password='password', host='host', port=3306, database='test')

# 直接操作数据查询，返回列表，列表元为字典为查询的每一行数据
user = db.select('select * from user')
# user =>
# [
#     {'id': 1, 'name': 'Timmy Chu'},
#     ......
# ]

# 执行INSERT DELETE UPDATE返回受影响的行数
n = db.update('insert int user(id, name) value(?, ?)', 4, 'Jack')
# n =>
# 1