SQLAlchemy 增刪改查 一對多 多對多

時間  2019-12-09
標籤 sqlalchemy 增刪 一對多 多對 简体版
原文   原文鏈接

Python 的 ORM 框架 SQLAlchemy 有些同窗已經據說過這個框架的大名了,也據說了 SQLAlchemy 沒有 Django 的 Models 好用mysql

我在這裏官宣闢謠一下啊, Models 牢牢只是配置和使用比較簡單(這特麼就是廢話),由於他是Django自帶的ORM框架,也正是由於是Django原生的,因此兼容性遠遠不如SQLAlchemysql

真正算得上全面的ORM框架必然是咱們的SQLAlchemy ORM框架,它能夠在任何使用SQL查詢時使用數據庫

固然了,不管是使用什麼ORM框架,都是爲了方便不熟練數據庫的同窗使用的,我我的仍是比較推崇原生 SQL ,也建議每位同窗攻克 SQL 的難關session

廢話很少說,咱們來看一下 SQLAlchemy 如何使用:app

1.建立數據表

# ORM中的數據表是什麼呢?
# Object Relation Mapping
# Object - Table 經過 Object 去操縱數據表
# 從而引出了咱們的第一步建立數據表 - 建立Object
# 1. 建立Object
# class User(object):
#     pass

# 2. 讓Object與數據表產生某種關係 也就是讓Object與數據表格式極度類似
# 導入官宣基礎模型
from sqlalchemy.ext.declarative import declarative_base
# 實例化官宣模型 - Base 就是 ORM 模型
Base = declarative_base()
# 當前的這個Object繼承了Base也就是表明了Object繼承了ORM的模型
class User(Base):  # 至關於 Django Models中的 Model
    # 爲Table建立名稱
    __tablename__ = "user"
    # 建立ID數據字段 , 那麼ID是否是一個數據列呢? 也就是說建立ID字段 == 建立ID數據列
    from sqlalchemy import Column,Integer,String
    # id = Column(數據類型,索引,主鍵,外鍵,等等)
    # int == Integer
    id = Column(Integer,primary_key=True,autoincrement=True)
    # str == char(長度) == String(長度)
    name = Column(String(32),index=True)

# 3.去數據庫中建立數據表? or 先鏈接數據庫?
# 3.去鏈接數據庫 建立數據引擎
from sqlalchemy import create_engine
# 建立的數據庫引擎
engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")

# Base 自動檢索全部繼承Base的ORM 對象 而且建立全部的數據表
Base.metadata.create_all(engine)

my_create_table
View Code

2.增刪改查操做

2.1.增長數據

#insert 爲數據表增長數據
# insert One 增長一行數據
# insert into user(name) values ("heshun")
# 在ORM中的操做:
# 1.首先導入之間作好的ORM 對象 User
from my_create_table import User
# 2.使用Users ORM模型建立一條數據
user1 = User(name="heshun")
# 數據已經建立完了,可是須要寫入到數據庫中啊,怎麼寫入呢?
# 3.寫入數據庫:
# 首先打開數據庫會話 , 說白了就是建立了一個操縱數據庫的窗口
# 導入 sqlalchemy.orm 中的 sessionmaker
from sqlalchemy.orm import sessionmaker
# 導入以前建立好的 create_engine
from my_create_table import engine
# 建立 sessionmaker 會話對象,將數據庫引擎 engine 交給 sessionmaker
Session = sessionmaker(engine)
# 打開會話對象 Session
db_session = Session()
# 在db_session會話中添加一條 UserORM模型建立的數據
db_session.add(user1)
# 使用 db_session 會話提交 , 這裏的提交是指將db_session中的全部指令一次性提交
db_session.commit()

# 固然也你也可很任性的提交多條數據
# 方法一:
user2 = User(name="heshun")
user3 = User(name="和順")
db_session.add(user2)
db_session.add(user3)
db_session.commit()
# 以前說過commit是將db_session中的全部指令一次性提交,如今的db_session中至少有兩條指令user2和user3
db_session.close()
#關閉會話

