from sqlalchemy import Column, String,Integer, create_engine from sqlalchemy.orm import sessionmaker from sqlalchemy.ext.declarative import declarative_base #连接引擎,echo=True输出信息 engine = create_engine('mysql+pymysql://monitor:123@[email protected]/monitor',echo=True) #创建基类 Base = declarative_base() #创建对象,映射为表,属性映射为字段 class User(Base): __tablename__ = 'user' id = Column(Integer,primary_key=True) name = Column(String(20)) #父类把所有的子类,传到引擎,创建表结构 #Base.metadata.create_all(engine) # #创建一个会话,返回的是一个类,所以要创建一个实例 Session_class = sessionmaker(bind=engine) Session = Session_class() #insert # #设置实例的属性值,就是字段,然后调用add方法。 # user_obj = User(id=1,name='jab') # Session.add(user_obj) # #最后提交 # Session.commit() #select data = Session.query(User).filter_by(name='jab').first() print(data.name)