Flask-Sqlalchemy的基本使用详解_python_

pip install flask-sqlalchemy pip install pymysql 

from flask import Flask from flask_restful import Api, Resource from flask_sqlalchemy import SQLAlchemy import pymysql pymysql.install_as_MySQLdb() """ python2中数据库客户端： MySqldb python3中数据库客户端：pymysql 解决方案一：让python2和python3的包进行转换。 import pymysql pymysql.install_as_MySQLdb() 方案二：表示只使用python3的包，不使用python2的包 app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39" """ app = Flask(__name__) db = SQLAlchemy(app) # app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://账号:密码@数据库ip地址:端口号/数据库名" app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://root:mysql@192.168.44.128:3306/test39" # app.config['SQLALCHEMY_BINDS'] = {} # 关闭数据库修改跟踪操作[提高性能]： app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 开启输出底层执行的sql语句 app.config['SQLALCHEMY_ECHO'] = True # 开启数据库的自动提交功能[一般不使用] app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True @app.route('/') def hello_word(): return "hello, word" if __name__ == '__main__': print(app.url_map) app.run(host='0.0.0.0', port= 8000, debug=True) 

# 开发环境 class DevelopmentConfig(BaseConfig): """开发环境配置类""" DEBUG = True # SQL数据库连接信息 SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:mysql@192.168.243.157:3306/test39" # 关闭数据库修改跟踪操作 【提高性能】 SQLALCHEMY_TRACK_MODIFICATIONS = False # 开启输出底层执行sql语句 SQLALCHEMY_ECHO = True 

from flask import Flask, make_response, Response, request, current_app from settings import config_dict from flask_sqlalchemy import SQLAlchemy # 延后加载 # 创建了数据库，此时数据库对象还没有跟app关联 db = SQLAlchemy() # 定义一个工厂方法： def create_app(config_name): app = Flask(__name__) config_class = config_dict[config_name] app.config.from_object(config_class) app.config.from_envvar('CONFIG', silent=True) # 懒加载 db.init_app(app) return app app = create_app("dev") @app.route('/login') def login(): return "" if __name__ == '__main__': app.run(host='0.0.0.0', port=8000, debug=True) 

from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 相关配置 app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://root:mysql@192.168.44.128:3306/test39" app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False app.config['SQLALCHEMY_ECHO'] = True # 创建组件对象 db = SQLAlchemy(app) # 构建模型类 类->表 类属性->字段 实例对象->记录 class User(db.Model): __tablename__ = 't_user' # 设置表名, 表名默认为类名小写 id = db.Column(db.Integer, primary_key=True) # 设置主键, 默认自增 name = db.Column('username', db.String(20), unique=True) # 设置字段名 和 唯一约束 age = db.Column(db.Integer, default=10, index=True) # 设置默认值约束 和 索引 if __name__ == '__main__': # 删除所有继承自db.Model的表 db.drop_all() # 创建所有继承自db.Model的表 db.create_all() app.run(host="0.0.0.0", port=8000, debug=True) 

from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 相关配置 app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://root:mysql@192.168.44.128:3306/test39" app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False app.config['SQLALCHEMY_ECHO'] = True # 创建组件对象 db = SQLAlchemy(app) # 构建模型类 class User(db.Model): __tablename__ = 't_user' id = db.Column(db.Integer, primary_key=True) name = db.Column('username', db.String(20), unique=True) age = db.Column(db.Integer, index=True) @app.route('/') def index(): """增加数据""" # 1.创建模型对象 user1 = User(name='zs', age=20) # user1.name = 'zs' # user1.age = 20 # 2.将模型对象添加到会话中 db.session.add(user1) # 添加多条记录 # db.session.add_all([user1, user2, user3]) # 3.提交会话 (会提交事务) # sqlalchemy会自动创建隐式事务 # 事务失败会自动回滚 db.session.commit() return "index" if __name__ == '__main__': db.drop_all() db.create_all() app.run(host="0.0.0.0", port=8000, debug=True) 

