前往小程序，Get更优阅读体验！
立即前往
文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
首页
学习
活动
专区
工具
TVP最新优惠活动
返回腾讯云官网
社区首页 >专栏 >SALalchemy增删改查

SALalchemy增删改查

原创
作者头像
少年包青菜
修改于 2020-05-13 15:16:01
9750
修改于 2020-05-13 15:16:01
举报
文章被收录于专栏：Python 学习

1.单表操作

1.1创建表

代码语言：javascript
复制
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, INT, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# Base 是 ORM的基类
Base = declarative_base()


# 1.创建表
class User(Base):
    # 表名，最好设定和类名一样
    __tablename__ = 'user'
    # id int类型，主键，自增长
    id = Column(INT, primary_key=True, autoincrement=True)
    name = Column(String(32), index=True)
    age = Column(INT)
    gender = Column(String(100))


# 2.创建数据引擎
engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/my_test?charset=utf8')

# 3.将继承 Base 的类全部转化成表
Base.metadata.create_all(engine)


# 添加字段
def add_column(my_engine, table_name, column):
    """
    :param my_engine: engine 导入的引擎
    :param table_name: 表名 __tablename__
    :param column: # 列名
    :return:
    """
    # 获取列名
    column_name = column.compile(dialect=engine.dialect)
    # 获取属性
    column_type = column.type.compile(engine.dialect)
    print(column_name, column_type)
    # my_engine.execute('ALTER TABLE {} ADD COLUMN {} {}'.format(table_name, column_name, column_type))


add_column(engine, 'user', User.gender)

1.2 增、删、改、查

代码语言：javascript
复制

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from 单表操作.create_table import User

# 1.有一个创建连接的引擎
engine = create_engine(
    'mysql+pymysql://root:123@192.168.1.163:3306/my_test?charset=utf8'
)

# 2.有一个会话窗口
Session_window = sessionmaker(engine)

# 3.建立会话
db_session = Session_window()

1.2.1 增

代码语言：javascript
复制
# 新增一条数据
# db_session.add(User(name='bob', age=22))

# 插入多条数据
db_session.add_all([
    User(name='hello', age=12),
    User(name='shit', age=18),
])

1.2.2 删

代码语言：javascript
复制
# 删除数据，可以多个条件
db_session.query(User).filter(User.id >= 3, User.age >= 15).delete()
db_session.commit()

1.2.3 改

代码语言：javascript
复制
db_session.query(User).filter(User.id >= 2).update({'age': 50})
db_session.commit()

1.2.4 查

代码语言：javascript
复制
# 1.查询单条数据，查询出来是一个列表
# user_obj_list = db_session.query(User).all()
# for user_obj in user_obj_list:
#     print(user_obj.name, user_obj.age)

# 2.带条件的查询
# user_obj = db_session.query(User).filter(User.name == 'leon').first()  # type:User
# print(user_obj.name, user_obj.age)

user_obj_list = db_session.query(User).filter(User.id >= 2, User.age <= 20)
for user_obj in user_obj_list:
    print(user_obj.name, user_obj.age)
代码语言：javascript
复制
db_session.commit()
db_session.close()

2.外键一对多

2.1创建表

代码语言：javascript
复制
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, INT, VARCHAR, ForeignKey
from sqlalchemy.orm import relationship
from sqlalchemy import create_engine

Base = declarative_base()


class Student(Base):
    __tablename__ = 'student'
    id = Column(INT, primary_key=True, autoincrement=True)
    name = Column(VARCHAR(32))
    # 外键关联，表名，小写
    class_id = Column(INT, ForeignKey('classname.id'))
    # relationship 类名，大写
    # backref: 反向查询关键字
    stu_to_class = relationship('ClassName', backref='class_to_stu')


class ClassName(Base):
    __tablename__ = 'classname'
    id = Column(INT, primary_key=True, autoincrement=True)
    class_name = Column(VARCHAR(32))


# 创建引擎
engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/foreign_test?charset=utf8')

