本文共 1989 字,大约阅读时间需要 6 分钟。
环境:
python:3.6+
python框架:flask
orm框架:SQLAlchemy
功能描述:
1.实现对象关系映射,每次初始化时,动态更新表结构
2.实现中英文表数据插入
3.实现查询数据并返回json格式
ORM概述:
1.ORM,对象关系映射,即Object Relational Mapping的简称
2.ORM框架将编程语言中的对象模型与数据库的关系模型建立映射关系,目的是简化sql语言操作数据库的繁琐过程(原生sql的编写及拼接等),转而直接使用对象模型来操作数据库做替代
3.ORM思想的核心是隐藏了数据访问细节,提供了通用的数据库交互,从而实现快速开发
代码实例:
from flask import Flaskfrom sqlalchemy import Column, String, create_engine, INTEGERfrom sqlalchemy.orm import sessionmakerfrom sqlalchemy.ext.declarative import declarative_baseimport jsonapp = Flask(__name__)Base = declarative_base()class User(Base): # 定义User对象: __tablename__ = 'user' # 表的名字 # 表的结构: id = Column(INTEGER, primary_key=True, autoincrement=True) # int类型, 主键,自增 name = Column(String(20)) def obj_to_dict(self): # 返回json格式定义 return { "id": self.id, "name": self.name }#编码格式使用UTF-8,不然会中文乱码,查看数据库编码格式也要是UTF-8engine = create_engine('mysql+pymysql://root:root@localhost:3306/test', encoding='UTF-8', echo=True) # 数据库连接引擎Base.metadata.create_all(engine) # 创建表结构,不会重复创建已经存在的表结构class db_Session: def __init__(self): self.DBSession = sessionmaker(bind=engine) # 创建DBSession类型: self.session = self.DBSession() # 创建session对象'''#将查询结果对象列表转换为指定格式的字典'''def dict_helper(objlist): result2 = [item.obj_to_dict() for item in objlist] # 获取类自定义字典转换函数,转换为字典列表 return result2@app.route('/')def hello_world(): return 'Hello World!'@app.route('/getUsers')def get_users(): db = db_Session() #获取数据执行会话 result = db.session.query(User).filter(User.id > 1) # 返回一个对象列表 db.session.commit() db.session.close() # 关闭session: return json.dumps(dict_helper(result), ensure_ascii=False) # 返回json格式数据@app.route('/addUser')def add_user(): db = db_Session() new_user = User(name='小明') db.session.add(new_user) # 添加到session, 插入数据 db.session.commit() db.session.close() # 关闭session: return 'success'if __name__ == '__main__': app.run()
运行结果:
相关问题注意:
1.数据库编码格式,如果是其他格式,可能插入中文错误
运行时表结构如下:
转载地址:http://izagi.baihongyu.com/