dreamhua 2019-10-26
1、创建引擎
SQLAlchemy本身无法操作数据库,其必须以来pymsql等第三方插件,Dialect用于和数据API进行交流,根据配置文件的不同调用不同的数据库API,从而实现对数据库的操作,如:
MySQL-Python mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname> pymysql mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>] MySQL-Connector mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname> cx_Oracle oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...] 更多详见:http://docs.sqlalchemy.org/en/latest/dialects/index.html 以mysql为例: engine = create_engine("mysql+pymysql://root::3306/db4?charset=utf8", max_overflow=0, # 超过连接池大小外最多创建的连接 pool_size=5, # 连接池大小 pool_timeout=30, # 池中没有线程最多等待的时间,否则报错 pool_recycle=-1 # 多久之后对线程池中的线程进行一次连接的回收(重置) echo = True # echo参数为True时,会显示每条执行的SQL语句,可以关闭 ", max_overflow = 5)
2、创建表
(1)导入模块,创建Base
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index from sqlalchemy.orm import sessionmaker, relationship from sqlalchemy import create_engine Base = declarative_base()
(2)定义类(一个类为一张表)
class User(Base):
在类中创建列:
1)表名
# 这是在数据库中存在的表名 __tablename__ = ‘users‘
2)主键
id = Column(Integer, primary_key=True,autoincrement=True) #primary_key设置主键,autoincrement=True设置自增
3)普通字段
# 32代表最大长度,添加index索引,不可以为null name = Column(String(32), index=True, nullable=False)
4)外键
#ForeignKeyForeignKey(‘teacher.tid‘), teacher_id = Column(Integer,ForeignKey(‘teacher.tid‘))
5)索引
# 32代表最大长度,添加index索引,不可以为null name = Column(String(32), index=True, nullable=False)
6)联合唯一索引
#UniqueConstraint(列明,索引名) __table_args__ = ( UniqueConstraint(‘tid‘,‘tname‘,name = ‘uc_tid‘), )
7)联合索引
__table_args__ = ( # 联合索引 # 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)
删除表:
注意注意删除一定要慎重,利用Base的drop_all删除表
Base.metadata.drop_all(engine)
例:
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index from sqlalchemy.orm import sessionmaker, relationship from sqlalchemy import create_engine engine = create_engine("mysql+pymysql://root::3306/db4", max_overflow = 5) #创建引擎 Base = declarative_base() #创建Base class Teacher(Base): #创建表 __tablename__ = ‘teacher‘ #表名 tid = Column(Integer,nullable= False,primary_key = True,autoincrement= True) #整型,不为空,主键,自增 sname = Column(String(32),index=True) #字符串(32),普通索引 gender = Column(String(2)) __table_args__ = ( UniqueConstraint(‘tid‘,name = ‘uc_tid‘), #唯一索引 ) class Student(Base): __tablename__ = ‘student‘ sid = Column(Integer,primary_key = True,autoincrement= True) sname = Column(String(32),index=True) gender = Column(String(2)) teacher_id = Column(Integer,ForeignKey(‘teacher.tid‘)) #外键 def init_db(): #初始化表 Base.metadata.create_all(engine) def drop_db(): #删除表 Base.metadata.drop_all(engine) init_db() #创建表 # drop_db() #删除表