python sqlalchemy入门

参考：

Python SQLAlchemy入门教程(基本用法)SQLAlchemy入门和进阶SQLAlchemy 查询语句

sqlalchemy是一个ORM–Object Relational Mapping（对象关系映射）工具，同样的工具还有pymysql，Django ORM

1 概念与数据类型

概念：

常见数据类型

2 定义数据库表类

为了代码易读结构清晰，建议将定义数据库表的类单独放在一个文件中，比如models.py

# models.py from sqlalchemy import Column, Text, String, Integer, DateTime from sqlalchemy.ext.declarative import declarative_base # 创建映射类需要继承声明基类，使用 declarative_base Base = declarative_base() # 构建数据库表的基类 class Data(Base): # 定义映射类 __tablename__ = 'news_data' # 数据库表名 id = Column(Integer, primary_key=True) # 表中各字段 title = Column(String(64)) times = Column(DateTime) content = Column(Text) types = Column(String(32))

declarative_base()是sqlalchemy内部封装的一个方法，通过其构造一个基类，这个基类和它的子类，可以将Python类和数据库表关联映射起来。

数据库表模型类通过__tablename__和表关联起来，Column表示数据表的列。

从这里可以看到，模型定义与数据库是无关的，所以允许不同的数据库后端，不同类型拥有不同的表现形式和建表语句

3 连接数据库 创建数据库表

from sqlalchemy import create_engine from models import Base, Data # 连接数据库 engine = create_engine("mysql+pymysql://root:123456@localhost:3306/one", encoding='utf-8') # 创建在models.py中定义的所有数据库表，如果存在则忽略 Base.metadata.create_all(self.engine)

声明基类 Base 在创建之后并不会主动连接数据库，因为它的默认设置为惰性模式。Base 的 metadata 有个 create_all 方法，执行此方法会主动连接数据库并创建全部数据表，完成之后自动断开与数据库的连接

4 操作数据Session

sqlalchemy中使用session用于创建程序和数据库之间的会话，所有对象的载入和保存都需要通过session对象 。

通过sessionmaker调用创建一个工厂，并关联Engine以确保每个session都可以使用该Engine连接资源：

from sqlalchemy import create_engine from models import Base, Data # 连接数据库 engine = create_engine("mysql+pymysql://root:123456@localhost:3306/one", encoding='utf-8') # 创建在models.py中定义的所有数据库表，如果存在则忽略 Base.metadata.create_all(self.engine) # 创建session DBsession = sessionmaker(bind=self.engine) session = DBsession()

4.1 增

# 方式1 new = Data() new.title = item['title'] new.times = item['times'] new.content = item['desc'] new.types = item['n_type'] session.add(new) # 方式2 add_data = Data(title='title', times='times', content='content', types='types') session.add(add_data) session.commit()

session.add()将会把Model加入当前session维护的持久空间(可以从session.dirty看到)中，直到commit时提交到数据库。

4.2 查

参考SQLAlchemy查询语句