ORM框架SQLAlchemy

from sqlalchemy import create_engine

#1 准备
# 需要事先安装好pymysql
# 需要事先创建好数据库:create database com charset utf8;

#2 创建引擎
engine=create_engine(‘mysql+pymysql://adm:123456@127.0.0.1:3306/com‘, echo=True)

#3 执行sql
# egine.execute(‘create table if not EXISTS t1(id int PRIMARY KEY auto_increment,name char(32));‘)

# cur=egine.execute(‘insert into t1 values(%s,%s);‘,[(1,"egon1"),(2,"egon2"),(3,"egon3")]) #按位置传值

# cur=egine.execute(‘insert into t1 values(%(id)s,%(name)s);‘,name=‘egon4‘,id=4) #按关键字传值

#4 新插入行的自增id
# print(cur.lastrowid)

#5 查询
cur=egine.execute(‘select * from t1‘)

cur.fetchone() #获取一行
cur.fetchmany(2) #获取多行
cur.fetchall() #获取所有行

#1、MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
   
#2、pymysql
    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
   
#3、MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
   
#4、cx_Oracle
    oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]

更多详见：http://docs.sqlalchemy.org/en/latest/dialects/index.html 

#!/usr/bin/env python
# -*- encoding: utf-8 -*-
‘‘‘
@File    :   orm_pro.py
@Time    :   2020/01/07 22:11:59
@Author  :   yusheng_liang 
@Version :   1.0
‘‘‘
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String, ForeignKey
from sqlalchemy.orm import sessionmaker