from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 配置数据库连接 app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://root:mysql@192.168.44.128:3306/test39" # 配置取消数据库跟踪 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 配置数据库输出SQL语句 app.config['SQLALCHEMY_ECHO'] = True # 创建数据库对象 db = SQLAlchemy(app) class User(db.Model): # 指定表名：默认使用类名小写 __tablename__ = "users" id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(64)) email = db.Column(db.String(64)) age = db.Column(db.Integer) def __repr__(self): return "(%s, %s, %s, %s)"%(self.id, self.name, self.email, self.age) if __name__ == '__main__': # 删除所有表 # db.drop_all() # # 创建所有表 # db.create_all() # # 添加测试数据 # user1 = User(name='wang', email='wang@163.com', age=20) # user2 = User(name='zhang', email='zhang@189.com', age=33) # user3 = User(name='chen', email='chen@126.com', age=23) # user4 = User(name='zhou', email='zhou@163.com', age=29) # user5 = User(name='tang', email='tang@itheima.com', age=25) # user6 = User(name='wu', email='wu@gmail.com', age=25) # user7 = User(name='qian', email='qian@gmail.com', age=23) # user8 = User(name='liu', email='liu@itheima.com', age=30) # user9 = User(name='li', email='li@163.com', age=28) # user10 = User(name='sun', email='sun@163.com', age=26) # # # 一次添加多条数据 # db.session.add_all([user1, user2, user3, user4, user5, user6, user7, user8, user9, user10]) # db.session.commit() app.run(host="0.0.0.0",port=8000, debug=True) 

 # 1:查询所有的用户数据： users = User.query.all() print(type(users)) print(users) # 2:查询一共有多少个用户： count = User.query.count() print("一共有{}个人".format(count)) # 3:查询第一个用户信息： user1 = User.query.first() print("第一个用户的信息是：{}".format(user1)) # 4:查询id为4的三种方式： #<方案一>：根据id查询，返回模型类对象 user4 = User.query.get(4) print("第四个用户的信息是{}".format(user4)) # <方案二>：等值过滤器 关键字实参设置字段值 返回BaseQuery对象 user4 = User.query.filter_by(id=4).first() print("第四个用户的信息是{}".format(user4)) # <方案三>：使用复杂过滤器，返回BaseQuery对象 user4 = User.query.filter(User.id == 4).first() print("第四个用户的信息是{}".format(user4)) # 5:查询用户名字，开始，结尾，包含n的用户 user = User.query.filter(User.name.startswith('n')).all() print("名字以n开头的用户{}".format(user)) user = User.query.filter(User.name.endswith("n")).all() print("名字以n结尾的用户{}".format(user)) user = User.query.filter(User.name.contains("n")).all() print("名字中包含n的用户：{}".format(user)) 

 # 6:查询名字和邮箱都以li开头的所有用户[2种方式] users = User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all() print("查询名字和邮箱都以li开头的所有用户：{}".format(users)) users = User.query.filter(and_(User.name.startswith('li'), User.email.startswith('li'))).all() print("查询名字和邮箱都以li开头的所有用户：{}".format(users)) # 7：查询age是25或者email以com结尾的所有用户 users = User.query.filter(or_(User.age==25, User.email.endswith('com'))).all() print("age是25或者email以com结尾的所有用户 : {}".format(users)) # 8: 查询名字不等于wang的所有用户 users = User.query.filter(User.name != "wang").all() print("名字不等于wang的所有用户： {}".format(users)) users= User.query.filter(not_(User.name=="wang")).all() print("名字不等于wang的所有用户： {}".format(users)) # 9: 查询id是[1, 3, 5, 7, 9]的用户 users = User.query.filter(User.id.in_([1, 3, 5, 7, 9])).all() print("id是[1, 3, 5, 7, 9]的用户: {}".format(users)) # 10：所有用户先按年龄从小到大, 再按id从大到小排序, 取前5个 users = User.query.order_by(User.age, User.id.desc()).limit(5).all() print("所有用户先按年龄从小到大, 再按id从大到小排序, 取前5个: {}".format(users)) 

# 11:查询年龄从小到大第2-5位的数据 users = User.query.order_by(User.age).offset(1).limit(4).all() print("查询年龄从小到大第2-5位的数据: {}".format(users)) # 12: 分页查询, 每页3个, 查询第2页的数据 paginate(页码, 每页条数) pn = User.query.paginate(2, 3) print("总页数是：", pn.pages) print("当前页：", pn.page) print("当前页的数据：", pn.items) print("当前页的总条数", pn.tota
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：Python+pyecharts绘制双动态曲线教程详解_python_
                                                                
下一篇：flask-SQLALchemy连接数据库的实现示例_python_