tornado的ORM | decimal

tornado的ORM

安装sqlalchemy和pymysql
- pip install sqlalchemy
- pip install pymysql

连接数据库

 from sqlalchemy import create_engine

 config = {

     'HOST': '',

     'USERNAME': '',

     'PASSWORD': '',

     'PORT': '',

     'DATABASE': '',

     'PARAMS': ''

 }

 DB_URL = 'mysql+pymysql://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DATABASE}?{PARAMS}'

 engine = create_engine(DB_URL.format(**config))

 if __name__ == '__main__':

     conc = engine.connect()

     result = conc.execute('select 1')

     print(result.fetchone())

如果连接成功，则控制台会出现（1，）的结果

数据库建模
- 建立base类
```
 from sqlalchemy import create_engine

 from sqlalchemy.ext.declarative import declarative_base

 config = {

     'HOST': '',

     'USERNAME': '',

     'PASSWORD': '',

     'PORT': '',

     'DATABASE': '',

     'PARAMS': ''

 }

 DB_URL = 'mysql+pymysql://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DATABASE}?{PARAMS}'

 engine = create_engine(DB_URL.format(**config))

 Base = declarative_base(engine)
```
- 使用base类并建立表格
```
 from settings import Base

 from sqlalchemy import Column, Integer, String, DateTime, Boolean

 from datetime import datetime

 class User(Base):

     __tablename__ = 'user'  # 指定表名

     id = Column(Integer, autoincrement=True, primary_key=True)

     username = Column(String(20))

     password = Column(String(20))

     create_time = Column(DateTime, default=datetime.now())

     is_login = Column(Boolean, default=False, nullable=False)

 if __name__ == '__main__':

     Base.metadata.create_all()  # 创建表格
```
  创建的表名必须为该类的__tablename__属性，Colum新建一个字段，然后给Colum传参来进行约束
- Column的常用参数：
  - default: 默认值，可以传一个函数体，default的值等于这个函数体执行后返回的值
  - nullable：是否可为空
  - primary_key：是否为主键
  - unique: 是否唯一
  - autoincrement：是否自增长
  - onupdate: 更新的时候执行的函数，和default一样，可以传一个函数体
  - name: 该属性在数据库中的字段的映射，默认是属性名
- 常用的数据类型
  - Integer: 整形
  - Float: 浮点类型
  - Boolean：布尔
  - DECIMAL: 定点类型： DECIMAL第一个参数为整数位的个数，第二位参数为小数位的个数
  - Enum：枚举类型： Enum可以借助python3自带的enum包来实现更加简便
  - Date: 传递datetime.date()
  - DateTime: 传递datetime.datetime()
  - Time：传递datetime.time() 进去
  - String: 字符串型, 使用时需要制定长度
  - Text: 文本类型
  - LONGTEXT: 长文本类型

简单的增删改查

增

 from sqlalchemy import create_engine

 from settings import DB_CONFIG

 from sqlalchemy.ext.declarative import declarative_base

 from sqlalchemy.orm import sessionmaker

 DB_URL = 'mysql+pymysql://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DATABASE}?{PARAMS}'

 engine = create_engine(DB_URL.format(**DB_CONFIG))

 Base = declarative_base(engine)

 Session = sessionmaker(engine)

 session = Session()

与上面不同的是,新建了一个Session对象，然后将这个对象实例化，接下来的数据库操作都用到这个实例对象来操作

 from config import Base

 from sqlalchemy import Column, Integer, String, DateTime, Boolean

 from datetime import datetime

 class User(Base):

     __tablename__ = 'user'

     id = Column(Integer, primary_key=True, autoincrement=True)

     username = Column(String(20))

     password = Column(String(20))

     create_time = Column(DateTime, default=datetime.now())

     is_login = Column(Boolean, default=False, nullable=False)

表结构

 from wechat import User

 from config import session

 def add():

     user = User(username='ivy', password='')

     session.add(user)

     session.commit()

 if __name__ == '__main__':

     add()

添加一条

 from wechat import User

 from config import session

 def add():

     session.add_all([

         User(username='ivy', password=''),

         User(username='ivy1', password=''),

         User(username='ivy2', password=''),

     ])

     session.commit()

 if __name__ == '__main__':

     add()

添加多条

查

 from wechat import User

 from config import session

 def search():

     session.query(User).all()  # 查找所有

     result = session.query(User).first().username  # 查找第一个

     result = session.query(User).filter(User.username=='ivy').first().password

     print(result)

 if __name__ == '__main__':

     search()

改

 from wechat import User

 from config import session

 def update():

     session.query(User).filter(User.username == 'ivy').update(

         {

             User.username: 'bob',

             User.password: '',

         }

     )

     session.commit()

 if __name__ == '__main__':

     update()

更改的数据以字典的键值对的形式传入

删

 from wechat import User

 from config import session

 def delete():

     result = session.query(User).filter(User.username == 'bob').first()

     session.delete(result)

     session.commit()

 if __name__ == '__main__':

     delete()

先查询结果，再讲查询的结果删除，如果查询的结果为空，则删除会报错。

　每个session执行完毕之后都要close()