ORM_Cre.py

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
engine = create_engine("mysql+pymysql://root:123456@192.168.0.4/lmg",
                       encoding='utf-8', echo=True)
Base = declarative_base()  # 生成orm基类
class User(Base):
    __tablename__ = 'user'  # 表名
    id = Column(Integer, primary_key=True)
    name = Column(String(32))
    password = Column(String(64))
    def __repr__(self):
        return "<%s name:%s>" %(self.id,self.name)
Base.metadata.create_all(engine)  # 创建表结构
Session_class = sessionmaker(bind=engine)  # 创建与数据库的会话session class ,注意,这里返回给session的是个class,不是实例
Session = Session_class()  # 生成session实例
#创建数据
# user_obj = User(name="lmg", password="123456")  # 生成你要创建的数据对象
# user_obj2 = User(name="alex", password="1223")  # 生成你要创建的数据对象
# print(user_obj.name, user_obj.id)  # 此时还没创建对象呢，不信你打印一下id发现还是None
# Session.add(user_obj)  # 把要创建的数据对象添加到这个session里， 一会统一创建
# Session.add(user_obj2)  # 把要创建的数据对象添加到这个session里， 一会统一创建
# print(user_obj.name, user_obj.id)  # 此时也依然还没创建

#查询
# data=Session.query(User).filter_by().all()#Session.query(User).filter_by(name="lmg")查的是一个列表
# data=Session.query(User).filter(User.id>1).filter(User.id<3).all()#条件查询

#修改
# data=Session.query(User).filter(User.id>1).filter(User.id<3).first()
# print(data)
# data.name = "lmg3"
# data.password = "liminnn"


# print(data[0].name,data[0].password) #data[0].lmg 在data列表里调出
Session.commit()  # 现此才统一提交，创建数据