当前位置： 首页 > news >正文

python-27-Python ORM系列之彻底搞明白ORM概念，对ORM进行封装结合FastAPI实现数据库的增删改查，联表查询等接口

news 2024/11/24 1:55:26

python-27-Python ORM系列之彻底搞明白ORM概念，对ORM进行封装结合FastAPI实现数据库的增删改查，联表查询等接口

一.简介

在Python基础系列ORM部分为大家介绍了如何搭建MySQL数据和MySQL一些访问配置，同时也介绍了pymysql库的封装来实现对数据库的增删改查功能，但是截止以上都没有实现ORM，好菜已经上来 这一篇文章来帮助大家彻底掌握ORM框架，并且对ORM进行封装，利用ORM和FASTAPI实现数据库的增删改查，开始我们今天的日拱一卒！

二.安装pymysql、sqlalchemy、fastapi、uvicorn

#使用豆瓣源安装 提升安装速度
pip install pymysql -i http://pypi.doubanio.com/simple --trusted-host pypi.doubanio.com
pip install sqlalchemy -i http://pypi.doubanio.com/simple --trusted-host pypi.doubanio.com
pip install fastapi -i http://pypi.doubanio.com/simple --trusted-host pypi.doubanio.com
pip install uvicorn -i http://pypi.doubanio.com/simple --trusted-host pypi.doubanio.com

pymysql：Python 实现的 MySQL 数据库连接库

本文示例是调用MySql数据库，如果需要切换其他数据库，可以下载对应插件和改变ORM对应的连接字符串即可

MySQL-Python
mysql+mysqldb://:@[:]/

pymysql
mysql+pymysql://:@/[?]

MySQL-Connector
mysql+mysqlconnector://:@[:]/

cx_Oracle
oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value…]

SQLAlchemy：Python ORM（对象关系映射）工具

fastapi：FastAPI 是一个现代的、快速的 web 框架，用于构建 API

Uvicorn：Uvicorn 是一个高性能的 ASGI 服务器，适用于运行 FastAPI 和其他支持 ASGI 的 Python web 框架。

三.ORM基础介绍

1.首先我们需要sqlalchemy 多个不同模块和库,常用的引入如下

from sqlalchemy import create_engine,Column, Integer, String, ForeignKey,DateTime,Boolean,Text
from sqlalchemy.ext.declarative import declarative_base #orm基类
from sqlalchemy.orm import sessionmaker,relationship,joinedload

create_engine：创建数据库连接引擎。

Column, Integer, String, ForeignKey, DateTime, Boolean, Text：用来定义数据库表的字段类型和约束。

declarative_base：创建 ORM 基类，供模型类继承。

sessionmaker：创建数据库会话，执行数据库操作。

relationship：定义表之间的关系。

joinedload：优化查询，避免 N+1 查询问题。

四.构建数据库连接字符串的配置文件

4.1创建配置文件db_config.ini

在当前项目中创建config文件夹，在文件夹下db_config.ini文件，作为我们的数据库配置文件，内容如下：

[localdb]
host     = localhost
user     = root
password = yourpsw
port     = 3306
database = myurlhub

4.2创建获取配置文件工具包

在当前项目中创建utils文件夹，新建__init__.py文件，里面不用写任何东西，在utils文件夹下新建config_helper.py文件，用来帮助我们获取配置文件信息，文件内容如下：

import configparserclass Config(object):def __init__(self, filename, encoding='UTF-8'):# 声明配置类对象self.config = configparser.ConfigParser()# 读取配置文件self.config.read(filename, encoding)def get_value(self, section, option):"""获取 value"""value = self.config.get(section, option)return valuedef get_items(self, section):value = dict(self.config.items(section))return value# 读取配置文件
# config.read(fileName, 'GBK')
# print(f"sections: {config.sections()}")
# print(f"options: {config.options('localdb')}")
# print(f"items: {config.items('localdb')}")

我们的整体结构文件：

在这里插入图片描述

五.读取配置文件数据 构建数据库连接引擎