# 若是說你以爲方法一很麻煩,那麼方法二必定很是很是適合你
# 方法二:
user_list = [
    User(name="和順1"),
    User(name="heshun2"),
    User(name="heshun3")
]
db_session.add_all(user_list)
db_session.commit()

db_session.close()

orm_insert
View Code

2.2.查詢數據

# ORM操做查詢數據
# 有了剛纔Insert增長數據的經驗,那麼查詢以前的準備工做,就不用再重複了吧
# 回想一下剛纔Insert時咱們的操做
from my_create_table import User, engine
from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine)
db_session = Session()

# 1. select * from user 查詢user表中的全部數據
# 語法是這樣的 使用 db_session 會話 執行User表 query(User) 取出所有數據 all()
user_all_list = db_session.query(User).all()
print(user_all_list)  # [<my_create_table.User object at 0x0000016D7C4BCDD8>]
# 如何查看user_all_list其中的數據呢? 循環唄
for i in user_all_list:
    print(i.id, i.name)  # ORM對象 直接使用調用屬性的方法 拿出對應字段的值

db_session.close()
#關閉會話

# 2. select * from user where id >= 20
# 語法是這樣的 使用 db_session 會話 執行User表 query(User) 篩選內容User.id >=20 的數據所有取出 all()
user_all_list = db_session.query(User).filter(User.id >= 20).all()
print(user_all_list)
for i in user_all_list:
    print(i.id, i.name)

db_session.close()
#關閉會話

# 3. 除了取出所有還能夠只取出一條
user = db_session.query(User).filter(User.id >= 20).first()
print(user.id, user.name)
db_session.close()
#關閉會話

# 4. 烏龍 之 忘了取出數據.......
wulong1 = db_session.query(User).filter(User.id >= 20)
print(wulong1)
#SELECT user.id AS user_id, user.name AS user_name
#FROM user
#WHERE user.id >= %(id_1)s
# Fuck我忘了取出數據了!!!!!!! 哎? wulong1給我顯示了原生SQL語句,塞翁失馬了
wulong2 = db_session.query(User)
print(wulong2)
#SELECT user.id AS user_id, user.name AS user_name
#FROM user
# Fuck我又忘了取出數據了!!!!!!! 哎? wulong2給我顯示了原生SQL語句,塞翁失馬了
db_session.close()
#關閉會話

orm_select
View Code

2.3.修改數據

# ORM更新數據
# 不管是更新仍是刪除,首先要作的事情,就應該是查詢吧
# 根據以前原有的經驗,接下來是否是要導入ORM對象了,是否是要建立db_session會話了
from my_create_table import User,engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()

# UPDATE user SET name="heshun" WHERE id=20 更新一條數據
# 語法是這樣的 :
# 使用 db_session 執行User表 query(User) 篩選 User.id = 20 的數據 filter(User.id == 20)
# 將name字段的值改成heshun update({"name":"heshun"})
res = db_session.query(User).filter(User.id == 20).update({"name":"heshun"})
print(res) # 1 res就是咱們當前這句更新語句所更新的行數
# 注意注意注意
# 這裏必定要將db_session中的執行語句進行提交,由於你這是要對數據中的數據進行操做
# 數據庫中 增 改 刪 都是操做,也就是說執行以上三種操做的時候必定要commit
db_session.commit()
db_session.close()
#關閉會話

# 更新多條
res = db_session.query(User).filter(User.id <= 20).update({"name":"heshun"})
print(res) # 6 res就是咱們當前這句更新語句所更新的行數
db_session.commit()
db_session.close()
#關閉會話

orm_update
View Code

2.4.刪除數據

# ORM 刪除一條多條數據
# 老規矩
# 導入 ORM 建立會話
from my_create_table import User,engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()

# DELETE FROM `user` WHERE id=20
res = db_session.query(User).filter(User.id==20).delete()
print(res)
# 是刪除操做吧,沒錯吧,那你想什麼呢?commit吧
db_session.commit()

