python 之 数据库（多表查询之连接查询、子查询、pymysql模块的使用）

select * from emp,dep；                                  #连接两张表的笛卡尔积
select * from emp,dep where emp.dep_id = dep.id;            # 不推荐用where连接表
select * from emp inner join dep on emp.dep_id = dep.id;    #推荐
+----+-----------+--------+------+--------+------+--------------+
| id | name      | sex    | age  | dep_id | id   | name         |
+----+-----------+--------+------+--------+------+--------------+
|  1 | egon      | male   |   18 |    200 |  200 | 技术         |
|  2 | alex      | female |   48 |    201 |  201 | 人力资源     |
|  3 | wupeiqi   | male   |   38 |    201 |  201 | 人力资源     |
|  4 | yuanhao   | female |   28 |    202 |  202 | 销售         |
|  5 | liwenzhou | male   |   18 |    200 |  200 | 技术         |
+----+-----------+--------+------+--------+------+--------------+

select * from emp left join dep on emp.dep_id = dep.id;
+----+------------+--------+------+--------+------+--------------+
| id | name       | sex    | age  | dep_id | id   | name         |
+----+------------+--------+------+--------+------+--------------+
|  1 | egon       | male   |   18 |    200 |  200 | 技术         |
|  5 | liwenzhou  | male   |   18 |    200 |  200 | 技术         |
|  2 | alex       | female |   48 |    201 |  201 | 人力资源     |
|  3 | wupeiqi    | male   |   38 |    201 |  201 | 人力资源     |
|  4 | yuanhao    | female |   28 |    202 |  202 | 销售         |
|  6 | jingliyang | female |   18 |    204 | NULL | NULL         |
+----+------------+--------+------+--------+------+--------------+

select * from emp right join dep on emp.dep_id = dep.id;
+------+-----------+--------+------+--------+------+--------------+
| id   | name      | sex    | age  | dep_id | id   | name         |
+------+-----------+--------+------+--------+------+--------------+
|    1 | egon      | male   |   18 |    200 |  200 | 技术         |
|    2 | alex      | female |   48 |    201 |  201 | 人力资源     |
|    3 | wupeiqi   | male   |   38 |    201 |  201 | 人力资源     |
|    4 | yuanhao   | female |   28 |    202 |  202 | 销售         |
|    5 | liwenzhou | male   |   18 |    200 |  200 | 技术         |
| NULL | NULL      | NULL   | NULL |   NULL |  203 | 运营         |
+------+-----------+--------+------+--------+------+--------------+

select * from emp left join dep on emp.dep_id = dep.id
union
select * from emp right join dep on emp.dep_id = dep.id;
+------+------------+--------+------+--------+------+--------------+
| id   | name       | sex    | age  | dep_id | id   | name         |
+------+------------+--------+------+--------+------+--------------+
|    1 | egon       | male   |   18 |    200 |  200 | 技术         |
|    5 | liwenzhou  | male   |   18 |    200 |  200 | 技术         |
|    2 | alex       | female |   48 |    201 |  201 | 人力资源     |
|    3 | wupeiqi    | male   |   38 |    201 |  201 | 人力资源     |
|    4 | yuanhao    | female |   28 |    202 |  202 | 销售         |
|    6 | jingliyang | female |   18 |    204 | NULL | NULL         |
| NULL | NULL       | NULL   | NULL |   NULL |  203 | 运营         |
+------+------------+--------+------+--------+------+--------------+

#查询技术部员工的名字
select emp.name from emp inner join dep on emp.dep_id = dep.id where dep.name="技术";#连接查询
select name from emp where dep_id =(select id from dep where name="技术");          #子查询
+-----------+
| name      |
+-----------+
| egon      |
| liwenzhou |
+-----------+
#查询平均年龄在25岁以上的部门名                                                       #子查询
select name from dep where id in (select dep_id from emp group by dep_id having avg(age) > 25);
select dep.name from emp inner join dep on emp.dep_id = dep.id                         #连接查询
    group by dep.name
    having avg(age) > 25;
+--------------+
| name         |
+--------------+
| 人力资源      |
| 销售          |
+--------------+
#查询每个部门最新入职的那位员工
select t1.id,t1.name,t1.post,t1.hire_date,t2.post,t2.max_date from (emp as t1) inner join
(select post,max(hire_date) as max_date from emp group by post) as t2   #拿到最大雇佣时间
on t1.post = t2.post
where t1.hire_date = t2.max_date;
+----+--------+-----------------------------------------+----
| id | name   | post    | hire_date  | post    |  max_date  |
+----+--------+-----------------------------------------+-----
|  1 | egon   | 外交大使 | 2017-03-01 | 外交大使 | 2017-03-01 |
|  2 | alex   | teacher | 2015-03-02 | teacher  | 2015-03-02 |
| 13 | 格格   | sale     | 2017-01-27 | sale     | 2017-01-27 |
| 14 | 张野   | operation| 2016-03-11 | operation| 2016-03-11 |
+----+--------+-----------------------------------------+-----

select * from emp where exists (select id from dep where id > 3);       #找到所有

import pymysql              #pip3 install pymysql
conn=pymysql.connect(        #连接
    host=‘127.0.0.1‘,
    port=3306,
    user=‘root‘,
    password=‘‘,
    database=‘db2‘,
    charset=‘utf8‘)
cursor=conn.cursor(pymysql.cursors.DictCursor)#以字典形式显示表的记录
rows=cursor.execute(‘show tables;‘)           #1 显示受影响的行数(row),此处为有表的条数
print(rows)
rows=cursor.execute(‘select * from emp;‘)      #18 此处rows为emp表内有记录的条数
print(rows)
?
print(cursor.fetchone())     #查看一条记录 一个字典{key:value}
print(cursor.fetchmany(2))   #查看多条记录 [{key:value},]
#print(cursor.fetchall())    #查看所有记录 强调：下一次查找是接着上一次查找的位置继续
?
cursor.scroll(0,‘absolute‘)  #绝对移动，以0位置为参照显示
print(cursor.fetchone())
?
cursor.scroll(1,‘relative‘)  #相对移动，相对当前位置移动1条记录
print(cursor.fetchone())
?
cursor.close()#光标
conn.close()

import pymysql 
conn=pymysql.connect(
    host=‘127.0.0.1‘,
    port=3306,
    user=‘root‘,
    password=‘‘,
    database=‘db2‘,
    charset=‘utf8‘)
cursor=conn.cursor(pymysql.cursors.DictCursor)          
sql=‘insert into user(username,password) values(%s,%s)‘         #插入单行记录
rows=cursor.execute(sql,(‘EGON‘,‘123456‘))              
print(rows)
print(cursor.lastrowid)                                      #显示当前最后一行的id
?
sql=‘insert into user(username,password) values(%s,%s)‘         #一次插入多行记录
rows=cursor.executemany(sql,[(‘lwz‘,‘123‘),(‘evia‘,‘455‘),(‘lsd‘,‘333‘)])
print(rows)
?
rows=cursor.execute(‘update user set username="alexSB" where id=2‘)#修改记录
print(rows)
?
conn.commit() # 只有commit提交才会完成真正的修改
cursor.close()
conn.close()