SQLAlchemy 增删改查 一对一 多对多

首先要导入SQLAIchemy模块

from sqlalchemy.ect.declaative import  declarative_base

创建orm基类

Base = declarative_base()

创建orm对象

class User(Base):
    __tablename__ = "user"
    
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32),index=True)

创建数据库链接

from sqlalchemy import create_engine
ngine = create_engine("mysql+pymysql://root:pwd@127.0.0.1:3306/user?charset=utf8")
备注：pwd表示密码，如果数据库属性中没有密码的话可以忽略，user是数据库名

# 数据库链接创建完成
# 去数据库中创建与User所对应的数据库表
# 去engine数据库中创建继承Base类所对应的数据表

Base.metadata.create_all(engine)

#############################################################################################################################

添加数据

首先打开数据库链接

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

创建会话窗口---打开数据库链接

from sqlalchemy.orm import  sessionmaker

创建会话

Session = sessionmaker(engine)

打开会话窗口

db_session = Session()

添加单条数据

user_obj=  User(name="ywb")
db_session.add(user_obj)

添加多条数据

db_session.add_all([
    User(name="Alex"),
    User(name="Wusir"),
    User(name="Yuan")

])

开始执行操作

   db_session.commit()

执行完成之后关闭执行命令

db_session.close()

查询数据

 1 # 创建会话窗口
 2 from sqlalchemy.orm import sessionmaker
 3 from creat_table import engine,User
 4 
 5 Session = sessionmaker(engine)
 6 db_session = Session()
 7 
 8 
 9 # 简单的查询语句
10 user_list = db_session.query(User).all()
11 for row in user_list:
12     print(row.id,row.name)
13 
14 # 单条查询
15 user = db_session.query(User).first()
16 print(user.id,user.name)
17 
18 
19 # 带条件的查询
20 user_list = db_session.query(User).filter(User.id==4).all()
21 print(user_list[0].id,user_list[0].name)
22 
23 user = db_session.query(User).filter_by(id=3).first()
24 print(user.id,user.name)
25 
26 user_list = db_session.query(User).filter(User.id>=2).all()
27 for row in user_list:
28     print(row.id,row.name)
29 
30 
31 # 查询sql语句(拓展)
32 sql = db_session.query(User).filter(User.id>=2)
33 print(sql)

查询数据