1、复习mysql经常使用操做python
一、建立库mysql
create database test;
二、建立表sql
create table student(id int not null);
三、受权一个用户数据库
grant all privileges on *.* to 'username'@'%' identified by 'passwd'; 其中%通配全部地址
四、查询session
select * from tabel_name where 条件1 and 条件2;
五、增长数据并发
insert into table_name (id, name, age, sex, grander) values (1, 'jsh', 25, 'M', 99), (2, 'Tom', 45, 'F', 88);
六、删除数据ide
delete from table_name where 条件判断; drop table table_name; 删除表
七、改数据(更新数据)fetch
update table_name set id=10 where 条件判断;
八、联合查询spa
select a.id, b.name from A a join B b on a.id=b.tid;
九、建立索引对象
create index idx_库名_表名_列名1_列名2 或 (列名1, 列名2)
十、查看SQL是否走索引
explain select * from student where name='JSH'
2、复习——MySQL 数据库链接
一、Python2 使用mysqldb python3 使用 pymysql
二、建立连接 和 游标
在mysql链接中,尽可能使用一个链接,确保mysql的并发数
conn = pymysql.connect(host='', port=, user='', passwd='', db='') # cus = conn.curse()
三、执行MySQL语句
sql = "select * from Student;" # cus.execute(sql) # cus.fetchone() 获取单个 返回值 tuple # cus.fetchall() 获取多个 返回值 list(单个元素是tuple) # cus.fetchmany(size=n) 获取多个
四、关闭游标 和 连接
注意结合try exception finally的使用
cus.close() conn.close()
3、复习——SQLAlchemy (对象关系映射)
一、建立引擎
engine = create_engine('mysql+pymysql://root:123456@192.168.6.137/sqlalchemy',echo=True)
二、建立session
DBsession = sessionmaker(bind=engine) session = DBsession()
三、建立表
a. 得到engine b. metadata = MetaData(engine) c. student = Table('表名', metadata, Colume('id', Integer, primary_key=True), Colume('name', String(50)) d. metadata.create_all()
四、增长数据
a. 先要有一个模型 Base = declarative_base(0 class Student(Base): __tablename__ = 'student' id = Column(Integer, primary_key=True) name = Column(String(100), primary_key=True) b. 导入模型类,实例化该类, sutdent1 = Student(1, 'ling') c. session.add(单实例) session.add_all([实例1, 实例2])
五、查询
# filter和filter_by的区别 # filter:可使用> < 等,可是列必须是: 表.列, filter的等于号是== session.query(Student).filter(Student.id>100) # filter 不支持组合查询 session.query(Student).filter(Studnet.id>100).filter(name='ling') # filter_by: 能够直接写列,不支持< > filter_by 等因而== session.query(Student).filter_by(id==10) # filter_by 能够支持组合查询 session.query(Student).filter_by(name='ling' and id='342') # 模糊查询含有ling的关键字 select * from student where name like '%JSH%'; # 模糊查询 # session.query(Student).filter(Student.name.like('%JSH%')) # 获取数据的时候有两个方法: # one() 获取到的数据为 tuple # all() 获取到的数据为 list(单个元素是tuple) # 若是在查询中不写one(), 或者all() 获得的就是sql语句
六、更新
1. 先查出来 2. 跟新一下类所对应的属性值就ok session.commit() student1 = session.query(Student).filter(Student.id=1001) student1.name = "test" session.commit()
七、删除
# 1. 先查出来 # 2. 直接调用delete()方法就能够 # 3. 提交一下
八、统计count() 分组
# 只须要在查出来之后, 把one或者all替换成count()
九、分组 group_by
查出来之后,把one或者all替换成group_by(属性)