Base.metadata.create_all(engine)

2.2插入数据、查看数据

代码语言：javascript
复制
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from 外键一对多.create_table_ForeignKey import Student, ClassName

# 1.创建引擎
engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/foreign_test?charset=utf8')

# 2.有一个会话窗口
Session_window = sessionmaker(engine)

# 3.建立会话
db_session = Session_window()

2.2.1 插入数据

代码语言：javascript
复制
# 正向外键关联插入数据
# db_session.add(Student(name='leon', stu_to_class=ClassName(class_name='linux')))

# 反向插入数据
class_obj = ClassName(class_name='GoLang')
class_obj.class_to_stu = [Student(name='Bob'), Student(name='shit')]
db_session.add(class_obj)

2.2.2 查看数据

代码语言：javascript
复制
# 外键关联正向查询
# stu_list = db_session.query(Student).filter(Student.id >= 1)
# for stu_obj in stu_list:  # type: Student
#     print(stu_obj.name, stu_obj.stu_to_class.class_name)

# 外键关联反向查询
class_list = db_session.query(ClassName).filter(ClassName.id >= 2).all()
for class_obj in class_list:
    class_name = class_obj.class_name
    # 根据班级反向取到所有的学生
    students_list = class_obj.class_to_stu
    for stu_obj in students_list:
        print(class_obj, stu_obj)
代码语言：javascript
复制
db_session.commit()
db_session.close()

3.多对多操作

3.1 创建表，注意 secondary 关键字

代码语言：javascript
复制
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import VARCHAR, INT, Column, create_engine, ForeignKey

Base = declarative_base()


class Man(Base):
    __tablename__ = 'man'
    id = Column(INT, primary_key=True)
    name = Column(VARCHAR(32))
    # secondary: 中间媒介
    # backref: 反向查询关键字
    # secondary: 媒介类是 couples
    man_to_woman = relationship('Woman', backref='woman_to_man', secondary='couples')


class Woman(Base):
    __tablename__ = 'woman'
    id = Column(INT, primary_key=True)
    name = Column(VARCHAR(32))


# 一个 man 可以对应多个 woman
# 一个 woman 可以对应多个 man
class Couples(Base):
    __tablename__ = 'couples'
    id = Column(INT, primary_key=True)
    man_id = Column(INT, ForeignKey('man.id'))
    woman_id = Column(INT, ForeignKey('woman.id'))


engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/many_test?charset=utf8')
Base.metadata.create_all(engine)

3.2 插入数据、查看数据

代码语言：javascript
复制
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from 外键一对多.create_table_ForeignKey import Student, ClassName

# 1.创建引擎
engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/many_test?charset=utf8')

# 2.有一个会话窗口
Session_window = sessionmaker(engine)

# 3.建立会话
db_session = Session_window()

3.2.1 插入数据

代码语言：javascript
复制
# 增加数据，正向relationship
# man_obj = Man(name='李雷')
# man_obj.man_to_woman = [Woman(name='罗玉凤'), Woman(name='韩梅梅')]
# db_session.add(man_obj)


# 增加数据，方向relationship
woman_obj = Woman(name='王菲')
woman_obj.woman_to_man = [Man(name='窦唯'), Man(name='李亚鹏')]
db_session.add(woman_obj)

2.2.2 查询数据

代码语言：javascript
复制
# 正向操作
# man_list = db_session.query(Man).filter(Man.id >= 1).all()
# for man_obj in man_list:
#     man_name = man_obj.name
#     woman_list = man_obj.man_to_woman
#     for woman_obj in woman_list:
#         print(man_name, woman_obj.name)

# 反向操作  
man_list = db_session.query(Woman).filter(Woman.name == '王菲').first().woman_to_man
for man_obj in man_list:
    print(man_obj.name)
代码语言：javascript
复制
db_session.commit()
db_session.close()

4.部分高级操作

4.1 创建表

代码语言：javascript
复制
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, VARCHAR, INT, create_engine
from sqlalchemy.orm import sessionmaker