db_session.close()
#關閉會話

orm_delete
View Code

2.5.搞基!高級版查詢操做

from create_table import engine, User
from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine)

db_session = Session()

# 查詢數據表操做
# and or
# res = db_session.query(User).filter(User.name == "heshun" and User.id == 2).all()
# and 只會匹配前面的
# print(res[0].name)
# res = db_session.query(User).filter(User.name == "heshun" or User.id == 2).all()
# or 只會匹配後面的
# print(res[0].name, res)


# from sqlalchemy.sql import and_, or_
# ret = db_session.query(User).filter(and_(User.id==1,User.name=="heshun")).all()
# print(ret[0].name)
# ret = db_session.query(User).filter(or_(User.id==1, User.name == "lx")).all()
# for row in ret:
#     print(row.name)
# ret = db_session.query(User).filter_by(id=2,name="hxf").all()
# print(ret[0].name)


# 查詢全部數據
# r1 = db_session.query(User).all()
# print(r1)

# 查詢數據  指定查詢數據列   加入別名
# r2 = db_session.query(User.id.label("uid"), User.name.label("username")).first()
# print(r2.id, r2.username)  # AttributeError: 'result' object has no attribute 'id'   表示沒有這個字段
# print(r2.uid, r2.username)

# 表達式篩選條件
# r3 = db_session.query(User).filter(User.name == "heshun").all()

# 原生SQL篩選條件
# r4 = db_session.query(User).filter_by(name="heshun").all()
# r5 = db_session.query(User).filter_by(name="heshun").first()

# 字符串匹配方式篩選條件  並使用 order_by 進行排序
# from sqlalchemy.sql import text
# r6 = db_session.query(User).filter(text("id=:value and name=:name")).params(value=1, name="heshun").first()
# print(r6.name)

# 原生SQL查詢
# r7 = db_session.query(User).from_statement(text("select * from User WHERE  NAME =:NAME ")).params(name="heshun").all()

# 篩選查詢列
# query 的時候咱們不在使用User ORM對象, 而是使用User.name 來對內容進行選取
# user_list = db_session.query(User.name).all()
# print(user_list)
# for row in user_list:
#     print(row.name)


# 別名映射 name as nick
# user_list = db_session.query(User.name.lable('nick')).all()
# print(user_list)
# for row in user_list:
#     print(row.nick)

# 篩選條件格式
# user_list = db_session.query(User).filter(User.name == "heshun").all()
# user_list = db_session.query(User).filter(User.name == "heshun").first()
# user_list = db_session.query(User).filter_by(name="heshun").first()
# for row in user_list:
#     print(row.nick)

# 排序 :
# user_list = db_session.query(User).order_by(User.id.asc()).all()
# user_list = db_session.query(User).order_by(User.id.desc()).all()
# for row in user_list:
#     print(row.name,row.id)


# 其餘查詢條件
"""
ret = session.query(User).filter_by(name='DragonFire').all()
ret = session.query(User).filter(User.id > 1, User.name == 'DragonFire').all()
ret = session.query(User).filter(User.id.between(1, 3), User.name == 'DragonFire').all() # between 大於1小於3的
ret = session.query(User).filter(User.id.in_([1,3,4])).all() # in_([1,3,4]) 只查詢id等於1,3,4的
ret = session.query(User).filter(~User.id.in_([1,3,4])).all() # ~xxxx.in_([1,3,4]) 查詢不等於1,3,4的
ret = session.query(User).filter(User.id.in_(session.query(User.id).filter_by(name='DragonFire'))).all() 子查詢
from sqlalchemy import and_, or_
ret = session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all()
ret = session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all()
ret = session.query(User).filter(
    or_(
        User.id < 2,
        and_(User.name == 'eric', User.id > 3),
        User.extra != ""
    )).all()
# select * from User where id<2 or (name="eric" and id>3) or extra != "" 

# 通配符
ret = db_session.query(User).filter(User.name.like('e%')).all()
ret = db_session.query(User).filter(~User.name.like('e%')).all()

# 限制
ret = db_session.query(User)[1:2]

# 排序
ret = db_session.query(User).order_by(User.name.desc()).all()
ret = db_session.query(User).order_by(User.name.desc(), User.id.asc()).all()

# 分組
from sqlalchemy.sql import func

ret = db_session.query(User).group_by(User.extra).all()
ret = db_session.query(
    func.max(User.id),
    func.sum(User.id),
    func.min(User.id)).group_by(User.name).all()

ret = db_session.query(
    func.max(User.id),
    func.sum(User.id),
    func.min(User.id)).group_by(User.name).having(func.min(User.id) >2).all()
"""

