主要参考官方文档,看不懂的地方上网查的
The SQLAlchemy Object Relational Mapper presents a method of associating user-defined Python classes with database tables, and instances of those classes (objects) with rows in their corresponding tables.
用户定义类 <—> 数据库表格 类的实例 < —–> 表格中的行
engine是连接数据库的核心接口
from sqlalchemy import create_engine engine = create_engine('mysql+mysqldb://{0}:{1}@{2}:{3}/{4}?charset={5}'.format( config_database['alarm']['username'], config_database['alarm']['password'], config_database['alarm']['host'], config_database['alarm']['port'], config_database['alarm']['database'], config_database['alarm']['charset'] ), pool_recycle=3600)Base 是 declarative_base类的实例,也是一个类。自己定义的与数据库表格对应的类继承Base类。
from sqlalchemy.ext.declarative import declarative_base Base = declarative_base()可以用mymetadata.tables[tablename]取得继承Base的Table类。
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import MetaData mymetadata = MetaData() Base = declarative_base(metadata = mymetadata)User是自己定义的类, users是数据库中表格的名字。__tablename__ 必不可少。
from sqlalchemy import Column, Integer, String class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True) name = Column(String) fullname = Column(String) password = Column(String)可以用__table__查看类的定义
>>> User.__table__ # 打印出来的结果 Table('users', MetaData(bind=None), Column('id', Integer(), table=<users>, primary_key=True, nullable=False), Column('name', String(), table=<users>), Column('fullname', String(), table=<users>), Column('password', String(), table=<users>), schema=None)用session来处理数据库的增删改查
from sqlalchemy.orm import sessionmaker Session = sessionmaker(bind = engine) session = Session()因为实例与table的行相对应,所以要操作table的行在sqlalchemy中就是直接操作实例
# 增一行 session.add(User(name = 'ed', fullname = 'Ed Jones', password = 'password')) #增多行 -> 用list传递多个实例 session.add_all([User(...), User(...)])query()中写的是类名或类名的属性名,可多选 filter()中写的是表达式,用于过滤
# 返回的是一个迭代器 out = session.query(User).filter_by(name='ed') # 返回一个list out.all() # 返回第一个实例, 不存在返回None out.first() # 返回所有的行,如果不是正好一行就raise an error out.one() # 正好一行返回这一行,没有返回None, 多于一行raise an error out.one_or_none() # 如果有记录,返回第一条记录 out.scalar()用text即可用字符串处理, from_statement()可以用sql语句处理
from sqlalchemy import text for user in session.query(User).\ filter(text("id<224")).\ order_by(text("id")).all() session.query(User).from_statement(text("SELECT * FROM users where name=:name")).\ params(name='ed').all()慢慢补吧,不想写了