Base = declarative_base()


class User(Base):
    __tablename__ = 'user'
    id = Column(INT, primary_key=True, autoincrement=True)
    name = Column(VARCHAR(32), index=True)
    age = Column(INT)
    gender = Column(VARCHAR(8))


engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/senior_test?charset=utf8')
Base.metadata.create_all(engine)

4.2 查看数据

代码语言：javascript
复制
from sqlalchemy.orm import sessionmaker
from 高级操作.create_table import User

engine = create_engine('mysql+pymysql://root:123@192.168.1.163:3306'
                       '/senior_test?charset=utf8')

Session_window = sessionmaker(engine)
db_session = Session_window()

4.2.1 or_

代码语言：javascript
复制
# or_
# id=1 或者 id=3 的
# user_list = db_session.query(User).filter(or_(User.id == 1, User.id == 3)).all()
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.2.2 and_

代码语言：javascript
复制
# and_
# 新版本其实 逗号本身已经带了 and_ 的这效果，看情况使用
# user_list = db_session.query(User).filter(and_(User.id == 1, User.name == '张三'))
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.2.3 query(指定字段)

代码语言：javascript
复制
# 查询特定字段，只会查出指定字段
# user_list = db_session.query(User.name, User.gender).all()
# for user_obj in user_list:
#     print(user_obj)

4.2.4 order_by 排序

代码语言：javascript
复制
# 升序
# user_list = db_session.query(User).order_by(User.id).all()
# 降序
# user_list = db_session.query(User).order_by(User.id.desc()).all()
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.2.5 between，在范围内

代码语言：javascript
复制
# user_list = db_session.query(User).filter(User.id.between(2, 3)).order_by(User.id).all()
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.2.6 in_，在指定集合内

代码语言：javascript
复制
# user_list = db_session.query(User).filter(User.id.in_([1, 3, 2])).order_by(User.id).all()
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.2.7 notin_，排除指定范围的，与 in_ 互斥

代码语言：javascript
复制
# user_list = db_session.query(User).filter(User.id.notin_([3, 2])).order_by(User.id).all()
# for user_obj in user_list:
#     print(user_obj.__dict__)

4.3 更新数据

# 本身自增加的写法

代码语言：javascript
复制
# 引用增加
# 所有的 User.age 全部自增长 1
db_session.query(User).update({User.age: User.age + 1})
代码语言：javascript
复制
db_session.commit()
db_session.close()

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
登录 后参与评论
推荐阅读
LV.
文章
0
获赞
0
目录
  • 1.单表操作
    • 1.1创建表
      • 1.2 增、删、改、查
        • 1.2.1 增
        • 1.2.2 删
        • 1.2.3 改
        • 1.2.4 查
    • 2.外键一对多
      • 2.1创建表
        • 2.2插入数据、查看数据
          • 2.2.1 插入数据
          • 2.2.2 查看数据
      • 3.多对多操作
        • 3.1 创建表，注意 secondary 关键字
          • 3.2 插入数据、查看数据
            • 3.2.1 插入数据
            • 2.2.2 查询数据
        • 4.部分高级操作
          • 4.1 创建表
            • 4.2 查看数据
              • 4.2.1 or_
              • 4.2.2 and_
              • 4.2.3 query(指定字段)
              • 4.2.4 order_by 排序
              • 4.2.5 between，在范围内
              • 4.2.6 in_，在指定集合内
              • 4.2.7 notin_，排除指定范围的，与 in_ 互斥
            • 4.3 更新数据
              • # 本身自增加的写法
          领券

          腾讯云开发者

          扫码关注腾讯云开发者

          扫码关注腾讯云开发者

          领取腾讯云代金券

          热门产品

          热门推荐

          更多推荐

          Copyright © 2013 - 2024 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

          深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

          腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号 | 京公网安备号11010802020287

          问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档

          Copyright © 2013 - 2024 Tencent Cloud.

          All Rights Reserved. 腾讯云 版权所有

          登录 后参与评论