SQLALchemy之創建表，刪除表

1、創建引擎

"數據庫+第三方模塊：//用戶名：密碼@數據庫服務端IP：端口號/數據庫名？編碼"

engine = create_engine(
    "mysql+pymysql://root:123@127.0.0.1:3306/t1?charset=utf8",
    max_overflow=0,  # 超過連接池大小外最多創建的連接
    pool_size=5,  # 連接池大小
    pool_timeout=30,  # 池中沒有線程最多等待的時間，否則報錯
    pool_recycle=-1  # 多久之后對線程池中的線程進行一次連接的回收（重置）
    echo = True    # echo參數為True時，會顯示每條執行的SQL語句，可以關閉   
)

 

2、創建表

（1）引入，創建Base

import datetime
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, Text, ForeignKey, DateTime, UniqueConstraint, Index

Base = declarative_base()

（2）定義類（表）

class  User(Base):

》》》》在定義類中創建：：：

1）表名：

# 這是在數據庫中存在的表名
__tablename__ = 'users'

2）主鍵

設置自增：autoincrement=True

id = Column(Integer, primary_key=True，autoincrement=True)

3）普通字段

字符串長度限制，index索引，null

# 32代表最大長度，添加index索引，不可以為null
name = Column(String(32), index=True, nullable=False)

4）普通字段2

唯一索引

# 添加唯一索引
email = Column(String(32), unique=True)

5）普通字段3

設置默認值

# 設置默認值
age = Column(Integer, default=18)

 

6）時間字段

# 設置默認值時不能加括號
ctime = Column(DateTime, default=datetime.datetime.now)

7）聯合唯一，聯合索引

__table_args__ = (
        # 聯合唯一
        # UniqueConstraint('id', 'name', name='uix_id_name'),
        
        # 聯合索引
        # Index('ix_id_name', 'name', 'email'),
    )

 

8）一對多關系

ForeignKey中的參數是表名.要關聯的字段，注意這里的表名不是別的類名，而是__tablename__參數值

默認是同步刪除同步更新的，也就是on  delete cascade   on  update  cascade

hobby_id = Column(Integer, ForeignKey("hobby.id"))

 

9）多對多關系

要自己創建關系表，分別和其它2張表做forejgnkey

class Server2Group(Base):
    __tablename__ = 'server2group'
    id = Column(Integer, primary_key=True, autoincrement=True)
    server_id = Column(Integer, ForeignKey('server.id'))
    group_id = Column(Integer, ForeignKey('group.id'))

 

（3）利用Base的create_all創建表

Base.metadata.create_all(engine)

 

3、刪除表

注意注意刪除一定要慎重

利用Base的drop_all刪除表

Base.metadata.drop_all(engine)