python之sqlalchemy

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
# 创建数据库
engine = create_engine("mysql+pymysql://root:123456@127.0.0.1:3306/wang", max_overflow=5)
# 生成一个SqlORM 基类
Base = declarative_base()
# 定义表结构
class User(Base):
    # 表名
    __tablename__ = ‘users‘
    # 定义id,主键唯一,
    id = Column(Integer, primary_key=True)
    name = Column(String(50))
# 寻找Base的所有子类，按照子类的结构在数据库中生成对应的数据表信息
Base.metadata.create_all(engine)
# 创建与数据库的会话session class ,注意,这里返回给session的是个class,不是实例
Session = sessionmaker(bind=engine)
session = Session()
# 获取session，然后把对象添加到session
# 最后提交并关闭。Session对象可视为当前数据库连接。

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:123456@127.0.0.1:3306/wang", max_overflow=5)
Base = declarative_base()

class User(Base):
    __tablename__ = ‘users‘
    id = Column(Integer, primary_key=True)
    name = Column(String(50))

Base.metadata.create_all(engine)
Session = sessionmaker(bind=engine)
session = Session()
####  添加 ########
# 定义一个字段
zengjia = User(id=2, name=‘sbliuyao‘)
# 添加字段
session.add(zengjia)
# 添加多个字段
session.add_all([
    User(id=3, name=‘sbyao‘),
    User(id=4, name=‘liuyao‘)
])
# 提交以上操作，现在只是在内存中增加，回写到数据库，就必须做提交操作
session.commit()

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:123456@127.0.0.1:3306/wang", max_overflow=5)
Base = declarative_base()

class User(Base):
    __tablename__ = ‘users‘
    id = Column(Integer, primary_key=True)
    name = Column(String(50))

Base.metadata.create_all(engine)
Session = sessionmaker(bind=engine)
session = Session()

########### 删除 ##########
# 删除user表，id大于2的字段
session.query(User).filter(User.id > 2).delete()
session.commit()

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:123456@127.0.0.1:3306/wang", max_overflow=5)
Base = declarative_base()

class User(Base):
    __tablename__ = ‘users‘
    id = Column(Integer, primary_key=True)
    name = Column(String(50))

Base.metadata.create_all(engine)
Session = sessionmaker(bind=engine)
session = Session()
# user表里的id等于2的字段修改为id=6
session.query(User).filter(User.id == 2).update({‘id‘ : 6})
session.commit()

###　查询方式1 ####
# 查询User表中字段是name=liuyao的第一条数据
ret = session.query(User).filter_by(name=‘liuyao‘).all()
print(ret)  # 输出ret，这是个对象的内存地址
for i in ret:
    print(i.id,i.name)  # 输出ret的内容

###　查询方式2 ####
# 查询user表里字段是name=liuyao的第一条数据
ret = session.query(User).filter_by(name=‘liuyao‘).first()
print(ret)        # 输出的结果为对象的内存地址
print(ret.name)   # 输出结果的name字段
print(ret.id)     # 输出结果的id字段

### 查询方式3 ###
# 查询user表里字段是name是liuyao或者mayun的信息打印出来
ret = session.query(User).filter(User.name.in_([‘liuyao‘,‘mayun‘])).all()
print(ret)
for i in ret:
    print(i.name,i.id)

### 查询方式4 ###
# 可以给返回的结果起一个别名，或者叫标签：可有可无
ret = session.query(User.name.label(‘‘)).all()
# 这里的关键是label方法，它的意思是把User的name字段改个名字叫name_label,
# 其相当于执行了：select users.name as name_label from User
print(ret,type(ret))

### 查询方式5 ###
# 查询User表根据id排序
ret = session.query(User).order_by(User.id).all()
print(ret)
for i in ret:
    print(i.name)

### 查询方式6 ###
# 查询user表里根据id排序输入0到3的字段
ret = session.query(User).order_by(User.id)[0:3]
print(ret)
for i in ret:
    print(i.name)

### 查询方式7 ###
# 创建Query查询，filter是where条件，最后调用one()返回唯一行，如果调用all()则返回所有行
user = session.query(User).filter(User.id==‘5‘).one()
print(type(user))  # 查看user的类型
print(user.name)   # 查看对象的name属性

#!/usr/bin/env python3
#coding:utf8
# 导入所需模块
from sqlalchemy import create_engine,func
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String,ForeignKey
from  sqlalchemy.orm import sessionmaker,relationship
# 生成sqlorm基类
Base = declarative_base()
# 创建数据库连接
engine = create_engine("mysql+pymysql://root:123456@127.0.0.1:3306/wang", max_overflow=5)
# 目的是一个人可以拥有多本书，那么在数据库里的一对多关系
class User(Base):
    # 表名
    __tablename__ = ‘user‘
    # id字段
    id = Column(String(20), primary_key=True)
    # 名字字段
    name = Column(String(20))
    # 一对多:
    # 内容不是表名而是定义的表结构名字
    books = relationship(‘Book‘)
class Book(Base):
    # 表明
    __tablename__ = ‘book‘
    # id字段
    id = Column(String(20), primary_key=True)
    # 名字字段
    name = Column(String(20))
    # “多”的一方的book表是通过外键关联到user表的:
    # ForeignKey是外键 关联user表的id字段
    user_id = Column(String(20), ForeignKey(‘user.id‘))
# 创建所需表
Base.metadata.create_all(engine)

if __name__ == ‘__main__‘:
    # 绑定,生成会话
    SessionCls = sessionmaker(bind=engine)
    session = SessionCls()
    # 创建用户
    liuyao = User(id=‘1‘,name=‘liuyao‘)
    ali = User(id=‘2‘,name=‘ali‘)
    # 添加字段
    session.add_all([liuyao,ali])
    # 提交
    session.commit()
    # 创建白鹿原这本书，指定谁是拥有者
    Whitedeer = Book(id=‘1‘,name=‘White_deer‘,user_id = ‘1‘)
    # 创建三体这本书，指定谁是拥有者
    Threebody = Book(id=‘2‘,name=‘Three_body‘,user_id = ‘2‘)
    # 添加字段
    session.add_all([Whitedeer,Threebody])
    # 提交
    session.commit()