#!/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