PyMySQL模块, SQLAlchemy基础, SQLAlchemy进阶

PyMySQL模块, SQLAlchemy基础, SQLAlchemy进阶

PyMySQL模块

PyMySQL安装

使用pypi

• pypi即python package index

• 是python语言的软件仓库

• 官方站点为

使用国内镜像站点

• 为了实现安装加速，可以配置pip安装时采用国内镜 像站点 
[root@localhost ~]#	mkdir ~/.pip/ 
[root@localhost ~]#	vim	~/.f
[global]
index-url=/
[install]
trusted-host=pypi.douban

通过pip安装PyMySQL模块

• 安装依赖包
[root@localhost ~]#	yum	install	-y	gcc
• 本地安装
[root@localhost ~]#	pip3 install PyMySQL-0.8.
• 离线安装
[root@localhost ~]# cd /root/python_bao/zzg_pypkgs/pymysql_pkgs
[root@localhost pymysql_pkgs]# pip3 install *
• 在线安装
[root@localhost packages]#	pip3 install pymysql

配置mysql或mariadb

1. 安装
2. 启动
3. 修改密码
4. 创建数据库

[root@localhost ~]# yum install -y mariadb-server
[root@localhost ~]# systemctl start mariadb
[root@localhost ~]# mysql
MariaDB [(none)]> create database nqe default charset utf8;

PyMySQL应用

数据库

为一个小型企业编写数据库，能够记录员工信息，记录发工资情况。

经过调查，需要这些字段：姓名、出生日期、联系方式、部门、工资日、基本工资、奖金、总工资。

关系型数据库，应该尽量减少数据冗余（重复的数据）

姓名	生日	联系方式	部门	工资日	基本工资	奖金	总工资
张三	19950221	13242356	运维	20190510	10000	2000	12000
张三	19950221	13242356	运维部	20190610	10000	2000	12000

为了减少数据冗余，可以将字段存放到不同的表中：员工表、部门表、工资表。

员工表：

姓名	生日	联系方式	部门ID
张三	19950221	13242356	2

部门表：

部门ID	部门名称
2	运维

工资表：

姓名	工资日	基本工资	奖金	总工资
张三	20190510	10000	2000	12000

虽然各张表已经分开了，但是字段并不符合关系型数据库的要求。

关系型数据库字段需要满足数据库范式：

1. 所谓第一范式（1NF）是指在关系模型中，所有的域都应该是原子性的。联系方式不满足1NF，因为它包括家庭住址、电话号码、email等，所以要把联系方式拆分成更小的项目。
2. 2NF在1NF的基础上，非码属性必须完全依赖于码。简单来说就是表需要一个主键。根据2NF，最好为员工表加上员工ID作为主键；工资表应该记录的是员工ID，而不是员工姓名，但是员工ID也不能成为主键，因为每个月都要发工资，用现有的任何字段作为主键都不合适，干脆强加一个主键。
3. 第三范式（3NF）任何非主属性不得传递依赖于主属性，非主属性不能依赖其他非主属性。工资表中的总工资依赖于基本工资和奖金，它不应该出现在表中。最终确定了三张表：
员工表：员工ID、姓名、email、部门ID
部门表：部门ID、部门名称
工资表：工资日、员工ID、基本工资、奖金

配置mysql或mariadb

1. 安装
2. 启动
3. 修改密码
4. 创建数据库

[root@localhost ~]# yum install -y mariadb-server
[root@localhost ~]# systemctl start mariadb
[root@localhost ~]# mysql
MariaDB [(none)]> create database nqe default charset utf8;

