1、多表联合查询
查询没有被购买过的商品
select goods.name from goods left join user on goods.gid=user.gid where user.id is NULL;
查询哪类商品是销量冠军
select category, count(*) as c from user join goods on user.gid=goods.gid group by category order by c desc limit 1;
查询哪个商品是销量冠军
select goods.name, goods.price, count(*) as c from user join goods on user.gid=goods.gid group by goods.name order by c desc limit 1;
分组只能写分组字段和统计字段，写其它字段报错
进入mysql执行如下指令
SET @@GLOBAL.sql_mode="STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION";
清空表
truncate table 表名 清空表，id会从1开始
delete from table 清空表，id从上次记录的值开始
创建用户
mysql -h ip地址 -u用户名 -p
create user 'test'@'ip' identified by '密码'
2、索引
索引是什么？索引就是个东西，类似是目录的东西
数据库在查询的时候，是一条一条挨着查呢。查询效率太低了。
如何提高查询效率？索引
如果在查询的时候，经常通过某个字段查询，那就要考虑给这个字段添加索引。
索引的缺点：在插入的时候效率就比较低
索引有
普通索引
唯一索引 要确保唯一性
主键索引 是特殊的唯一索引，但是不能为空
全文索引
3、数据库导入导出
数据库里面的表可以导出来，导出来一般都是sql脚本的东西， data.sql
【注】版本，通过指令导出和通过不同的可视化工具导出，格式也不一样。
mysql自带的指令：
正常终端模式下
导出：mysqldump -uroot -p 数据库名>c:\data.sql
导入：mysql -uroot -p 数据库名<c:\data.sql
注意，导入之前首先创建一个新的数据库
Navicat导出和导入：
右键==》转储sql文件
右键==》运行sql文件
4、python操作数据库
需要使用到第三方库：pymysql，在python交互界面输入 import pymysql 看有没有报错，报错了就是没有它，没报错就是有它
安装之：pip install pymysql
代码操作之
port只能是整型
import pymysql
# 第一步，连接数据库，类似于指令里面的 mysql -uroot -p
# mysql -h地址 -uroot -p
'''
连接数据库需要用到的参数
主机：host
端口：port
用户名：user
密码：password
指定数据库：db
指定字符集：charset
'''
db = pymysql.connect(host='localhost', port=3306, user='root', password='123456', db='dudu', charset='utf8')
# 连接成功之后，得到一个对象
# print(db)
# 首先根据db得到游标，游标就是执行sql语句用到的东西
# cursor = db.cursor()
# 给cursor添加一个参数，让其的到数据是一个字典
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
# 准备sql语句，执行sql语句
sql = 'select * from star'
# 返回结果rows是受影响的行数
rows = cursor.execute(sql)
# print(rows)
# 通过cursor的方法得到数据
# 返回一个元组，元组里面每个元素的值对应的就是数据表中每个字段对应的值
# 获取内容的时候，里面有个迭代器在记录你的位置
# print(cursor.fetchone())
# print(cursor.fetchone())
# print(cursor.fetchone())
# print(cursor.fetchone())
# print(cursor.fetchmany(5))
# print(cursor.fetchmany(5))
# 元组里面套元组
# print(cursor.fetchall())
# 打印得到所有的用户名
ret = cursor.fetchall()
for obj in ret:
print('我叫%s,我来自%s,我有%s￥' % (obj['name'], obj['province'], obj['money']))
# print(ret)
# 遍历每一个元组
# for tp in ret:
# print(tp[1])
# 最后呀，要记得关闭
cursor.close()
db.close()
import pymysql
db = pymysql.connect(host='localhost', port=3306, user='root', passwd='123456', db='dudu', charset='utf8')
# print(db)
cursor = db.cursor()
sql = 'select * from start'
# 查询语句，通过try-except，让代码更加健壮
try:
ret = cursor.execute(sql)
print(cursor.fetchall())
except Exception as e:
print(e)
finally:
cursor.close()
db.close()
import pymysql
db = pymysql.connect(host='localhost', port=3306, user='root', passwd='123456', db='dudu', charset='utf8')
cursor = db.cursor()
'''
# 准备sql语句
obj = {'name': '李云龙', 'money': '20', 'province': '河南', 'age': 36, 'sex': '男'}
# 注意，这里的引号需要加
sql = 'insert into star(name, money, province, age, sex) values("%s", "%s", "%s", "%s", "%s")' % (obj['name'], obj['money'], obj['province'], obj['age'], obj['sex'])
'''
# id = 8
# sql = 'delete from star where id=%s' % id
sql = 'update star set name="马德华" where id=12'
# 注意，没有添加进去，是因为没有提交，需要提交才能成功
try:
cursor.execute(sql)
# 提交，写入磁盘
db.commit()
except Exception as e:
print(e)
# 回滚到最初始的状态
db.rollback()
finally:
cursor.close()
db.close()
import pymysql
class MyMysql(object):
def __init__(self, host, port, user, password, db, charset):
self.host = host
self.port = port
self.user = user
self.password = password
self.db = db
self.charset = charset
# 链接数据库
self.connect()
def connect(self):
# 链接数据库和获取游标
self.db = pymysql.connect(host=self.host, port=self.port, user=self.user, password=self.password, db=self.db, charset=self.charset)
self.cursor = self.db.cursor()
def run(self, sql):
ret = None
try:
ret = self.cursor.execute(sql)
self.db.commit()
except Exception as e:
self.db.rollback()
finally:
self.close()
return ret
def close(self):
self.cursor.close()
self.db.close()
def insert(self, sql):
return self.run(sql)
def update(self, sql):
return self.run(sql)
def delete(self, sql):
return self.run(sql)
def read_one(self, sql):
ret = None
try:
self.cursor.execute(sql)
# 获取得到数据
ret = self.cursor.fetchone()
except Exception as e:
print('查询失败')
finally:
self.close()
return ret
def read_many(self, sql):
ret = None
try:
self.cursor.execute(sql)
# 获取得到数据
ret = self.cursor.fetchall()
except Exception as e:
print('查询失败')
finally:
self.close()
return ret
5、redis安装和学习
什么是redis？是一个基于内存的数据库，计算机里面，有内存，有硬盘
文件都在硬盘中存放，代码在运行的时候，有一个变量a
内存：读写快，但是断电消失，不大
硬盘：读写慢，但是可以持久化保存，大，随便存
什么是NoSQL？ not only sql 非关系型数据库
键值对，根据键立马就可以得到值
redis、MongoDB
redis官网：redis.io redis.cn
5种数据类型：字符串（string）、列表（list）、集合（set）、哈希（hash）、有序集合（zset）
redis官网只有linux版本的，不支持windows