在当前项目文件夹utils中 新建orm_helper.py文件作为 ORM 帮助类库，我们需要根据配置文件来构建连接字符串，从而创建我们的ORM据库连接引擎 engine = create_engine(mysql_conn_str)

orm_helper.py 目前的代码：

#orm_helper.py
from sqlalchemy import create_engine,Column, Integer, String, ForeignKey,DateTime,Boolean,Text
from sqlalchemy.ext.declarative import declarative_base #orm基类
from sqlalchemy.orm import sessionmaker,relationship,joinedload
from utils import config_helper
import os
from datetime import datetime
import uuid
'''
数据库连接拼接串语法：
'''
# 加载数据库配置
__config_file_path = os.path.join(os.getcwd(),'config\db_config.ini') 
__config = config_helper.Config(__config_file_path,'UTF-8')
__localdb = __config.get_items('localdb')
mysql_conn_str = f"mysql+pymysql://{__localdb['user']}:{__localdb['password']}@{__localdb['host']}:{__localdb['port']}/{__localdb['database']}"engine = create_engine(mysql_conn_str)

六.创建 ORM 基类，公共基类，用来定义数据库表的字段类型和约束的类

创建ORM模型的基类，公共字段基类，用于一键生成数据库对应的表字段

  1. 实现ORM基类：后续用来定义数据库表的字段类型和约束的类都要继承ORM的基类

    我们本次 要创建2个数据库表 都要继承ORM Base基类CommonFieldsMixin公共字段类，CommonFieldsMixin公共字段类，所有表都有的字段，不需要额外实现，直接继承实现

    Base = declarative_base() 
# 我们本次 要创建2个数据库表 都要继承ORM Base基类 CommonFieldsMixin为公共字段类，为所有表都有的字段，不需要额外实现
# 创建用户表
#class MUH_User(Base,CommonFieldsMixin):#创建用户登录密码表
#class MUH_User_Psw(Base,CommonFieldsMixin):

  2. 实现与数据库关联的ORM表的类：这些类后续为ORM操作的对象，我们就可像操作对象一样操作这2个类与数据库进行关联，而不需要关心SQL实现

    因为我们需要实现用户注册，故要创建2张表 用户表 和 用户密码表，一张保存用户基础信息，一张保存用户密码表

    注意有几个细节：

    1. 创建公共基类CommonFieldsMixin，让所有的表都自动包含公共基类字段

      class MUH_User(Base,CommonFieldsMixin):
class MUH_User_Psw(Base,CommonFieldsMixin)

      其中Base 是ORM基类 CommonFieldsMixin为公共基类

      ORM类定义说明：

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

      • create_date:对应数据库表的列名

      • Column：表示列

      • DateTime：数据类型，注意数据库表的类型都是基础类型，千万别搞个列表，字典，元组作为表的类型，如果非要用请转换为JSON string类型

      • default：默认值

      • ORM中常见类型约束及其他约束整理如下

        ORM表中列的类型说明举例
        Integer整数类型的字段age = Column(Integer)
        String(length)描述变长字符串类型的字段name = Column(String(50))
        Text用于存储较长文本description = Column(Text)
        Boolean描述布尔值类型的字段is_active = Column(Boolean, default=True)
        Float描述浮点数类型的字段price = Column(Float)
        Numeric(precision, scale)精确数字类型，适用于需要高精度的小数amount = Column(Numeric(10, 2)) #精度为 10 位，保留 2 位小数的数字
        Date描述日期类型字段，不包含时间部分birthdate = Column(Date)
        DateTime描述日期和时间类型字段created_at = Column(DateTime)
        Time描述时间类型字段，不包含日期部分clock_in = Column(Time)
        Interval描述时间间隔字段，用于存储持续时间（例如，2 days, 5 hours）duration = Column(Interval)
        UUID用于存储 UUID（通用唯一标识符）user_id = Column(UUID(as_uuid=True), default=uuid.uuid4)
        LargeBinary（不建议使用）描述二进制数据字段，适用于存储大块二进制数据，如文件或图像。image = Column(LargeBinary)
        Enum用于存储枚举类型字段，通常用于有限的固定选项（如性别、状态等）size = Column(Enum(‘small’, ‘medium’, ‘large’, name=‘size’))
        JSON用于存储 JSON 格式的数据preferences = Column(JSON)
        ForeignKey用于指定外键约束，表示该列是另一个表的外键user_id = Column(Integer, ForeignKey(‘users.id’))
        primary_key定义表的主键id = Column(String(50), primary_key=True, default=str(uuid.uuid4()))
        nullable是否可为nullname = Column(String(100), nullable=False)
        default默认值id = Column(String(50), primary_key=True, default=str(uuid.uuid4()))
        onupdate当更新默认值onupdate=datetime.utcnow

      创建公共基类

      #orm_helper.py