# 练习
[root@localhost ~]# vim py_mysql.py
#! /usr/local/python3
import pymysqlconn = t(host = '127.0.0.1',port = 3306,user = 'root',passwd = '123',db = 'nqe',charset = 'utf8'
)cursor = conn.cursor()
[root@localhost ~]# python3 py_mysql.py
[root@localhost ~]# vim py_mysql.py
#! /usr/local/python3
import pymysqlconn = t(host = '127.0.0.1',port = 3306,user = 'root',passwd = '123',db = 'nqe',charset = 'utf8'
)cursor = conn.cursor()
create_dep = '''CREATE TABLE departments(
dep_id INT, dep_name VARCHAR(50),
PRIMARY KEY(dep_id)
)'''
create_emp = '''CREATE TABLE employees(
emp_id INT, emp_name VARCHAR(50), email VARCHAR(50), dep_id INT,
PRIMARY KEY(emp_id), FOREIGN KEY(dep_id) REFERENCES departments(dep_id)
)'''
create_sal = '''CREATE TABLE salary(
id INT, date DATE, emp_id INT, basic INT, awards INT,
PRIMARY KEY(id), FOREIGN KEY(emp_id) REFERENCES employees(emp_id)
)''&#ute(create_dep)
ute(create_emp)
ute(create_sal)connmit()		# 提交改动
cursor.close()		# 关闭游标
conn.close()		# 关闭连接
[root@localhost ~]# python3 py_mysql.py

[root@localhost ~]# mysql -u root -p
Enter password: 
Welcome to the MariaDB monitor.  Commands end with ; or g.
Your MariaDB connection id is 15
Server version: 5.5.64-MariaDB MariaDB ServerCopyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others.Type 'help;' or 'h' for help. Type 'c' to clear the current input statement.MariaDB [(none)]> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| nqe                |
| performance_schema |
| test               |
+--------------------+
7 rows in set (0.00 sec)MariaDB [(none)]> use nqe;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -ADatabase changed
MariaDB [nqe]> show tables;
+---------------+
| Tables_in_nqe |
+---------------+
| departments   |
| employees     |
| salary        |
+---------------+
3 rows in set (0.00 sec)# > drop tables 删除表

import pymysql
conn = t(host='127.0.0.1',port=3306,user='root',passwd='123',db='nqe',charset='utf8'
)cursor = conn.cursor()          # 游标...
# 插入语句
insert_dep = 'INSERT INTO departments VALUES(%s, %s)'
utemany(insert_dep, [(1, '人事部')])
deps = [(2, '财务部'), (3, '运维部'), (4, '开发部'), (5, '测试部'), (6, '市场部')]
utemany(insert_dep, deps)
#############################################connmit()           # 提交改动
cursor.close()          # 关闭游标
conn.close()            # 关闭连接

MariaDB [nqe]> select * from departments;
+--------+-----------+
| dep_id | dep_name  |
+--------+-----------+
|      1 | 人事部    |
|      2 | 财务部    |
|      3 | 运维部    |
|      4 | 开发部    |
|      5 | 测试部    |
|      6 | 市场部    |
+--------+-----------+
6 rows in set (0.00 sec)
# > delete from  departments;

import pymysql
conn = t(host='127.0.0.1',port=3306,user='root',passwd='123',db='nqe',charset='utf8'
)cursor = conn.cursor()          # 游标...
# 基础查询
select1 = 'SELECT * FROM departments'
ute(select1)
print(cursor.fetchone())
print('*' * 20)
print(cursor.fetchmany(2))
print('*' * 20)
print(cursor.fetchall())
#############################################connmit()           # 提交改动
cursor.close()          # 关闭游标
conn.close()            # 关闭连接

[root@localhost ~]# python3 py_mysql.py 
(1, '人事部')
********************
((2, '财务部'), (3, '运维部'))
********************
((4, '开发部'), (5, '测试部'), (6, '市场部'))

import pymysql
conn = t(host='127.0.0.1',port=3306,user='root',passwd='123',db='nqe',charset='utf8'
)cursor = conn.cursor()          # 游标...
# 基础查询
select1 = 'SELECT * FROM departments'
ute(select1)
print(cursor.fetchone())
print('*' * 20)
print(cursor.fetchmany(2))
print('*' * 20)
print(cursor.fetchall())
#############################################connmit()           # 提交改动
cursor.close()          # 关闭游标
conn.close()            # 关闭连接

MariaDB [nqe]> select * from departments order by dep_id;

[root@localhost ~]# python3 py_mysql.py 
(3, '运维部')
********************
(1, '人事部')

import pymysql
conn = t(host='127.0.0.1',port=3306,user='root',passwd='123',db='nqe',charset='utf8'
)cursor = conn.cursor()          # 游标...
# 修改
update1 = 'UPDATE departments set dep_name=%s WHERE dep_name=%s'
ute(update1, ('人力资源部', '人事部'))
#############################################connmit()           # 提交改动
cursor.close()          # 关闭游标
conn.close()            # 关闭连接

[root@localhost ~]# python3 py_mysql.py

MariaDB [nqe]> select * from departments order by dep_id;
+--------+-----------------+
| dep_id | dep_name        |
+--------+-----------------+
|      1 | 人力资源部      |
|      2 | 财务部          |
|      3 | 运维部          |
|      4 | 开发部          |
|      5 | 测试部          |
|      6 | 市场部          |
+--------+-----------------+
6 rows in set (0.00 sec)

import pymysql
conn = t(host='127.0.0.1',port=3306,user='root',passwd='123',db='nqe',charset='utf8'
)cursor = conn.cursor()          # 游标...
# 删除
delete1 = 'DELETE FROM departments WHERE dep_name=%s'
ute(delete1, ('市场部',))connmit()           # 提交改动
cursor.close()          # 关闭游标
conn.close()            # 关闭连接

[root@localhost ~]# python3 py_mysql.py

MariaDB [nqe]> select * from departments order by dep_id;
+--------+-----------------+
| dep_id | dep_name        |
+--------+-----------------+
|      1 | 人力资源部      |
|      2 | 财务部          |
|      3 | 运维部          |
|      4 | 开发部          |
|      5 | 测试部          |
+--------+-----------------+
5 rows in set (0.00 sec)

连接数据库

• 创建连接是访问数据库的第一步
conn = t(host='127.0.0.1',	port=3306,	user='root',passwd='tedu',db=nsd_cloud',	charset='utf8')

游标

• 游标（cursor）就是游动的标识 
• 通俗的说，一条sql取出对应n条结果资源的接口/句柄，就 是游标，沿着游标可以一次取出一行
cursor = conn.cursor()

插入数据

• 对数据库表做修改操作，必须要commit
sql1 = "insert into	departments(dep_name) values(%s)"
result = ute(sql1, ('development',))sql2 = "insert into	departments(dep_name) values(%s)"
data = [('hr',), ('op',)]
result = utemany(sql2, data)sql3 = "insert into departments(dep_name) values(%s)"
data = [('行政',), ('财务',), ('运营',)]
result = utemany(sql3, data)connmit()

查询数据

• 可以取出表中一条、多条或全部记录
sql4 = "select * from departments"
ute(sql4)
result = cur.fetchone()
print(result)result2 = cur.fetchmany(2)
print(result2)result3 = cur.fetchall()
print(result3)

移动游标

• 如果希望不是从头取数据，可以先移动游标
cur.scroll(1, mode="ralative")
cur.scroll(2, mode="absolute")sql5 = "select * from departments"
ute(sql5)
cur.scroll(3, mode='absolute')
result4	= cur.fetchmany(2)s
print(result4)

修改数据

• 通过update修改某一字段的值
sql6 = "update departments set dep_name=%s where dep_name=%s"
result = ute(sql6, ('operations', 'op'))
print(result)
connmit()

删除记录

• 通过delete删除记录
sql7 = "delete from departments where dep_id=%s"
result = ute(sql7, (6,))
print(result)
connmit()

向表中添加数据

1. 通过pymysql模块创建数据库的表
2. 向employees表插入数据
3. 向salary表插入数据
4. 插入的数据需要commit到数据库中

SQLAlchemy基础

SQLAlchemy概述

安装

• SQLAlchemy由官方收录，可以直接安装 
[root@localhost ~]# cd python_bao/zzg_pypkgs/sqlalchemy_pkgs/
[root@localhost sqlalchemy_pkgs]# pip3 install *
[root@localhost sqlalchemy_pkgs]# pip3 install SQLAlchemy-1.2.

简介

• SQLAlchemy是Python编程语下的一款开源软件。提供 SQL 具包及对象关系映射(ORM) 工具，使用MIT许可证发

• SQLAlchemy“采用简单的Python语言，为高效和高性能的数据库访问设计，实现了完整的企业级持久模型”

• SQLAlchemy的理念是，SQL数据库的量级和性能重要于对象集合；而对象集合的抽象又重要于表和行

• 目标是提供能兼容众多数据库（如 SQLite、MySQL、Postgresql、Oracle、MS-SQL、SQLServer 和 Firebird）的企业级持久性模型

架构

SQL Alchemy ORMObject Relational Mapper (ORM)SQL Alchemy Core
Schema / Types		SQL Expression Language		EngineConnection Pooling			DialectDBAPI

ORM模型

• ORM即对象关系映射 
• 数据库表是一个二维表，包含多行多列。把一个表的内容用Python的数据结构表示出来的话，可以用一个list表示多行，list的每一个元素是tuple，表示一行记录
[('1', 'Michael'),('2', 'Bob'),('3', 'Adam')
]- 对象：指OOP编程的方式- 关系：关系型数据库- 将python中的class映射到数据库的表- class中的类变量映射到数据库表中的每个字段- class的每个实例映射到数据库表中的每行记录

ORM模型（续1）

• 用tuple表示一行很难看出表的结构。如果把一个tuple用class实例来表示，就可以更容易地看出表的结构来
class User(object):
def __init__(self, id, name):
self.id = id
self.name =	name
[
User('1', 'Michael'),
User('2', 'Bob'),
User('3', 'Adam')
]

数据库对象管理

连接mysql

• 通过create_engine实现数据库的连接 
[root@bogon bin]# mysql -uroot -ptedu
MariaDB [(none)]> create database tarena default char set utf8;>>>	from sqlalchemy import create_engine
>>>	engine = create_engine( 'mysql+pymysql://root:tedu@localhost/tarena?charset=utf8', encoding='utf8',
echo=True
)
//echo=True表示将日志输出到终端屏幕，默认为False

声明映射

• 当使用ORM的时候，配置过程从描述数据库表开始 
• 通过自定义类映射相应的表 
• 通过声明系统实现类映射 
• 首先通过声明系统，定义基类
>>>	declarative import declarative_base
>>>	Base = declarative_base()

创建映射类

• 一旦创建了基类，就可以创建自定义映射类了
>>>	from sqlalchemy import Column, Integer,	String
>>>	class Departments(Base):
...	__tablename__ =	'departments'
...	dep_id = Column(Integer, primary_key=True)
...	dep_name =	Column(String(20))
...	def __repr__(self):
...		return "<Department(dep_name='%s')>" % self.dep_name
//__repr__是可选项

创建架构

• 类构建完成后，表的信息将被写入到表的元数据 （metadata）
>>>	Departments.__table__
Table('departments', MetaData(bind=None), Column('dep_id', Integer(),	
table=<departments>, primary_key=True, nullable=False),	olumn('dep_name', String(),	table=<departments>), schema=None)

创建架构（续1）

• 通过表的映射类，在数据库中创建表
>>>	ate_all(engine)

创建映射类的实例

• 创建实例时，并不会真正在表中添加记录dep_dev = Departments(dep_name='developments')
print(dep_dev.dep_name)
print(str(dep_dev.dep_id))

创建会话类

• ORM访问数据库的句柄被称作Session>>>	 import sessionmaker
>>>	Session	= sessionmaker(bind=engine)如果在创建session前还未创建engine，操作如下
>>>	Session	= sessionmaker()
>>>	figure(bind=engine) //创建engine后执行

添加新对象

• 会话类的实例对象用于绑定到数据库 
• 实例化类的对象，并不打开任何连接 
• 当实例初次使用，它将从Engine维护的连接池中获 得一个连接 
• 当所有的事务均被commit或会话对象被关闭时，连接结束
>>>	session	= Session()
>>>	session.add(dep_dev)
>>> sessionmit()
>>> print(str(dep_dev.dep_id))
>>> session.close()

添加新对象（续1）

• 可以创建多个实例，批量添加记录dep_hr = Departments(dep_name='hr')
dep_op = Departments(dep_name='operations')
dep_finance = Departments(dep_name='财务')
dep_xz = Departments(dep_name='行政’)
Session	= sessionmaker(engine)
session	= Session()
session.add_all([dep_hr, dep_op, dep_finance, dep_xz])
sessionmit()
session.close()

外键约束

• ORM映射关系也可用于表间创建外键约束
class Employees(Base):__tablename__ = 'employees'emp_id = Column(Integer, primary_key=True)name = Column(String(20))genda =	Column(String(10))phone =	Column(String(11))dep_id = Column(Integer,	ForeignKey('departments.dep_id'))def __repr__(self):return "<Employees(name='%s')>"	% self.name

新建数据库

MariaDB [(none)]> create database mqe default charset utf8;
Query OK, 1 row affected (0.00 sec)MariaDB [(none)]> use mqe;
Database changed

dbconn.py

from sqlalchemy import create_engine, Column, Integer, String, ForeignKey
declarative import declarative_baseengine = create_engine(# mysql+pymymysql://用户名:密码@服务器/数据库?参数'mysql+pymysql://root:123@127.0.0.1/mqe?charset=utf8',encoding='utf8',# echo=True  # 在屏幕上输出日志，生产环境中不要使用
)
# 创建ORM的基类
Base = declarative_base()class Department(Base):__tablename__ = 'departments'  # 定义库中的表名dep_id = Column(Integer, primary_key=True)dep_name = Column(String(50), unique=True, nullable=False)if __name__ == '__main__':# 如果库中没有相关的表则创建，有的话不会创建ate_all(engine)

[root@localhost ~]# python3 dbconn.py

MariaDB [(none)]> use mqe;
Database changed
MariaDB [mqe]> show tables;
Empty set (0.01 sec)MariaDB [mqe]> show tables;
+---------------+
| Tables_in_mqe |
+---------------+
| departments   |
+---------------+
1 row in set (0.00 sec)
# > drop tables 删除表

from sqlalchemy import create_engine, Column, Integer, String, ForeignKey
declarative import declarative_baseengine = create_engine(# mysql+pymymysql://用户名:密码@服务器/数据库?参数'mysql+pymysql://root:tedu@127.0.0.1/mqe?charset=utf8',encoding='utf8',# echo=True  # 在屏幕上输出日志，生产环境中不要使用
)
# 创建ORM的基类
Base = declarative_base()class Department(Base):...class Employee(Base):__tablename__ = 'employees'emp_id = Column(Integer, primary_key=True)emp_name = Column(String(50), nullable=False)email = Column(String(50), unique=True, nullable=False)dep_id = Column(Integer, ForeignKey('departments.dep_id'))if __name__ == '__main__':# 如果库中没有相关的表则创建，有的话不会创建ate_all(engine)

[root@localhost ~]# python3 dbconn.py

MariaDB [mqe]> show tables;
+---------------+
| Tables_in_mqe |
+---------------+
| departments   |
| employees     |
+---------------+
2 rows in set (0.00 sec)

from sqlalchemy import create_engine, Column, Integer, String, ForeignKey, Date
declarative import declarative_baseengine = create_engine(# mysql+pymymysql://用户名:密码@服务器/数据库?参数'mysql+pymysql://root:tedu@127.0.0.1/tedu1812?charset=utf8',encoding='utf8',# echo=True  # 在屏幕上输出日志，生产环境中不要使用
)
# 创建ORM的基类
Base = declarative_base()class Department(Base):...class Employee(Base):...class Salary(Base):__tablename__ = 'salary'id = Column(Integer, primary_key=True)date = Column(Date, nullable=False)emp_id = Column(Integer, ForeignKey(&#p_id'))basic = Column(Integer)awards = Column(Integer)if __name__ == '__main__':# 如果库中没有相关的表则创建，有的话不会创建ate_all(engine)

[root@localhost ~]# python3 dbconn.py

MariaDB [mqe]> show tables;
+---------------+
| Tables_in_mqe |
+---------------+
| departments   |
| employees     |
| salary        |
+---------------+
3 rows in set (0.00 sec)

....
 import sessionmaker
....
# 创建ORM的基类
Base = declarative_base()
Session = sessionmaker(bind=engine)
....

创建表

1. 创建employees表
2. 创建部门表
3. 创建salary表
4. 表间创建恰当的关系

添加数据

1. 分别在部门表、员工表和工资表中加入数据
2. 通过SQLAlchemy代码实现
3. 分别练习每次加入一行数据和每次可加入多行数据

SQLAlchemy进阶

查询操作

基本查询

• 通过作用于session的query()函数创建查询对象 
• query()函数可以接收多种参数from myorm import Session, Departmentssession	= Session()for	instance in	session.query(Departments).order_by(Departments.dep_id):print(instance.dep_id, instance.dep_name)

使用ORM描述符进行查询

• 使用ORM描述符进行查询 
• 返回值是元组from myorm import Employees, Sessionsession	= Session()for	name, phone	in session.query(Employees.name,Employees.phone):print(name,	phone)

排序

• 通这order_by()函数可以实现按指定字段排序from myorm import Session, Departmentssession	= Session()for	instance in	session.query(Departments).order_by(Departments.dep_id):print(instance.dep_id,instance.dep_name)

提取部分数据

• 通过“切片”的方式，实现部分数据的提取from myorm import Session, Departmentssession	= Session()for row	in session.query(Departments, Departments.dep_name)[2:5]:print(row.Departments,	row.dep_name)

结果过滤

• 通过filter()函数实现结果过滤from myorm import Session, Departmentssession	= Session()for	row	in	session.query(Departments.dep_name).filter(Departments.dep_id==2):print(row.dep_name)

结果过滤（续1）

• filter()函数可以叠加使用from myorm import Session, Salarysession	= Session()for	row	in session.p_id, Salary.base,	Salary.award).filter(Salary.award>2000).filter(Salary.base>10000):p_id)

常用过滤操作符

• 相等query.filter(Employees.name=='john')
• 不相等query.filter(Employees.name!='john')
• 模糊查询query.filter(Employees.name.like('%j'))

常用过滤操作符（续1）

• inquery.filter(new_emp.name.in_(['bob', 'john'])
• not inquery.filter(~new_emp.name.in_(['bob', 'john']) 
• 字段为空query.filter(new_emp.name.is_(None)) 
• 字段不为空query.filter(new_emp.name.isnot(None))

查询对象返回值

• all()返回列表 
• first()返回结果中的第一条记录

修改操作

多表查询

• 通过join()方法实现多表查询
q = session.query(
Employees.name,	Departments.dep_name).join(Departments)
print(q.all())

更新数据

• 通过会话的update()方法更新
from myorm import Session, Departments
session	= Session()
q1 = session.query(Departments).filter(Departments.dep_id==6)
q1.update({Departments.dep_name: '运维部'})
sessionmit()
session.close()

更新数据（续1）

• 通过会话的字段赋值更新
from myorm import Session, Departments
session	= Session()
q2 = session.query(Departments).get(1) # get(1)查询主键是1的记录
q2.dep_name	= '开发部'
sessionmit()
session.close()

删除记录

• 通过会话的delete()方法进行记录删除
from myorm import Session, Departments
session	= Session()
q1 = session.query(Departments).get(7)
session.delete(q1)
sessionmit()
session.close()

crud.py

from dbconn import Session, Department, Employee, Salarysession = Session()
########################
hr = Department(dep_id=1, dep_name='人事部')
finance = Department(dep_id=2, dep_name='财务部')
ops = Department(dep_id=3, dep_name='运维部')
dev = Department(dep_id=4, dep_name='开发部')
qa = Department(dep_id=5, dep_name='测试部')
session.add_all([hr, finance, ops, dev, qa])sessionmit()
session.close()

[root@localhost ~]# python3 crud.py

MariaDB [mqe]> select * from departments;
+--------+-----------+
| dep_id | dep_name  |
+--------+-----------+
|      1 | 人事部    |
|      4 | 开发部    |
|      5 | 测试部    |
|      2 | 财务部    |
|      3 | 运维部    |
+--------+-----------+
5 rows in set (0.00 sec)

from dbconn import Session, Department, Employee, Salarysession = Session()...
#########################
wt = Employee(emp_id=1,emp_name='王涛',email='wangtao@qq',dep_id=3
)
zj = Employee(emp_id=2,emp_name='张钧',email='zhangjun@163',dep_id=3
)
sy = Employee(emp_id=3,emp_name='苏艳',email='suyan@qq',dep_id=1
)
wjy = Employee(emp_id=4,emp_name='吴计印',email='wujiying@126',dep_id=4
)
kzw = Employee(emp_id=5,emp_name='康志文',email='kangzhiwen@qq',dep_id=4
)
hzq = Employee(emp_id=6,emp_name='胡志强',email='huzhiqiang@163',dep_id=5
)
lh = Employee(emp_id=7,emp_name='李浩',email='lihao@126',dep_id=2
)
session.add_all([wt, zj, sy, wjy, kzw, hzq, lh])sessionmit()
session.close()

[root@localhost ~]# python3 crud.py

MariaDB [mqe]> select * from employees;
+--------+-----------+--------------------+--------+
| emp_id | emp_name  | email              | dep_id |
+--------+-----------+--------------------+--------+
|      1 | 王涛      | wangtao@qq     |      3 |
|      2 | 张钧      | zhangjun@163   |      3 |
|      3 | 苏艳      | suyan@qq       |      1 |
|      4 | 吴计印    | wujiying@126   |      4 |
|      5 | 康志文    | kangzhiwen@qq  |      4 |
|      6 | 胡志强    | huzhiqiang@163 |      5 |
|      7 | 李浩      | lihao@126      |      2 |
+--------+-----------+--------------------+--------+
7 rows in set (0.00 sec)

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset1 = session.query(Department)
print(qset1)  # qset1只是个sql语句，当取具体值的时候，才真正查数据库
# qset1.all()取出全部的部门，因为查询的是类名，所以返回所有的实例组成的列表
print('*' * 30)
print(qset1.all())
print('*' * 30)
for dep in qset1:  # 遍历实例列表中的每个实例print('%s: %s' % (dep.dep_id, dep.dep_name))sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
SELECT departments.dep_id AS departments_dep_id, departments.dep_name AS departments_dep_name 
FROM departments
******************************
[<dbconn.Department object at 0x7f5369838c10>, <dbconn.Department object at 0x7f5369838c90>, <dbconn.Department object at 0x7f5369838d50>, <dbconn.Department object at 0x7f5369838dd0>, <dbconn.Department object at 0x7f5369838e50>]
******************************
1: 人事部
4: 开发部
5: 测试部
2: 财务部
3: 运维部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset3 = session.p_name, ail)
# 查询的参数是字段，返回的结果是元组
for item in qset3:print(item)
print('*' * 30)
for name, email in qset3:print('%s: %s' % (name, email))sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
('王涛', 'wangtao@qq')
('张钧', 'zhangjun@163')
('苏艳', 'suyan@qq')
('吴计印', 'wujiying@126')
('康志文', 'kangzhiwen@qq')
('胡志强', 'huzhiqiang@163')
('李浩', 'lihao@126')
******************************
王涛: wangtao@qq
张钧: zhangjun@163
苏艳: suyan@qq
吴计印: wujiying@126
康志文: kangzhiwen@qq
胡志强: huzhiqiang@163
李浩: lihao@126

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#########################
qset4 = session.query(Department).order_by(Department.dep_id)[1:4]
for dep in qset4:  # 遍历实例列表中的每个实例print('%s: %s' % (dep.dep_id, dep.dep_name))sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
2: 财务部
3: 运维部
4: 开发部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset5 = session.query(Department).filter(Department.dep_id==2)
print(qset5)
print(qset5.all())  # all()返回列表
dep = ()  # 返回一个实例，如果返回值不是一个，将报错
print(dep.dep_id, dep.dep_name)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
SELECT departments.dep_id AS departments_dep_id, departments.dep_name AS departments_dep_name 
FROM departments 
WHERE departments.dep_id = %(dep_id_1)s
[<dbconn.Department object at 0x7f5471b02e50>]
2 财务部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset6 = session.query(Department).filter(Department.dep_id>1).filter(Department.dep_id<4)
for dep in qset6:print(dep.dep_id, dep.dep_name, sep=', ')sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
2, 财务部
3, 运维部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset7 = session.query(Employee).ail.like('%@qq'))
for emp in qset7:p_name, ail)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
王涛 wangtao@qq
苏艳 suyan@qq
康志文 kangzhiwen@qq

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset8 = session.query(Department).filter(Department.dep_id.in_([3, 4]))
for dep in qset8:print(dep.dep_id, dep.dep_name)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
4 开发部
3 运维部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset9 = session.query(Department).filter(Department.dep_name.isnot(None))
for dep in qset9:print(dep.dep_id, dep.dep_name)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
1 人事部
4 开发部
5 测试部
2 财务部
3 运维部

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
# query中先写的是Employee，join中要写Department
qset10 = session.p_name, Department.dep_name).join(Department)
for row in qset10:print(row)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
('王涛', '运维部')
('张钧', '运维部')
('苏艳', '人事部')
('吴计印', '开发部')
('康志文', '开发部')
('胡志强', '测试部')
('李浩', '财务部')

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
qset11 = session.query(Department.dep_name, p_name).join(Employee)
for row in qset11:print(row)sessionmit()
session.close()

[root@localhost ~]# python3 crud.py 
('运维部', '王涛')
('运维部', '张钧')
('人事部', '苏艳')
('开发部', '吴计印')
('开发部', '康志文')
('测试部', '胡志强')
('财务部', '李浩')

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
# 修改数据，先找到实例，再给实例的属性重新赋值
qset12 = session.query(Department).filter(Department.dep_name=='人事部')
hr = ()
hr.dep_name='人力资源部'sessionmit()
session.close()

[root@localhost ~]# python3 crud.py

MariaDB [mqe]> select * from departments;
+--------+-----------------+
| dep_id | dep_name        |
+--------+-----------------+
|      1 | 人力资源部      |
|      4 | 开发部          |
|      5 | 测试部          |
|      2 | 财务部          |
|      3 | 运维部          |
+--------+-----------------+
5 rows in set (0.00 sec)

from dbconn import Session, Department, Employee, Salarysession = Session()
...
#######################
# 删除，只要找到实例，然后删除即可
qset13 = session.query(Employee).p_id==6)
emp = ()
session.delete(emp)sessionmit()
session.close()

MariaDB [mqe]> select * from employees;
+--------+-----------+-------------------+--------+
| emp_id | emp_name  | email             | dep_id |
+--------+-----------+-------------------+--------+
|      1 | 王涛      | wangtao@qq    |      3 |
|      2 | 张钧      | zhangjun@163  |      3 |
|      3 | 苏艳      | suyan@qq      |      1 |
|      4 | 吴计印    | wujiying@126  |      4 |
|      5 | 康志文    | kangzhiwen@qq |      4 |
|      7 | 李浩      | lihao@126     |      2 |
+--------+-----------+-------------------+--------+
6 rows in set (0.00 sec)

操作数据

1. 修改部门表，将人事部改为人力资源部
2. 如果存在设计部，将设计部删除
3. 查询所有每个员工及其所在部门