from pymysql import *
class JD(object):
def __init__(self):
# 创建Connection连接
self.conn = connect(host='localhost', port=3306, user='root', password='wjh830724', database='jd', charset='utf8')
# 获得Cursor对象
self.cursor =self.conn.cursor()
def excute_sql(self,sql):
self.cursor.execute(sql)
for tempin self.cursor.fetchall():
print(temp)
def show_all_items(self):
"""查询所有商品"""
sql ='select * from goods;'
self.excute_sql(sql)
def __del__(self):
# 关闭Cursor对象
self.cursor.close()
self.conn.close()
def show_cates(self):
"""所有的商品分类"""
sql ='select name from goods_cates;'
self.excute_sql(sql)
def show_brands(self):
"""所有商品品牌分类"""
sql ='select name from goods_brands;'
self.excute_sql(sql)
def add_cates(self):
"""添加商品分类"""
item_name = input('请输入新类商品名称:')
sql ="""insert into goods_cates (name) values ("%s");""" %item_name
self.cursor.execute(sql)
self.conn.commit()
def delete_cates(self):
"""删除商品分类"""
item_name = input('请输入新类商品名称:')
sql ="""delete from goods_cates where name = '%s';""" %item_name
self.cursor.execute(sql)
self.conn.commit()
def update_cates(self):
"""修改商品分类"""
item_name_old = input('请输入更改前名字:')
item_name_new = input('请输入更改后名字:')
sql ="""update goods_cates set name = '%s' where name = '%s';""" %(item_name_new,item_name_old)
self.cursor.execute(sql)
self.conn.commit()
def get_into_by_name(self):
fint_name = input('请输入商品名字:')
# sql = """select * from goods where name="%s";""" %fint_name
# print("-->%s<--" % sql)
# self.cursor.execute(sql)
sql ="select * from goods where name=%s"
self.cursor.execute(sql,[fint_name])
print(self.cursor.fetchall())
def add_brands(self):
"""添加商品品牌分类"""
item_name = input('请输入新类商品名称:')
sql ="""insert into goods_brands (name) values ("%s");""" %item_name
self.cursor.execute(sql)
self.conn.commit()
def delete_brands(self):
"""删除商品品牌分类"""
item_name = input('请输入新类商品名称:')
sql ="""delete from goods_brands where name = '%s';""" %item_name
self.cursor.execute(sql)
self.conn.commit()
def update_brands(self):
"""修改商品品牌分类"""
item_name_old = input('请输入更改前名字:')
item_name_new = input('请输入更改后名字:')
sql ="""update goods_brands set name = '%s' where name = '%s';""" %(item_name_new,item_name_old)
self.cursor.execute(sql)
self.conn.commit()
@staticmethod
def print_menu():
print('------京东------')
print('1.所有商品')
print('2.所有的商品分类')
print('3.所有商品品牌分类')
print('4.添加商品分类')
print('5.删除商品分类')
print('6.修改商品分类')
print('7.根据名字查询商品')
print('8.添加商品品牌')
print('9.删除商品品牌')
print('10.修改商品品牌')
return input('请输入功能应用序号:')
def run(self):
while True:
num =self.print_menu()
if num =='1':
#所有商品
self.show_all_items()
elif num =='2':
#所有的商品分类
self.show_cates()
elif num =='3':
#所有商品品牌分类
self.show_brands()
elif num =='4':
#添加商品分类
self.add_cates()
elif num =='5':
#删除商品分类
self.delete_cates()
elif num =='6':
#修改商品分类
self.update_cates()
elif num =='7':
#根据名字查询商品
self.get_into_by_name()
elif num =='8':
#添加商品品牌分类
self.add_brands()
elif num =='9':
#删除商品品牌分类
self.delete_brands()
elif num =='10':
#修改商品品牌分类
self.update_brands()
else:
print('输入错误')
def main():
#创建对象
jd = JD()
#用一个run方法跑来
jd.run()
if __name__ =='__main__':
main()
索引
索引是什么
索引是一种特殊的文件(InnoDB数据表上的索引是表空间的一个组成部分)，它们包含着对数据表里所有记录的引用指针。
更通俗的说，数据库索引好比是字典前面的目录，能加快数据库的查询速度
索引目的
提高查询效率
-- 开启运行时间监测：
set profiling=1;
-- 查看执行的时间：
show profiles;
-- 查看索引
show indexfrom 表名;
-- 删除索引：
drop index索引名称 on 表名;
所以比较占磁盘，比建议建索引
如果数据很大，并且经常查，建立索引
账户管理
在生产环境下操作数据库时，绝对不可以使用root账户连接，而是创建特定的账户，授予这个账户特定的操作权限，然后连接进行操作，主要的操作就是数据的crud
MySQL账户体系：根据账户所具有的权限的不同，MySQL的账户可以分为以下几种
服务实例级账号：启动了一个mysqld，即为一个数据库实例；如果某用户如root,拥有服务实例级分配的权限，那么该账号就可以删除所有的数据库、连同这些库中的表
数据库级别账号：对特定数据库执行增删改查的所有操作
数据表级别账号：对特定表执行增删改查等所有操作
字段级别的权限：对某些表的特定字段进行操作
存储程序级别的账号：对存储程序进行增删改查的操作
账户的操作主要包括创建账户、删除账户、修改密码、授权权限等
授予权限
需要使用实例级账户登录后操作，以root为例
主要操作包括：
查看所有用户
修改密码
删除用户
查看所有用户
所有用户及权限信息存储在mysql数据库的user表中
查看user表的结构
desc user;
主要字段说明：
Host表示允许访问的主机
User表示用户名
authentication_string表示密码，为加密后的值
查看所有用户
selecthost,user,authentication_stringfromuser;
建账户、授权
需要使用实例级账户登录后操作，以root为例
常用权限主要包括：create、alter、drop、insert、update、delete、select
如果分配所有权限，可以使用all privileges
grant权限列表on数据库to'用户名'@'访问主机'identifiedby'密码';
查看用户有哪些权限
show grants for laoweng@localhost;
账户操作
修改权限
grant权限名称on数据库to账户@主机with grant option;
-- 刷新权限flush privileges;
修改密码
使用root登录，修改mysql数据库的user表
使用password()函数进行密码加密
update user set authentication_string=password('新密码') where user='用户名';
例：update user set authentication_string=password('123') where user='laoweng';
注意修改完成后需要刷新权限
刷新权限：flush privileges
远程登录（危险慎用）
如果向在一个Ubuntu中使用msyql命令远程连接另外一台mysql服务器的话，通过以下方式即可完成，但是此方法仅仅了解就好了，不要在实际生产环境中使用
修改 /etc/mysql/mysql.conf.d/mysqld.cnf 文件
sudo vim /etc/mysql/mysql.conf.d/mysqld.cnf
然后重启msyql
sudo service mysql restart
删除账户
1.使用root登录 推荐使用
drop user'用户名'@'主机';
2.使用root登录，删除mysql数据库的user表中数据
delete from user where user='用户名';
-- 操作结束之后需要刷新权限flush privileges
MySQL主从同步配置
1. 主从同步的定义
主从同步使得数据可以从一个数据库服务器复制到其他服务器上，在复制数据时，一个服务器充当主服务器（master），其余的服务器充当从服务器（slave）。因为复制是异步进行的，所以从服务器不需要一直连接着主服务器，从服务器甚至可以通过拨号断断续续地连接主服务器。通过配置文件，可以指定复制所有的数据库，某个数据库，甚至是某个数据库上的某个表。
使用主从同步的好处：
通过增加从服务器来提高数据库的性能，在主服务器上执行写入和更新，在从服务器上向外提供读功能，可以动态地调整从服务器的数量，从而调整整个数据库的性能。
提高数据安全，因为数据已复制到从服务器，从服务器可以终止复制进程，所以，可以在从服务器上备份而不破坏主服务器相应数据
在主服务器上生成实时数据，而在从服务器上分析这些数据，从而提高主服务器的性能
2. 主从同步的机制
Mysql服务器之间的主从同步是基于二进制日志机制，主服务器使用二进制日志来记录数据库的变动情况，从服务器通过读取和执行该日志文件来保持和主服务器的数据一致。
在使用二进制日志时，主服务器的所有操作都会被记录下来，然后从服务器会接收到该日志的一个副本。从服务器可以指定执行该日志中的哪一类事件（譬如只插入数据或者只更新数据），默认会执行日志中的所有语句。
每一个从服务器会记录关于二进制日志的信息：文件名和已经处理过的语句，这样意味着不同的从服务器可以分别执行同一个二进制日志的不同部分，并且从服务器可以随时连接或者中断和服务器的连接。
主服务器和每一个从服务器都必须配置一个唯一的ID号（在my.cnf文件的[mysqld]模块下有一个server-id配置项），另外，每一个从服务器还需要通过CHANGE MASTER TO语句来配置它要连接的主服务器的ip地址，日志文件名称和该日志里面的位置（这些信息存储在主服务器的数据库里）
3. 配置主从同步的基本步骤
有很多种配置主从同步的方法，可以总结为如下的步骤：
在主服务器上，必须开启二进制日志机制和配置一个独立的ID
在每一个从服务器上，配置一个唯一的ID，创建一个用来专门复制主服务器数据的账号
在开始复制进程前，在主服务器上记录二进制文件的位置信息
如果在开始复制之前，数据库中已经有数据，就必须先创建一个数据快照（可以使用mysqldump导出数据库，或者直接复制数据文件）
配置从服务器要连接的主服务器的IP地址和登陆授权，二进制日志文件名和位置
