初识ORM

ORM(Object Relational Mapping)又被称之为对象关系映射，

我们通过ORM的映射关系，只需要对实体对象的方法和属性进行操作，就可以完成我们对数据库的操作，不必再关心后台使用的是哪种数据库，也不需要跟原生的SQL语句打交道

那么今天我们所说的SQLAlchemy就是ORM里面的其中一种，在SQLAlchemy里面的一个类就对应我们数据库里面的一张表，那么我们应该如何在tornado中去使用它？

安装模块
pip install pymysql
pip install sqlalchemy

连接SQLAlchemy

from sqlalchemy import create_engine  # 导入engine

HOSTNAME = 'localhost'  # IP地址
POST = '3306'  # 端口
DATABASE = 'mydb'  # 要连接的数据库
USERNAME = 'admin'  # 数据库用户
PASSWORD = '123456'  # 数据库密码

# 构造一个url
Db_url = 'mysql+pymysql://%s:%s@%s:%s/%s?charset=utf8' % (
    USERNAME,
    PASSWORD,
    HOSTNAME,
    POST,
    DATABASE
)

engine = create_engine(Db_url)  # 把构造的url放到导入进来的engine

if __name__ == '__main__':
    # 测试连接是否成功
    connection = engine.connect()
    result = connection.execute('select 1')
    print(result.fetchone())

创建module

__tablename__：数据库表名
Column：创建字段的方法
Integer：映射到数据库中的int类型
String：映射到数据库中的varchar类型
DateTime：时间类型

首先我们先在刚才连接数据库的文件中生成一个Base基类

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base(engine)

在module文件中导入Base基类以及创建字段使用的类型

from connect import Base
from sqlalchmy import Column, Integer, String, DateTime, Boolean


class User(Base):
    __tablename__ = 'user'
    id = Column(Integer, primary_key=True, autoincrement=True)
    username = Column(String(20))
    
if __name__ == '__main__':
    Base.metadata.create_all()

执行完成创建

简单增删改查

在数据库连接文件中导入并生成一个session会话

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

Base = declarative_base(engine)

Session = sessionmaker(engine)
session = Session()

导入刚才生成的session会话，利用会话对数据进行操作

from connect import session
from user_modules import User


def add_user():
    """添加数据，默认会开启事务"""
    add_data = User(username='jack', password='123')
    add_datas = [
        User(username='rose1', password='123456'),
        User(username='rose2', password='654321'),
        User(username='rose3', password='321'),
    ]

    session.add(add_data)  # 添加一条
    session.add_all(add_datas)  # 添加多条

    session.commit()  # 提交事务


def query_user():
    """查询数据"""
    row = session.query(User).all()  # 查询所有
    rows = session.query(User).first()  # 查询第一条
    print(row, rows)


def update_user():
    """更新数据，默认开启事务"""
    session.query(User).filter(User.username=='jack').update({User.username: 'xiaoming'})
    session.commit()


def delete_user():
    """删除数据，默认开始事务"""
    rows = session.query(User).filter(User.username=='jack').first()
    session.delete(rows)
    session.commit()


if __name__ == '__main__':
    # add_user()
    # query_user()
    # update_user()
    # delete_user()
    pass