python_way day12 sqlalchemy，原生mysql命令 python_way day12  sqlalchemy，mysql原生命令

MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
  
pymysql
    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
  
MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
  
cx_Oracle
    oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
  
更多详见：http://docs.sqlalchemy.org/en/latest/dialects/index.html

中间状态

from sqlalchemy import  create_engine , Table, Column, Integer, String, MetaData,ForeignKey
#MetaData 里面封装了很多类被创建后的属性，ForeignKey外键,Column 队列 ， integer 证书 ， string 字符串
metadata = MetaData
#相当于继承父类

user = Table('user', metadata,
             Column('id', Integer, primary_key=True),
             Column('name', String))

#Table 创建一个user表的对象

color = Table('color', metadata,
                Column('id',Integer,primary_key=True),
                Column('name',String(20)),)

engine = create_engine('mysql+pymysql://r:<password>@<host>/<dbname>[?<options>]')
#连接数据库
metadata.create_all(engine) 
#创建所有跟metadata关联的表格

conn.engine.connect() 
#获取mysql游标

sql = user.insert().values(name="alex")
conn.execute(sql)  #相当于执行上面的命令
sql = user.delete().where(user.c.id >1)

修改

查找

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import create_engine

engine = create_engine('mysql+pymysql://root:hanxu@192.168.109.129:3306/asset',max_overflow=5,echo=True)  #echo=True 看过程

Base = declarative_base()  #封装了metadata，生成了一个SqlORM的基类

# 创建单表
class Host(Base):  #所有的子类都继承这个基类
    #创建表结构
    __tablename__ = 'hosts'
    id = Column(Integer, primary_key=True,autoincrement=True)  #id整数，主键, 自增，
    hostname = Column(String(64),unique=True,nullable=False)       #name string,唯一，非空
    ip_addr = Column(String(128),unique=True,nullable=False)
    port = Column(Integer, default=22)

Base.metadata.create_all(engine) #执行上面的sql

if __name__ == '__main__':
    SessionCls = sessionmaker(bind=engine)   #创建与数据库的回话session class #注意了这里创建的是一个类，而不是一个实例
    session = SessionCls()     #这次是连接的实例
    h1 = Host(hostname='localhost',ip_addr='127.0.0.1')   #给Host增加一条数据
    h2 = Host(hostname="ubantu",ip_addr='192.168.0.2',port=5500)
    # session.add(h1)#注册创建1个
    session.add_all([h1,h2]) #注册全部创建
    session.commit() #提交

#以上步骤可以单独执行，也可以一起执行


#查询

class Host(Base):  #所有的子类都继承这个基类
    #创建表结构
    __tablename__ = 'hosts'
    id = Column(Integer, primary_key=True,autoincrement=True)  #id整数，主键, 自增，
    hostname = Column(String(64),unique=True,nullable=False)       #name string,唯一，非空
    ip_addr = Column(String(128),unique=True,nullable=False)
    port = Column(Integer, default=22)

Base.metadata.create_all(engine) #执行上面的sql

if __name__ == '__main__':
    SessionCls = sessionmaker(bind=engine)   #创建与数据库的回话session class #注意了这里创建的是一个类，而不是一个实例
    session = SessionCls()     #这次是连接的实例
    obj = session.query(Host).filter(Host.hostname=='localhost').first() 
    obj = session.query(Host).filter(Host.hostname=='localhost').all()

    print(obj)  #obj是个对象，获取到他后就可以对他进行修改了

    session.commit()

#删除

class Host(Base):  #所有的子类都继承这个基类
    #创建表结构
    __tablename__ = 'hosts'
    id = Column(Integer, primary_key=True,autoincrement=True)  #id整数，主键, 自增，
    hostname = Column(String(64),unique=True,nullable=False)       #name string,唯一，非空
    ip_addr = Column(String(128),unique=True,nullable=False)
    port = Column(Integer, default=22)

Base.metadata.create_all(engine) #执行上面的sql

SessionCls = sessionmaker(bind=engine)   #创建与数据库的回话session class #注意了这里创建的是一个类，而不是一个实例
session = SessionCls()     #这次是连接的实例

h1 = Host(hostname='suse',ip_addr='172.168.0.19')   #给Host增加一条数据
session.add(h1)#注册创建1个
obj = session.query(Host).filter(Host.hostname=='centos').first()   #查询且过滤 hostname = lcoalhost
session.delete(obj)     　　　　　　　　　　　　　　　　　　　　　　　　　 #把centos查询到的这个对象删除
session.commit()　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　 #提交　　　　　

filter_by:后面的 = 只用写一个就可以了

obj = session.query(Host).filter_by(Host.hostname='centos').first()

#其他写法

obj = session.query(Host).filter(Host.hostname.like('%en%')).first() 

模糊查询
in_ 在
obj = session.query(Host).filter(Host.hostname.in_(['cen','suse'])).first() 
#查询到的结果如果在cen，suse里 则匹配

or_ 或
# obj = session.query(Host).filter(or_(Host.hostname.like('ng%'),Host.port > 50)).first(）
查询ng%后面任意的或者port>50的

