SQLAlchemy与mysql连接
SQLAlchemy与mysql连接
- 设置并且数据库引擎
engine = create_engine("mysql+pymysql://数据库用户名:数据库密码@ip地址:3306/数据库名")
- 创建缓存类
Session = sessionmaker(bind=engine)# 实例化缓存类
session = Session()
- 声明映射
# SQLAlchemy在中首先通过declarative_base申明一个基类。这个基类维持着类与数据库表的关系
from sqlalchemy.ext.declarative import declarative_base
Base=declarative_base()
- 编写映射类
# python中的映射类要继承Base基类
class Product(Base):# 设置表名__tablename__ = 'products'title = Column(String(100))image = Column(String(200))link = Column(String(200), primary_key=True)price = Column(Float)sizes = Column(String(10000))stocks = Column(Integer)# 设置字符串友好显示def __repr__(self):return "<Product>{}:{}".format(self.title, self.stocks)
- 创建数据库表
Base.metadata.create_all(engine)
- 实例化映射类添加到数据库中
product = Product(…………)
# 将对象添加到缓存中
session.add(product)
# 要将缓存中的数据提交,才能生效到数据库中
session.commit()# 最后数据库操作完成之后关闭数据库连接
session.close()
SQLAlchemy与mysql连接
SQLAlchemy与mysql连接
- 设置并且数据库引擎
engine = create_engine("mysql+pymysql://数据库用户名:数据库密码@ip地址:3306/数据库名")
- 创建缓存类
Session = sessionmaker(bind=engine)# 实例化缓存类
session = Session()
- 声明映射
# SQLAlchemy在中首先通过declarative_base申明一个基类。这个基类维持着类与数据库表的关系
from sqlalchemy.ext.declarative import declarative_base
Base=declarative_base()
- 编写映射类
# python中的映射类要继承Base基类
class Product(Base):# 设置表名__tablename__ = 'products'title = Column(String(100))image = Column(String(200))link = Column(String(200), primary_key=True)price = Column(Float)sizes = Column(String(10000))stocks = Column(Integer)# 设置字符串友好显示def __repr__(self):return "<Product>{}:{}".format(self.title, self.stocks)
- 创建数据库表
Base.metadata.create_all(engine)
- 实例化映射类添加到数据库中
product = Product(…………)
# 将对象添加到缓存中
session.add(product)
# 要将缓存中的数据提交,才能生效到数据库中
session.commit()# 最后数据库操作完成之后关闭数据库连接
session.close()