#公共基类
# 定义公共字段 Mixin 类
class CommonFieldsMixin:create_date = Column(DateTime, default=datetime.now())create_id = Column(String(50))update_date = Column(DateTime, default=datetime.now(), onupdate=datetime.now)update_id = Column(String(50))visible = Column(Boolean, default=True)descriptions = Column(Text)

    2. 所有的id 采用guid字符串来实现，故引入import uuid，

      默认自动生成id = Column(String(50), primary_key=True,default=uuid.uuid4())

      #orm_helper.py
# 创建用户表
class MUH_User(Base,CommonFieldsMixin):__tablename__ = "muh_user"id = Column(String(50), primary_key=True,default=str(uuid.uuid4()))user_name = Column(String(20))user_gender = Column(String(2))user_age = Column(Integer)user_imgs =Column(String(255))def __repr__(self):# 自动列出所有字段attrs = {column.name: getattr(self, column.name) for column in self.__table__.columns}return f"<{self.__class__.__name__}({', '.join(f'{key}={value!r}' for key, value in attrs.items())})>"#创建用户登录密码表
class MUH_User_Psw(Base,CommonFieldsMixin):__tablename__ = "muh_user_psw"id = Column(String(50), primary_key=True,default=str(uuid.uuid4())) user_id = Column(String(50))user_psw = Column(String(255))def __repr__(self):# 自动列出所有字段attrs = {column.name: getattr(self, column.name) for column in self.__table__.columns}return f"<

http://www.mrgr.cn/news/70805.html

相关文章：

  • Python爬虫案例八：抓取597招聘网信息并用xlutils进行excel数据的保存
  • 【智谱清言-注册_登录安全分析报告】
  • hbase mongodb hive starrocks比较
  • 计算机网络socket编程(4)_TCP socket API 详解
  • 大语言模型---什么是注意力机制？LlaMA 中注意力机制的数学定义
  • C# IO文件操作
  • C++学习笔记----11、模块、头文件及各种主题（二）---- 函数模板（2）
  • VirtIO实现原理（2）
  • Python酷库之旅-第三方库Pandas(207)
  • 金山云C++面试题及参考答案
  • Python学习：scipy是什么？
  • 关于cloacked-pixel-master在kali上的安装
  • C++线程
  • Java期末复习暨学校第四次上机课作业
  • 【含文档】基于ssm+jsp的校园疫情管理系统（含源码+数据库+lw）
  • NLP论文速读（NeurIPS2024）|使用视觉增强的提示来增强视觉推理
  • SQLite Where 子句
  • 从2D到3D：MoGe——微软的单目3D几何重建模型
  • Python CSV文件列合并实战：从基础到进阶
  • [数组二分查找] 0374. 猜数字大小
  • 知名开源项目官宣停更，太痛了！
  • （66）RLS均衡器和LMS均衡器作用于通过频率选择性衰落信道的16-QAM信号的性能对比MATLAB仿真
  • Python函数专题：偏函数
  • halcon拉普拉斯算子
  • 【优选算法】探索双指针之美（一）: 同向双指针缔造滑动窗口
  • SpringBoot（十二）SpringBoot配置redis