and_ 与
obj = session.query(Host).filter(and_(Host.hostname.like('ng%'),Host.port > 50)).first()  #查询且过滤 hostname = lcoalhost
查询ng%后面任意的并且port又要大于50

match

obj = session.query(Host).filter(Host.hostname.match('nginx'))
print(obj)

---> SELECT hosts.id AS hosts_id, hosts.hostname AS hosts_hostname, hosts.ip_addr AS hosts_ip_addr, hosts.port AS hosts_port
FROM hosts
WHERE hosts.hostname MATCH :hostname_1 <---

将相同的查出来并且合并
select * from a INNER JOIN b on a.a = b.b
select a.* ,b.* from a,b where a.a = b.b

以左边为主表，把相对应的右边的表查询出来
select * from a LEFT OUTER JOIN b on a.a = b.b
select a.* ,b.* from a,b where a.a = b.b（+）

把所有的表查询出来
select * from a FULL OUTER JOIN b on a.a = b.b

# utf-8
CREATE DATABASE 数据库名称 DEFAULT CHARSET utf8 COLLATE utf8_general_ci;
 
# gbk
CREATE DATABASE 数据库名称 DEFAULT CHARACTER SET gbk COLLATE gbk_chinese_ci;

创建用户
    create user '用户名'@'IP地址' identified by '密码';
删除用户
    drop user '用户名'@'IP地址';
修改用户
    rename user '用户名'@'IP地址'; to '新用户名'@'IP地址';;
修改密码
    set password for '用户名'@'IP地址' = Password('新密码')
  
PS：用户权限相关数据保存在mysql数据库的user表中，所以也可以直接对其进行操作（不建议）

create table 表名(
    列名  类型  是否可以为空，
    列名  类型  是否可以为空
)ENGINE=InnoDB DEFAULT CHARSET=utf8

insert into 表 (列名,列名...) values (值,值,值...)

insert into t2 (name,age) VALUES ('tian',18)

insert into 表 (列名,列名...) values (值,值,值...),(值,值,值...)
insert into t2 (name,age) VALUES ('tian',18),('xu',21)

insert into 表 (列名,列名...) select (列名,列名...) from 表

delete from 表
delete from 表 where id＝1 and name＝'alex'

update 表 set name ＝ 'alex' where id>1

select * from 表
select * from 表 where id > 1
select nid,name,gender as gg from 表 where id > 1

a、条件
    select * from 表 where id > 1 and name != 'alex' and num = 12;
 
    select * from 表 where id between 5 and 16;
 
    select * from 表 where id in (11,22,33)
    select * from 表 where id not in (11,22,33)
    select * from 表 where id in (select nid from 表)
 
b、通配符
    select * from 表 where name like 'ale%'  - ale开头的所有（多个字符串）
    select * from 表 where name like 'ale_'  - ale开头的所有（一个字符）
 
c、限制
    select * from 表 limit 5;            - 前5行
    select * from 表 limit 4,5;          - 从第4行开始的5行
    select * from 表 limit 5 offset 4    - 从第4行开始的5行
 
d、排序
    select * from 表 order by 列 asc              - 根据 “列” 从小到大排列
    select * from 表 order by 列 desc             - 根据 “列” 从大到小排列
    select * from 表 order by 列1 desc,列2 asc    - 根据 “列1” 从大到小排列，如果相同则按列2从小到大排序
 
e、分组
    select num from 表 group by num
    select num,nid from 表 group by num,nid
    select num,nid from 表  where nid > 10 group by num,nid order nid desc
    select num,nid,count(*),sum(score),max(score),min(score) from 表 group by num,nid
 
    select num from 表 group by num having max(id) > 10
 
    特别的：group by 必须在where之后，order by之前

 
f、连表
    显示所有的表。
    select A.num, A.name, B.name
    from A,B
    Where A.nid = B.nid
　　 


    无对应关系则不显示
    select A.num, A.name, B.name
    from A inner join B
    on A.nid = B.nid

    select * from t10 inner join t11 on t10.type_id = t11.id
　　 将t10 和t11表链接显示， 链接条件： （inner join，无对应关系的不显示） t10 的type_id 和t11 的id相等 

    A表所有显示，如果B中无对应关系，则值为null
    select A.num, A.name, B.name
    from A left join B
    on A.nid = B.nid

    select * from t10 left join t11 on t10.type_id = t11.id
　　 以 left join 前面的t10表为主， 后边的表无关系的表不显示，如果前面的表有无对应关系的就显示null

　　　

 
    B表所有显示，如果B中无对应关系，则值为null
    select A.num, A.name, B.name
    from A right join B
    on A.nid = B.nid
    和 left join 相反
 

g、组合
    组合，自动处理重合
    select nickname
    from A
    union
    select name
    from B



 
    组合，不处理重合
    select nickname
    from A
    union all
    select name
    from B

select sum(价格),资产类型， from t1 group by 资产类型 
显示价格总和，资产类型，从t1中查找，按照资产类型进行分组（分组就是把group by后面资产类型为1的分一组，资产为2的分一组）