python数据库编程

user                     用户名
password             　　密码
host                     主机名
database             　　数据库名　　MySQLdb数据库使用的是db
dsn                      数据源名
connect()函数通过 Connection 对象访问数据库。兼容模块必须实现 connect()函数，该函数创建并返回一个 Connection 对象。

close()                        　　　　　　 　关闭数据库连接
commit()                        　　　　　　  提交当前事务
rollback()                        　　　　　　取消当前事务
cursor()                        　　　　　　  使用该连接创建（并返回）一个游标或类游标的对象
errorhandler(cxn,cur,errcls,errval)          作为给定连接的游标的处理程序                                

arraysize                    　　　　　　使用fetchmany方法时，一次取出的结果行数，默认为1
connection                  　　　　　　 创建此游标的链接（可选）
description                  　　　　　　返回游标活动状态（7选项元组）:（name,type_code,display_size,internal_size,precision,scale,null_ok）
lastrowid                    　　　　　　上次修改的行ID（可选：如果不支持行ID，则返回None）
rowcount                    　　　　　　 上次execute*()方法处理或影响的行数
callproc(func[,args])      　　　　　　  调用储存过程
close()                        　　　　  关闭游标
execute(op[,args])        　　　　　　　 执行数据库查询或命令
executemany(op,args)    　　　　　　　　 类似execute()和map()的结合，为给定的所有参数准备执行的数据库查询或命令
fetchone()                    　　　　   获取查询结果的下一行
fetchmany([size=cursor.arraysize])      获取查询结果的下面size行
fetchall()                       　　   获取查询结果的所有（剩余）行
__iter__()                      　　　  为游标创建迭代器对象（可选，参考next()）
messages                       　　　　 游标执行后从数据库中获取的消息列表（元组结合，可选）
next()                           　　   被迭代器用于获取查询结果的下一行（可选，类似fetchone()，参考__iter__()）
nextset()                        　　   移动到下一个结果集合（如果支持）
rownumber                      　　    当前结果集中游标的索引（以行为单位，从0开始，可选）
setinputsizes(sizes)          　　　　　设置允许的最大输入大小（必须有，但是实现是可选的）
setoutputsize(size[,col])   　　　　　　设置大列获取的最大缓冲区大小（必须有，但是实现是可选的）

Date (yr, mo, dy)　　　　　　　　　　　　　　　　  日期值对象
Time (hr, min, sec) 　　　　　　　　　　　　　    时间值对象
Timestamp (yr, mo, dy, hr, min, sec) 　　　　    时间戳值对象
DateFromTicks (ticks) 　　　　　　　　　　　　　  日期对象，给出从新纪元时间（1970 年 1 月 1 日 00:00:00 UTC）以来的秒数
TimeFromTicks (ticks) 　　　　　　　　　　　　　  时间对象，给出从新纪元时间（1970 年 1 月 1 日 00:00:00 UTC）以来的秒数
TimestampFromTicks (ticks) 　　　　　　　　　　  时间戳对象，给出从新纪元时间（1970 年 1 月 1 日 00:00:00 UTC）以来的秒数
Binary (string) 　　　　　　　　　　　　　　　　  对应二进制（长）字符串对象
STRING 　　　　　　　　　　　　　　　　　　　　　 表示基于字符串列的对象，比如 VARCHAR
BINARY 　　　　　　　　　　　　　　　　　　　　　  表示（长）二进制列的对象，比如 RAW、BLOB
NUMBER 　　　　　　　　　　　　　　　　　　　　　　表示数值列的对象
DATETIME 　　　　　　　　　　　　　　　　　　　　 表示日期/时间列的对象
ROWID 　　　　　　　　　　　　　　　　　　　　　　表示“行 ID”列的对象

打开cmd输入：pip3 install mysqlclient    安装mysql驱动

>>> import MySQLdb as mysql         导入MySQL驱动重名为mysql
>>> conn = mysql.connect('127.0.0.1','root','root')            连接数据库
>>> conn = mysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='test', charset='utf8')        也可以使用关键字连接数据库
>>> config = {
    'host': '127.0.0.1',
    'port': 3306,
    'user': 'root',
    'passwd': 'root',
    'db': 'test',
    'charset': 'utf8'
}
>>> conn = mysql.connect(**config)        也可以使用字典连接数据库
>>> cur = conn.cursor()　　　　　　创建cursor对象
>>> cur.execute('create table users (id varchar(20) primary key, name varchar(20))')         创建users表
>>> id = 1
>>> name = "smelond"
>>> cur.execute("insert into users values('%s','%s')" % (id,name))            插入一行记录，注意MySQL的占位符是%s
>>> cur.execute("update users set id=2 where id=1")                      修改一行记录
>>> cur.execute("select * from users")                    查询记录
>>> values = cur.fetchall()                    将查询的记录赋给values
>>> values                                         输出values
(('2', 'smelond'),)
>>> cur.execute("insert into users values(3,'admin')")                     再次添加记录
>>> cur.execute("select * from users")
>>> values = cur.fetchall()
>>> values
(('2', 'smelond'), ('3', 'admin'))

>>> conn.commit()             提交
>>> cur.close()              关闭cursor
>>> conn.close()                关闭connection

pip3 install sqlalchemy

# 导入模块
from sqlalchemy import Column, String, create_engine, INT
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 创建对象的基类:
Base = declarative_base()


# 定义User对象
class User(Base):
    __tablename__ = "users"

    # 表的结构
    id = Column(INT, primary_key=True)
    name = Column(String(20))


# 初始化数据库连接
# create_engine()用来初始化数据库连接。SQLAlchemy用一个字符串表示连接信息
engine = create_engine("mysql://root:root@127.0.0.1:3306/test")
# 创建DBSession类型
DBSession = sessionmaker(bind=engine)

# 创建session对象
session = DBSession()
# 创建新User对象
new_user = User(name='smelond')  # 由于我在数据库里面设置id为主键，并且自动增长，所以这个地方可以不带id。
# 添加到session
session.add(new_user)
# 提交即保存到数据库
session.commit()
# 关闭session
session.close()

# 创建session对象
session = DBSession()
# 创建Query查询，filter是where条件，最后调用one()返回唯一行，如果条用all()则返回所有行：
result = session.query(User).filter(User.name == 'smelond').one()
print("type:", type(result))
print("name:", result.name)
session.close()


结果:
type: <class '__main__.User'>
name: smelond