engine = create_engine(‘mysql+pymysql://adm:123456@127.0.0.1:3306/com?charset=utf8‘,max_overflow=5)

Base = declarative_base()

# 一、创建两个表的项目结构
# 多对一：假如多个员工可以属于一个部门，而多个部门不能有同一个员工
class Dep(Base):
    __tablename__=‘dep‘
    id=Column(Integer, primary_key=True, autoincrement=True)
    dname=Column(String(32), index=True, nullable=False)

class Emp(Base):
    __tablename__=‘emp‘
    id=Column(Integer, primary_key=True, autoincrement=True)    
    ename=Column(String(32), nullable=False, index=True)
    dep_id=Column(Integer, ForeignKey(‘dep.id‘))

# 创建表结构的方法
def init_db():
    Base.metadata.create_all(engine)
# 删除表结构的方法
def drop_db():
    Base.metadata.drop_all(engine)

init_db()

Session=sessionmaker(bind=engine)
session=Session()

# 二、表结构创建完成后，可以对表进行增、删、改、查操作了


# 2.1增加数据的操作
row_obj=Dep(dname=‘销售部‘)   #按关键字传参，无需指定id，因id列是自动增长的
session.add(row_obj)
#也可以批量增加数据的操作
# session.add_all(
#     [
#         Dep(dname=‘人事部‘),
#         Dep(dname=‘财务部‘),
#         Dep(dname=‘技术部‘),
#     ]
# )

#提交数据，将数据插入到数据库中
session.commit()


# 2.2删除数据
# 删除Dep表中id大于3的数据记录
session.query(Dep).filter(Dep.id > 3).delete()
session.commit()


# 2.3修改数据
# 更新Dep表中id为1的dname列的值
session.query(Dep).filter(Dep.id == 1).update({‘dname‘:‘yusheng‘})
session.commit()


# 2.4查询数据
# 查询Dep表中的所有数据
ret = session.query(Dep).all()
# 查询Dep表中的dname列的数据，按id排序
res=session.query(Dep.dname).order_by(Dep.id).all()

result=session.query(Dep.dname).first()
print(result)  #yusheng

# 过渡查询数据,以逗号分隔，默认为and
results=session.query(Dep).filter(Dep.id >1, Dep.id < 1000)
print([(row.id, row.dname) for row in results])

# 三、其他操作
# 3.1条件查询
sql=session.query(Emp).filter_by(ename=‘admin‘) #filter_by只能传参数，XOXX=XOXX
ret=sql.all() #sql语句执行查询的结果

res=session.query(Emp).filter(Emp.id > 1, Emp.ename == ‘admin‘).all() #filter内传的是表达式,逗号分隔,默认为and,
res=session.query(Emp).filter(Emp.id.between(1,3), Emp.ename == ‘admin‘).all()
res=session.query(Emp).filter(Emp.id.in_([1,3,55,78]), Emp.ename == ‘admin‘).all()
res=session.query(Emp).filter(~Emp.id.in_([1,3,55,78]), Emp.ename == ‘admin‘).all()  #~代表取反,转换成sql就是关键字not

from sqlalchemy import and_, or_
res=session.query(Emp).filter(and_(Emp.id > 1, Emp.ename == ‘admin‘)).all()
res=session.query(Emp).filter(or_(Emp.id < 2, Emp.ename == ‘admin‘)).all()
res=session.query(Emp).filter(or_(
    Emp.dep_id == 3,
    and_(Emp.id > 1, Emp.ename == ‘admin‘),
    Emp.ename != ‘‘
)).all()

# 3.2通配符
res=session.query(Emp).filter(Emp.ename.like(‘%yu%‘)).all()
res.session.query(Emp).filter(~Emp.ename.like(‘%yu%‘)).all()

# 3.3limit
result=session.query(Emp)[0:5:2]

# 3.4排序
res=session.query(Emp).order_by(Emp.id.desc()).all()

# 3.5分组
from sqlalchemy.sql import func
res=session.query(Emp.dep_id).group_by(Emp.dep_id).all()
res=session.query(
    func.max(Emp.dep_id),
    func.min(Emp.dep_id),
    func.sum(Emp.dep_id),
    func.avg(Emp.dep_id),
    func.count(Emp.dep_id),
).group_by(Emp.dep_id).all()

res=session.query(
    Emp.dep_id,
    func.count(1),
).group_by(Emp.dep_id).having(func.count(1) > 2).all()


# 3.6连表操作
#笛卡尔积
res=session.query(Emp,Dep).all()  #select * from emp,dep;

# where条件
res=session.query(Emp, Dep).filter(Emp.dep_id == Dep.id).all()
# for row in res:
#     emp_tb=row[0]
#     dep_tb=row[1]
#     print(emp_tb.id,emp_tb.ename,dep_tb.id,dep_tb.dname)

# 内连接
ret=session.query(Emp).join(Dep)
#join默认为内连接,SQLAlchemy会自动帮我们通过foreign key字段去找关联关系
#但是上述查询的结果均为Emp表的字段,这样链表还有毛线意义,于是我们修改为
ret=session.query(Emp.id,Emp.ename,Emp.dep_id,Dep.dname).join(Dep).all()

# 左连接isouter=True
res=session.query(Emp.id,Emp.ename,Emp.dep_id,Dep.dname).join(Dep,isouter=True).all()
#右连接:同左连接,只是把两个表的位置换一下

# 3.7组合
q1=session.query(Emp.id,Emp.ename).filter(Emp.id > 0,Emp.id < 5)
q2=session.query(Emp.id,Emp.ename).filter(
    or_(
        Emp.ename.like(‘%大小%‘),
        Emp.ename.like(‘%上学%‘),
    )
)
res1=q1.union(q2) #组合+去重
res2=q1.union_all(q2) #组合,不去重

print([i.ename for i in q1.all()]) 
print([i.ename for i in q2.all()]) 
print([i.ename for i in res1.all()]) 
print([i.ename for i in res2.all()]) 


# 3.8子查询
# 有三种形式的子查询，注意：子查询的sql必须用括号包起来,尤其在形式三中需要注意这一点



#示例:查出id大于2的员工,当做子查询的表使用

#原生SQL:
# select * from (select * from emp where id > 2);

#ORM:
res=session.query(
    session.query(Emp).filter(Emp.id > 2).subquery()
).all()



#示例:#查出销售部门的员工姓名

#原生SQL:
# select ename from emp where dep_id in (select id from dep where dname=‘销售‘);

#ORM:
res=session.query(Emp.ename).filter(Emp.dep_id.in_(
    session.query(Dep.id).filter_by(dname=‘销售‘), #传的是参数
    # session.query(Dep.id).filter(Dep.dname==‘销售‘) #传的是表达式
)).all()



#示例:查询所有的员工姓名与部门名

#原生SQL:
# select ename as 员工姓名,(select dname from dep where id = emp.dep_id) as 部门名 from emp;

#ORM:
sub_sql=session.query(Dep.dname).filter(Dep.id==Emp.dep_id) #SELECT dep.dname FROM dep, emp WHERE dep.id = emp.dep_id
sub_sql.as_scalar() #as_scalar的功能就是把上面的sub_sql加上了括号

res=session.query(Emp.ename,sub_sql.as_scalar()).all()