# ret = db_session.query(User).filter(User.id.between(1,3)).all()  # between 大於1小於3的
# print(ret)

# ret = db_session.query(User).filter(User.id.in_([1,4])).all() # in_([1,3,4]) 只查詢id等於1,3,4的
# ret = db_session.query(User).filter(~User.id.in_([1,2,3])).all() # ~xxxx.in_([1,3,4]) 查詢不等於1,3,4的
# print(ret)

# from sqlalchemy.sql import and_, or_
#
# ret = db_session.query(User).filter(
#     or_(
#         User.id < 2,
#         and_(User.name == 'eric', User.id > 3),
#         User.name != ""
#     ))
# print(ret)

# 關閉鏈接
db_session.close()
View Code

2.6.高級修改數據操做

#高級版更新操做
from create_table import User,engine
from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine)
db_session = Session()

# 直接修改
# db_session.query(User).filter(User.id > 0).update({"name" : "099"})


# 在原基礎上添加 -1
# db_session.query(User).filter(User.id>0).update({User.name : User.name + "123"}, synchronize_session=False)
# db_session.commit()

#在原有值基礎上添加 - 2
# db_session.query(User).filter(User.id > 0).update({"age": User.age + 1}, synchronize_session="evaluate")
# db_session.commit()
View Code

 

3.一對多的操做 : ForeignKey

3.1.建立數據表及關係relationship:

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

# 此次咱們要多導入一個 ForeignKey 字段了,外鍵關聯對了
from sqlalchemy import Column,Integer,String,ForeignKey
# 還要從orm 中導入一個 relationship 關係映射
from sqlalchemy.orm import relationship

class ClassTable(Base):
    __tablename__="classtable"
    id = Column(Integer,primary_key=True)
    name = Column(String(32),index=True)

class Student(Base):
    __tablename__="student"
    id=Column(Integer,primary_key=True)
    name = Column(String(32),index=True)

    # 關聯字段,讓class_id 與 class 的 id 進行關聯,主外鍵關係(這裏的ForeignKey必定要是表名.id不是對象名)
    class_id = Column(Integer,ForeignKey("classtable.id"))

    # 將student 與 classtable 建立關係 這個不是字段,只是關係,backref是反向關聯的關鍵字
    to_class = relationship("ClassTable",backref = "stu2class")

from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")

Base.metadata.create_all(engine)

my_ForeignKey.py
View Code

3.2.基於relationship增長數據

# 添加數據
from sqlalchemy.orm import sessionmaker
from create_table_ForeignKey import engine,Student,School

Session = sessionmaker(engine)
db_session = Session()

# 1.添加數據 - 笨
# sch_obj = School(name="OldBoyBeijing")
# db_session.add(sch_obj)
# db_session.commit()
#
# sch = db_session.query(School).filter(School.name == "OldBoyBeijing").first()
# stu_obj = Student(name="DragonFire",school_id=sch.id)
# db_session.add(stu_obj)
# db_session.commit()
# db_session.close()

# 2.添加數據 - 正向 relationship 版
# stu_obj = Student(name="小籠包",stu2sch=School(name="OldBoyShenzhen"))
# db_session.add(stu_obj)
# db_session.commit()
# db_session.close()

