SQLAlchemy

Python publisher01 32℃ 0评论

灵魂三问大法:


乔巴.png

一、是个啥?

​ SQLAlchemy是Python中最著名的ORM框架,该框架建立在数据库API之上,使用关系对象映射进行数据库操作,简单点:将对象转换成SQL,然后使用数据API执行SQL语句来操作数据库。

二、有啥用?

​ 能够让我们将对数据库的操作(主要指SQL语句)转换为对对象属性的操作。也就是我们将数据表抽象成一个ORM对象,然后通过一系列简单的操作就可以完成数据库操作。多数web框架都可以使用sqlalchemy

三、咋用?

​ ORM

1 class-obj

创建一个Class

from sqlalchemy.ext.declarative_base import declarative_base
from sqlalchemy import Column,Integer,INT,INTEGER,VARCHAR,String,NVARCHAR
Base = declarative_base()  # 这个Base就是ORM模型的基类
class User(Base):
  __tablename__ = 'user'  # 数据库表名
   id = Cloumn(Integer,primary_key=True,autoincrenment=True)  # 这是一个字段Integer类型 等效于INT 等效于INTEGER,you happy is good;主键,自增。
  name = Cloumn(String(32),index=True)  # String 等效于VARCHAR,you happy is good, 索引。   
2 创建数据库引擎

创建数据引擎

from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/sqlalchemy_s?charset=utf8")
3 将所有的class序列化成数据表

将所有继承Base的Class序列化成数据表

Base.metadata.create_all(engine)  # mysql模块要确认是否已安装 
4 ORM操作-CRUD
1 增加数据

回顾一下我们使用原生SQL对数据库的操作步骤(以navcat可视化操作为例方便理解记忆):

  1. 选中数据库(表)
  2. 创建查询窗口
  3. 创建SQL语句
  4. 点击运行

ORM操作步骤是一样的一一对应的:

  1. 创建数据库引擎,导入数据库引擎

    from create_table import engine
    
  2. 创建查询窗口,必须是选中的数据库的查询窗口

    from sqlalchemy.orm import sessionmaker
    Session_window = sessionmaker(engine)
    db_session = Session_window()  # 打开查询窗口
    
  3. 增加数据

    # INSERT INTO table(name) VALUES('Gavin');
    from create_table import User
    User(name="Gavin") # 创建一个SQL语句
    db_session.add(user_obj)  # 将SQL语句粘贴到查询窗口中
    sb_session.commit()  # 执行全部的sql语句 相当于点击运行按钮
    db_session.close()  # 关闭窗口
    
  4. 增加多条数据

    from create_table import User
    user_obj_list = [User(name="Carrie"),User(name="Gavin")]
    db_session.add_all(user_obj_list)
    db_session.commit()
    db_session.close()
    
2 查询数据
# SELECT # FROM 数据源
# 1 创建查询窗口
from create_table import engine,user
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()
# 2 使用查询窗口进行查询
user_obj = db_session.query(User).first()  # 查询单个数据对象
print(user.id, user.name)
user_obj_list = db_session.query(User).all()  # 查询全部数据对象
print(user_obj_list)
for row in user_obj_list:
    print(row.id ,row.name)
    
user_obj_list = db_session.query(User).filter(User.id <=2, User.name=='Gavin').all()  # 查询符合filter表达式的全部数据对象
print(user_obj_list)
for row in user_obj_list:
    print(row.id ,row.name)
    
user_obj_list = db_session.query(User).filter_by(id=2, name=='Gavin').all()  # filter_by是通过传参的方式进行查询,效果等同于filte,大于用gt,小于用lt等等
3 UPDATE
# UPDATE table SET name="Gavin" WHERE id=1;
# 1 创建查询窗口
from sqlalchemy.orm import sessionmaker
from create_table import engine,User
Session = sessionmaker(engine)
db_session = Session()
# 2 修改一条数据
user_obj = db_session.query(User).filter(id==1).update({"name":"Carrie"})
print(user_obj)  # 这里返回的是受影响的行数
db_session.commit()  # 执行
# 3 修改多条数据
user_obj = db_session.query(User).filter(id>=1).update({"name":"Gavin"})
print(user_obj)  # 这里打印的是受影响的行数
db_session.commit()  # 执行
4 删除
# DELETE FROM table --删除表数据保留表
# 1 创建查询窗口
from sqlalchemy.orm import sessionmaker
from create_table import engine,User
Session = sessionmaker(engine)
db_session = Session()
# 2 删除单条数据
res = db_session.query(User).filter(User.id==1).delete()
print(res)  # 这里打印的是受影响的行数
db_session.commit()  # 执行
# 3 删除多条数据
res = db_session.query(User).filter(User.id>=1).delete()
print(res)  # 这里打印的是受影响的行数
db_session.commit()  # 执行

好,以上就是SQLALchemy的ORM操作,就是这么简单,OVER!!!






好吧,其实没那么简单,这里只是完成了单表的操作,未完待续。。。

你或许想:《去原作者写文章的地方

转载请注明:Python量化投资 » SQLAlchemy

喜欢 (0)or分享 (0)
发表我的评论
取消评论
表情

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址