ORM

不管后端业务逻辑交互怎么样，最终的数据是要储存在数据库的，因为目前市面上的数据库比较多比如SqlServer、oracle、mysql等等，但是如果项目可能根据需要，使用不同的数据库，因为每个数据库各自语言有差异：

image.png

那是不是针对每个数据库再重写一次SQL，还是该怎么办呢？

image.png

ORM全称 Object Relational Mapping对象关系映射。

SQLAlchemy连接数据库

SQLAlchemy 是 python 中常用的 ORM 框架，该框架建立在数据库API之上，使用关系对象映射进行数据库操作，简言之便是：将对象转换成SQL，然后使用数据API执行SQL并获取执行结果。
具体操作如下？
1、安装
安装： mysql
安装python包： pymysql、sqlalchemy
可以使用国内豆瓣源，速度快点：

pip install -i https://pypi.douban.com/simple pymysql
pip install -i https://pypi.douban.com/simple sqlalchemy

2、导入模块

from sqlalchemy import create_engine

3、数据库配置信息

HOSTNAME = '127.0.0.1'
PORT = '3306'  #注意这个不是本地端口是指远程数据库端口，因为pycharm已经先SSH连接到本地了
DATABASE = 'my_db'
USERNAME = 'root'
PASSWORD = '1q2w3e4r'

db_url = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(
    USERNAME,
    PASSWORD,
    HOSTNAME,
    PORT,
    DATABASE
)

PS：若不知道mysql的操作，则可以看前面Django环境搭建的文章。
4、连接数据库

#连接数据库
engine = create_engine(db_url)

5、测试连接

if __name__ == '__main__':
    connetion = engine.connect()
    result = connetion.execute('select 1')
    print(result.fetchone())

image.png

Module

上面步骤使用SQLAlchemy连上数据库，现在就需要操作数据库，新建一个表。
1、创建 Module 的 Base 类

from sqlalchemy.ext.declarative import declarative_base 
Base = declarative_base(engine)

对象关系型映射，数据库中的表与python中的类相对应，创建的类必须继承自 sqlalchemy 中的基类。
使用 declarative 方法定义的映射类依据一个基类，这个基类是维系类和数据表关系的目录。
应用通常只需要有一个 Base 的实例。我们通过 declarative_base() 功能创建一个基类。
2、创建Module

class User(Base):
    __tablename__ = 'users' #数据库中表明
    id = Column(Integer,primary_key=True,autoincrement=True) #Column 用来创建表字段的一个方法
    username = Column(String(12))
    password = Column(String(20))
    creatime = Column(DateTime,default=datetime.now)
    _locked = Column(Boolean,default=False,nullable=False)

用类来表示数据库里面的表，这些表的类都继承于我们的Base基类。
在类里面我们定义一些属性，这个属性通过映射，就对应表里面的字段。
3、映射到数据库中

if __name__ == '__main__':
    Base.metadata.create_all()

增删改查

1、创建会话

from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine)
session = Session()

在对表数据进行增删改查之前，先需要建立会话，建立会话之后才能进行操作，就类似于文件要打开之后才能对文件内容操作。
2、增加 add

def add_user(): #增加
    author = User(username='cainiao',password='1234')
    session.add(author) #插入一条

    session.add_all([
        User(username='cainiao2', password='1234'),
        User(username='cainiao3', password='1234'),
        User(username='cainiao4', password='1234'),

    ]) #一次性插入多条数据

    session.commit()  #提交

3、查询 query

def query_user():  #查询
    all_record = session.query(User).all() #查询所有，相当于select * from user1
    first_record = session.query(User).first() #查询第一个，类似limit

    print(all_record)
    print(first_record)

4、修改 update

def update_user(): #修改
    rows = session.query(User).filter(User.username=='cainiao').update({User.password:1})
    session.commit()

5、删除 delete

def delete_user(): #删除
    rows = session.query(User).filter(User.username=='cainiao')[0]
    print(rows)
    session.delete(rows)
    session.commit()

总的代码：

image.png

from sqlalchemy import create_engine

HOSTNAME = '127.0.0.1'
PORT = '3306'  #注意这个不是本地端口是指远程数据库端口，因为pycharm已经先SSH连接到本地了
DATABASE = 'my_db'
USERNAME = 'root'
PASSWORD = '1q2w3e4r'

# mysql + pymysql://username:password@hostname:port/database?charset=utf8

db_url = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(
    USERNAME,
    PASSWORD,
    HOSTNAME,
    PORT,
    DATABASE
)

engine = create_engine(db_url)

from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base(engine)


from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine)
session = Session()

if __name__ == '__main__':
    connetion = engine.connect()
    result = connetion.execute('select 1')
    print(result.fetchone())

user_module.py文件代码：

from datetime import datetime
from sqlalchemy import Column,Integer,String,DateTime,Boolean
from connect import Base

class User(Base):
    __tablename__ = 'users' #数据库中表明
    id = Column(Integer,primary_key=True,autoincrement=True) #Column 用来创建表字段的一个方法
    username = Column(String(12))
    password = Column(String(20))
    creatime = Column(DateTime,default=datetime.now)
    _locked = Column(Boolean,default=False,nullable=False)


if __name__ == '__main__':
    Base.metadata.create_all()

test_user_module.py代码：

from connect import session
from user_module import User

def add_user(): #增加
    author = User(username='cainiao',password='1234')
    session.add(author) #插入一条

    session.add_all([
        User(username='cainiao2', password='1234'),
        User(username='cainiao3', password='1234'),
        User(username='cainiao4', password='1234'),

    ]) #一次性插入多条数据

    session.commit()  #提交


def query_user():  #查询
    all_record = session.query(User).all() #查询所有，相当于select * from user1
    first_record = session.query(User).first() #查询第一个，类似limit

    print(all_record)
    print(first_record)


def update_user(): #修改
    rows = session.query(User).filter(User.username=='cainiao').update({User.password:1})
    session.commit()

def delete_user(): #删除
    rows = session.query(User).filter(User.username=='cainiao')[0]
    print(rows)
    session.delete(rows)
    session.commit()

if __name__ == '__main__':

    add_user()
    query_user()
    # update_user()
    # delete_user()

注意：想要from connect import Base不报错（报错时是可以运行代码的）
在data文件夹里面右键 选中Mark directory as 选中sources root。

image.png