from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String
from sqlalchemy.orm import sessionmaker
from sqlalchemy import func
engine=create_engine(
    "mysql+pymysql://root:123456@localhost/mxm_db",
    encoding='utf-8',echo=False
)
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,%s,%s>' %(self.id,self.name,self.password)
Base.metadata.create_all(engine)
Session_class=sessionmaker(bind=engine)#创建与数据库的会话class
Session=Session_class()#生成session实例，跟cursor一样
#1.增加数据
# user_obj=User(name='mxm1',password='mxm1')#生成你要创建的数据对象
# print(user_obj.name,user_obj.password)
# Session.add(user_obj)#把要创建的数据对象，添加到这个session里
# Session.commit()#统一提交，创建数据
#2.查询数据
data=Session.query(User).filter_by(name='mxm1').first()#查询不需要commit
print(data)
#3.修改数据
#data.name='mxm2'
#data.password='mxm2'
#Session.commit()
#4.数据回滚
#Session.rollback()
#filter(User.name.in_(['name1','name2']))
#5.统计
#data=Session.query(User).filter_by(password='mxm').\
#    filter_by(name='mxm').count()#查询不需要commit
#print(data)
#6.分组
#data=Session.query(User.name,func.count(User.name)).group_by(User.name).all()
#print(data)

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

为企业提供成都网站制作、成都做网站、外贸营销网站建设、网站优化、营销型网站建设、竞价托管、品牌运营等营销获客服务。创新互联拥有网络营销运营团队，以丰富的互联网营销经验助力企业精准获客，真正落地解决中小企业营销获客难题，做到“让获客更简单”。自创立至今，成功用技术实力解决了企业“网站建设、网络品牌塑造、网络营销”三大难题，同时降低了营销成本，提高了有效客户转化率，获得了众多企业客户的高度认可！
分享名称：python-sqlalchemy-创新互联
本文路径：http://myzitong.com/article/djijoh.html