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

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

时间：2024-11-12 20:46:47浏览次数：3  
标签：__ 27 String python 数据库 Column ORM config

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 configparser

class 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 value
    def 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 是否可为null name = 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"<

标签：__,27,String,python,数据库,Column,ORM,config
From： https://blog.csdn.net/Lookontime/article/details/143696629

相关文章

  • 第六课 Python之模块
    一、模块的介绍（1）python模块，是一个python文件，以一个.py文件，包含了python对象定义和pyhton语句（2）python对象定义和python语句（3）模块让你能够有逻辑地组织你的python代码段。（4）把相关的代码分配到一个模块里能让你的代码更好用，更易懂（5）模块能定义函数，类和变量，模块里也能包含可执行的......
  • TransFormer--注意力机制：多头注意力
    TransFormer--注意力机制：多头注意力多头注意力是指我们可以使用多个注意力头，而不是只用一个。也就是说，我们可以应用在上一篇中学习的计算注意力矩阵Z的方法，来求得多个注意力矩阵。我们通过一个例子来理解多头注意力层的作用。以Alliswell这句话为例，假设我们需要计算w......
  • python 工作中常用技巧
    json格式化后中文乱码问题在Python中，使用json.dumps()将数据序列化为JSON字符串时，默认情况下，非ASCII字符（包括中文字符）会被转义为Unicode码点（例如\uXXXX）。这是为了确保生成的JSON字符串在任何环境中都是有效的，并且能够被正确解析。如果你希望生成的JSON字符串直接包含中文字符......
  • [AIGC]使用阿里云Paraformer语音识别录音识别 API 进行音频处理 —— 完整流程及代码
    文章目录一、前提准备1.阿里云账号2.开通录音识别服务3.获取APIKey和AccessToken二、阿里云录音识别API的主要功能介绍三、完整代码流程1.导入依赖库2.设置环境变量3.生成Token4.上传文件并发起识别请求4.1请求4.2请将'{api-key}'替换为你的apikey，'{ta......
  • Python连接VNC
    #-*-coding:utf-8-*-"""安装命令:pipinstallopencv-pythonvncdotool-ihttps://mirrors.aliyun.com/pypi/simple"""importctypesimporttimefromloggingimportshutdownimportrandomimportcv2,numpyasnpfromvncdotool......
  • 【PAT_Python解】1125 子串与子列
    原题链接：PTA|程序设计类实验辅助教学平台Tips：以下Python代码仅个人理解，非最优算法，仅供参考！多学习其他大佬的AC代码！测试点5超时：defmin_window_substring(s,p):len1=len(s)len2=len(p)mixn=0min_length=len1+1#设置为一个较大的值......
  • debian11 使用python3 启动http文件服务器和ftp服务器脚本
    http文件服务器start_http_server.sh#!/bin/bashport=$1host=0.0.0.0functionUsage(){echo-e"Usage:${0}[port]"exit0}if[[${port}==""]];thenUsagefi#检查端口号是否被占用check_port=`netstat-ant|grepLISTEN|grep${port}......
  • Python科学计算的利器：Scipy库深度解析
    Python科学计算的利器：SciPy库深度解析在数据科学、工程计算和数学建模领域，Python的SciPy库是不可或缺的强大工具。SciPy以NumPy为基础，提供了丰富的函数和算法，用于数值积分、优化、线性代数、信号处理等科学计算任务。本文将详细介绍SciPy库的核心模块和功能，帮助你深入理解......
  • Python的Web请求：requests库入门与应用
    Python的Web请求：requests库入门与应用在Python中，进行网络请求和获取数据是许多应用程序的基础功能。requests库是Python中最流行的HTTP库之一，它以简洁、易用、功能强大的特点著称，可以帮助开发者高效地进行各种类型的Web请求。本文将带你快速上手requests库，并展示如何在实际......
  • 基于Python实现的django农业垃圾分类管理系统的设计与实现
    《[含文档+PPT+源码等]精品基于Python实现的django农业垃圾分类管理系统的设计与实现》该项目含有源码、文档、PPT、配套开发软件、软件安装教程、项目发布教程、包运行成功以及课程答疑与微信售后交流群、送查重系统不限次数免费查重等福利！软件开发环境及开发工具：开发语言：py......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99