美文网首页
SQLAlchemy

SQLAlchemy

作者: Gavininn | 来源:发表于2019-07-14 22:16 被阅读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!!!






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

    序:https://www.jianshu.com/p/161205d5c4b7

    相关文章

      网友评论

          本文标题:SQLAlchemy

          本文链接:https://www.haomeiwen.com/subject/mgfwkctx.html