Flask-SQLAlchemy框架使用

以MySQL+SQLAlchemy的组合来对数据库进行管理，而Flask-SQLAlchemy是一种开发框架，对SQLAlchemy进行了一个简单的封装。下面使用Flask-SQLAlchemy的方法对数据库进行管理。

  

   

    

     

    
    

     

      #config.py
     
    
   

    

     

    
    

     

      #数据库配置信息
     
    
   

    

     

    
    

     

      HOSTNAME = '127.0.0.1'    #
     
    
   

    

     

    
    

     

      PORT     = '3306'
     
    
   

    

     

    
    

     

      DATABASE = 'mydb'
     
    
   

    

     

    
    

     

      USERNAME = 'root'
     
    
   

    

     

    
    

     

      PASSWORD = 'wangjian'
     
    
   

    

     

    
    

     

      DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #URI格式：dialect+driver://username:password@host:port/database
     
    
   

    

     

    
    

     

      #URI格式：dialect+driver://username:password@host:port/database
     
    
   

    

     

    
    

     

      # dialect是数据库的实现，比如MySQL、PostgreSQL、SQLite，并且转换成小写。
     
    
   

    

     

    
    

     

      # driver是Python对应的驱动，如果不指定，会选择默认的驱动，比如MySQL的默认驱动是MySQLdb。
     
    
   

    

     

    
    

     

      # username是连接数据库的用户名，
     
    
   

    

     

    
    

     

      # password是连接数据库的密码，
     
    
   

    

     

    
    

     

      # host是连接数据库的域名，
     
    
   

    

     

    
    

     

      # port是数据库监听的端口号，
     
    
   

    

     

    
    

     

      # database是连接哪个数据库的名字。
     
    
  
 

  

   

    

     

    
    

     

      #app.py
     
    
   

    

     

    
    

     

      from flask import Flask
     
    
   

    

     

    
    

     

      from flask_sqlalchemy import SQLAlchemy
     
    
   

    

     

    
    

     

      from config import DB_URI
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #需要安装依赖包 pymysql用来操作mysql、SQLAlchemy是数据库的ORM框架、Flask-SQLAlchemy是对SQLAlchemy的进一步抽象
     
    
   

    

     

    
    

     

      #pip install pymysql
     
    
   

    

     

    
    

     

      #pip install SQLAlchemy
     
    
   

    

     

    
    

     

      #pip install flask-sqlalchemy
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      app = Flask(__name__)
     
    
   

    

     

    
    

     

      app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI   #载入配置
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #创建一个数据库引擎
     
    
   

    

     

    
    

     

      db = SQLAlchemy(app)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #ORM类 与数据库表示映射关系
     
    
   

    

     

    
    

     

      class User(db.Model):
     
    
   

    

     

    
    

     
    id = db.Column(db.Integer, primary_key=True)
     
    
   

    

     

    
    

     

          username = db.Column(db.String(80), unique=True)
     
    
   

    

     

    
    

     

          email = db.Column(db.String(120), unique=True)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
    def __init__(self, username, email):
     
    
   

    

     

    
    

     

              self.username = username
     
    
   

    

     

    
    

     

              self.email = email
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
    def __repr__(self):
     
    
   

    

     

    
    

     
        return '<User %s>' % self.username
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      db.drop_all()    #删除所有表
     
    
   

    

     

    
    

     

      db.create_all()  #创建所有表
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #实例化一个ORM对象
     
    
   

    

     

    
    

     

      admin = User(username='admin',email='admin@example.com')
     
    
   

    

     

    
    

     

      guest = User('guest','guest@example.com')
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #通过session来完成ORM到数据库表格的映射
     
    
   

    

     

    
    

     

      # 添加记录
     
    
   

    

     

    
    

     

      db.session.add(admin)
     
    
   

    

     

    
    

     

      db.session.add(guest)
     
    
   

    

     

    
    

     

      db.session.commit()
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #查询数据库
     
    
   

    

     

    
    

     

      # users = User.query.all() #查询所有记录
     
    
   

    

     

    
    

     

      # print( type(users) )
     
    
   

    

     

    
    

     

      # for user in users:
     
    
   

    

     

    
    

     

      # print(user)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # user = User.query.get(2) #get方法利用主键进行查询
     
    
   

    

     

    
    

     

      # print(type(user.id))
     
    
   

    

     

    
    

     

      # print(user.email)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # users = User.query.filter_by(username="guest").first() # 使用条件过滤，最后得到一个记录的查询对象
     
    
   

    

     

    
    

     

      # print(users.email)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      users = User.query.all()  #查询所有记录
     
    
   

    

     

    
    

     

      print( type(users) )    #打印删除记录中的email值
     
    
   

    

     

    
    

     

      for user in users:
     
    
   

    

     

    
    

     
    print(user.email)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #删除操作
     
    
   

    

     

    
    

     

      db.session.delete(guest)
     
    
   

    

     

    
    

     

      db.session.commit()
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      users = User.query.all()  #查询所有记录
     
    
   

    

     

    
    

     

      print( type(users) )    #打印删除记录中的email值
     
    
   

    

     

    
    

     

      for user in users:
     
    
   

    

     

    
    

     
    print(user.email)
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      if __name__ == '__main__':
     
    
   

    

     

    
    

     

          app.run()
     
    
  
 

  

   

    

     

    
    

     

      <class 'list'>
     
    
   

    

     

    
    

     

      admin@example.com
     
    
   

    

     

    
    

     

      guest@example.com
     
    
   

    

     

    
    

     

      <class 'list'>
     
    
   

    

     

    
    

     

      admin@example.com
     
    
  
 

文章来源: blog.csdn.net，作者：hinzer，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/feit2417/article/details/86590669