tornado的ORM

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='123456')
          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='123456'),
              User(username='ivy1', password='123456'),
              User(username='ivy2', password='123456'),
          ])
          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: '123654',
              }
          )
          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()