flask sqlalchemy 單表查詢

主要內容:python

1 sqlalchemy: 一個python的ORM框架mysql

2 使用sqlalchemy 的流程:sql

  建立一個類數據庫

       建立數據庫引擎session

       將全部的類序列化成數據表框架

  進行增刪改查操做orm

# 1.建立一個 Class
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
# Base 是 ORM模型 基類
# ORM模型 - Obj裏面的屬性 == table中建立的字段
#        - Obj定義table的操做方式和屬性
from sqlalchemy import Column,Integer,INT,INTEGER,VARCHAR,String
class User(Base):
    __tablename__ = "user"
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32),index=True)
# 2.建立數據引擎
from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/sqlalchemy_s14?charset=utf8")
# 3.將全部的繼承Base的Class序列化成數據表
Base.metadata.create_all(engine)

  增刪改操做blog

#1.選中數據庫 - 建立數據庫引擎 導入數據庫引擎
from model import engine
#2.建立查詢窗口,必須是選中數據庫的查詢窗口
from sqlalchemy.orm import sessionmaker
Session_window = sessionmaker(engine)
# 打開查詢窗口
db_session = Session_window()
3 增長數據
# user_obj = User(name='yuyu',age=12)
# db_session.add(user_obj)
# db_session.commit()    #執行所有sql語句
# add_list = [User(name='yu2yu',age=12), User(name='yu1yu',age=12)]
# db_session.add_all(add_list)
# db_session.commit()
# db_session.close()
 刪除數據
# res = db_session.query(User).filter(User.id>=8).all()
# for one in res:
#     db_session.delete(one)
# db_session.commit()
修改數據
# 修改數據
user_obj = db_session.query(User).filter(User.id==5).update({"name":"yu"})

res1 = db_session.query(User).all()
for one_info in res1:
    print(one_info.id, one_info.name)
相關文章
相關標籤/搜索