Python基础——mysql数据库、SQLAlchemy
一、MySQL常用操作 1、创建库 create database test; 2、创建表 create table student(id int not null); 3、授权一个用户 grant all privileges on *.* to 'username'@'%' identified by 'passwd'; 其中%通配所有地址 4、查询 select * from tabel_name where 条件1 and 条件2； 5、增加数据 insert into table_name (id, name, age, sex, grander) values (1, 'jsh', 25, 'M', 99), (2, 'Tom', 45, 'F', 88); 6、删除数据 delete from table_name where 条件判断； drop table table_name； 删除表 7、改数据（更新数据） update table_name set id=10 where 条件判断； 8、联合查询 select a.id, b.name from A a join B b on a.id=b.tid； 9、创建索引 create index idx_库名_表名_列名1_列名2 或 (列名1， 列名2) 10、查看SQL是否走索引 explain select * from student where name='JSH' 二、MySQL 数据库连接 1、Python2 使用mysqldb python3 使用 pymysql 2、创建链接 和游标 在mysql连接中，尽量使用一个连接，确保mysql的并发数 conn = pymysql.connect(host='', port=, user='', passwd='', db='') # cus = conn.curse() 3、执行MySQL语句 sql = "select * from Student;" # cus.execute(sql) # cus.fetchone() 获取单个 返回值 tuple # cus.fetchall() 获取多个 返回值 list（单个元素是tuple） # cus.fetchmany(size=n) 获取多个 4、关闭游标 和 链接 注意结合try exception finally的使用 cus.close() conn.close() 三、SQLAlchemy（对象关系映射） 1、创建引擎 engine = create_engine('mysql+pymysql://root:123456@192.168.6.137/sqlalchemy',echo=True) 2、创建session DBsession = sessionmaker(bind=engine) session = DBsession() 3、创建表 a. 获得engine b. metadata = MetaData(engine) c. student = Table('表名', metadata, Colume('id', Integer, primary_key=True), Colume('name', String(50)) d. metadata.create_all() 4、增加数据 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]) 5、查询 # 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语句 6、更新 1. 先查出来 2. 跟新一下类所对应的属性值就ok session.commit() student1 = session.query(Student).filter(Student.id=1001) student1.name = "test" session.commit() 7、删除 # 1. 先查出来 # 2. 直接调用delete()方法就可以 # 3. 提交一下 8、统计count() 分组 # 只需要在查出来以后， 把one或者all替换成count() 9、分组group_by 查出来以后，把one或者all替换成group_by(属性)