# 3.添加數據 - 反向 relationship 版
# sch_obj = School(name="OldBoyShanghai")
# sch_obj.sch2stu = [Student(name="趙麗穎"),Student(name="陳妍希")]
# db_session.add(sch_obj)
# db_session.commit()
# db_session.close()
View Code

3.3.基於relationship查詢數據

# 添加數據
from sqlalchemy.orm import sessionmaker
from create_table_ForeignKey import engine,Student,School

Session = sessionmaker(engine)
db_session = Session()

# 1.查詢數據 - relationship 版 正向
# stu = db_session.query(Student).all()
# for row in stu:
#     print(row.id,row.name,row.school_id,row.stu2sch.name)

# 2.查詢數據 - relationship 版 反向
# sch = db_session.query(School).all()
# for school in sch:
#     for student in school.sch2stu:
#         print(school.id,school.name,student.name)
View Code

3.4.更新數據

from sqlalchemy.orm import sessionmaker
from create_table_ForeignKey import engine, School, Student

Session = sessionmaker(engine)
db_session = Session()

sch = db_session.query(School).filter(School.name == "北京大學").first()
db_session.query(Student).filter(Student.name == "heshun").update({"school_id": sch.id})
db_session.add(sch)
db_session.commit()
db_session.close()
View Code

3.5.刪除數據

from sqlalchemy.orm import sessionmaker
from create_table_ForeignKey import engine, Student, School

Session = sessionmaker(engine)
db_session = Session()


sch = db_session.query(School).filter(School.name == "北京大學").first()
db_session.query(Student).filter(Student.school_id == sch.id).delete()
db_session.add(sch)
db_session.commit()
db_session.close()
View Code

 

4.多對多 : ManyToMany

boys　　　　　　　　　　　　　　grils框架

hotelide

 4.1.建立表及關係

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

from sqlalchemy import Column, String, Integer, ForeignKey
from sqlalchemy.orm import relationship


class Grils(Base):
    __tablename__="gril"
    id = Column(Integer, primary_key=True, autoincrement=True)
    name = Column(String(32))
    gril2boy = relationship("Boys", secondary="hotel", backref="boy2gril")


class Boys(Base):
    __tablename__ = "boy"
    id = Column(Integer, primary_key=True, autoincrement=True)
    name = Column(String(32))


class Hotel(Base):
    __tablename__ = "hotel"
    id = Column(Integer, primary_key=True, autoincrement=True)
    gril_id = Column(Integer, ForeignKey("gril.id"))
    boy_id = Column(Integer, ForeignKey("boy.id"))


from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/day127?charset=utf8")

Base.metadata.create_all(engine)
View Code

 

4.2.基於relationship增長數據

from sqlalchemy.orm import sessionmaker
from M2M import engine, Grils, Boys

Session = sessionmaker(engine)
db_session = Session()

# 經過Boy添加Girl和Hotel數據  relationship 反向
# boy = Boys(name="heshun")
# boy.boy2gril = [Grils(name="楊冪"), Grils(name="鞠婧禕")]
# db_session.add(boy)
# db_session.commit()
# db_session.close()

# 經過Gril添加Boy和Hotel數據  relationship 正向
# gril_obj = Grils(name="羅玉鳳", gril2boy=[Boys(name="小黃"), Boys(name="老K")])
# db_session.add(gril_obj)
# db_session.commit()
# db_session.close()
View Code

 

 4.3.基於relationship查詢數據

from sqlalchemy.orm import sessionmaker

from SQL.s5_M2M import engine

Session = sessionmaker(engine)
db_session = Session()

# 3.查詢 relationship 正向
# g_list = db_session.query(Girls).all()
# for girl in g_list:
#     for boy in girl.girl2boy:
#         print(girl.name,boy.name)

# 4.查詢 relationship 反向
# b_list = db_session.query(Boys).all()
# for boy in b_list:
#     for girl in boy.boy2girl:
#         print(boy.name,girl.name)
View Code
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程