#!/usr/bin/python

# -*- coding: utf-8 -*-

from sqlalchemy import create_engine

from sqlalchemy import Table, MetaData, Column, Integer, String

from sqlalchemy.ext.declarative import declarative_base

from sqlalchemy.orm import mapper, sessionmaker

# 创建实例，并连接test库

engine = create_engine("mysql+pymysql://root:123@localhost/demoDb?charset=utf8", encoding='utf-8', echo=True)

metadata = MetaData()

# 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 __init__(self):

        # 创建与数据库的会话session class ,注意,这里返回给session的是个class,不是实例 self.session_class = sessionmaker(bind=engine) # 实例和engine绑定

        self.session = self.session_class()  # 生成session实例，相当于游标

    # 创建表

    def create_user(self):

        Base.metadata.create_all(engine)  # 创建表结构 （这里是父类调子类）

    # 新增数据

    def insert_user(self, user):

        self.session.add(use)  # 把要创建的数据对象添加到这个session里， 一会统一创建

        return self.session.commit()  # 现此才统一提交，创建数据

    # 根据一个字段查询

    def sel_user(self):

        my_user = self.session.query(User).filter_by(name="12").first()  # 查询

        return my_user

    '''

    ----------------     条件查询    ----------------

        my_user1 = self.session.query(User).filter(User.id > 2).all()

        my_user2 = self.session.query(User).filter_by(id=27).all()  # filter_by相等用‘=’

        my_user3 = self.session.query(User).filter(User.id == 27).all()  # filter相等用‘==’

    ----------------     多条件查询  ----------------

        objs = self.session.query(User).filter(User.id>0).filter(User.id<7).all()

    --------------     模糊查询，返回count    ------------

        self.session.query(User).filter(User.name.like("f%")).count()  # mysql不区分大小写

    ----------------     分组查询    ----------------

        self.session.query(User.name,func.count(User.name)).group_by(User.name).all()

    ----------------     连表查询    ----------------

        ret = self.session.query(Users, Favor).filter(Users.id == Favor.nid).all()

        # 以下两种 必须表之间有外键关联才能查

        ret = session.query(Person).join(Favor).all() 

        ret = session.query(Person).join(Favor, isouter=True).all()

    '''

    # 查询所有

    def sel_user_all(self):

        return self.session.query(User).all()

        # return self.session.query(User.id,User.name).all() #查询所有，结果集只包含 id，name

    # 修改操作

    def up_user(self):

        my_user = self.session.query(User).filter_by(name="fgf").first()

        my_user.name = "fenggf"  # 查询出来之后直接赋值修改

        my_user.passwork = "123qwe"

        self.session.commit()

if __name__ == '__main__':

    use = User()

    user_list = use.sel_user_all()

    for us in user_list:

        print us.name