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
connect.py文件代码：
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
注意：直接运行py文件不能这样，框架班讲过的，要标记这个目录成 source root，app.py在项目根目录下，这个在子目录里所以需要设置，如果设置了则
.要去掉。记得如果此文件不为直接运行的，则记得要加上.
网友评论