如何在Django ORM中调用MySQL自定义函数（不使用原生游标）

核心实现逻辑 #

不需要手动调用connection.cursor()执行裸SQL，借助Django ORM内置的自定义函数表达式机制，即可将MySQL侧定义的RefreshOrderId函数完全融入ORM的标准查询流程。

落地步骤 #

1. 封装自定义ORM表达式 #

在项目的models模块（或单独的db_functions.py文件）中，继承models.Func基类，绑定对应的MySQL自定义函数：

from django.db import models
from django.db.models import Func

class RefreshOrderId(Func):
    # 与MySQL中定义的函数名保持完全一致
    function = "RefreshOrderId"
    # 声明函数返回值类型为整型，匹配MySQL函数的RETURNS INT定义
    output_field = models.IntegerField()

2. 用ORM聚合方法触发函数调用 #

借助ORM内置的aggregate方法（和调用Count()、Sum()等内置聚合函数的流程完全一致），单次调用自定义函数并拿到返回值，全程不会手动初始化数据库游标：

from .models import PostOrder, RefreshOrderId

# 比如传入需要更新的旧订单ID为123
# 在空QuerySet上调用，ORM会生成不带多余表引用的纯函数查询语句，性能更优
call_result = PostOrder.objects.none().aggregate(
    new_generated_id=RefreshOrderId(123)
)

# 提取函数返回的新订单ID，对应MySQL函数计算的last_order_id + 1
new_order_id = call_result["new_generated_id"]

该流程生成的SQL完全由Django ORM的查询编译器自动拼接，执行链路和日常ORM查询完全统一，没有手动拼接SQL、手动管理游标生命周期的步骤，生成的语句形式类似：SELECT RefreshOrderId(123) AS new_generated_id。

运行注意事项 #

• 数据库连接所用的账号需要具备RefreshOrderId函数的EXECUTE权限，以及post_order表的查询、更新权限，配置逻辑和普通表操作完全一致。
• 由于该自定义函数内部包含UPDATE写操作，调用时请确保当前数据库连接处于正常提交状态，不要将调用放在自动回滚的测试事务块中，避免更新操作不落库。
• 该函数逻辑是单次全局计算最大订单ID，适合用单次aggregate的方式触发一次执行；不要将其放入逐行遍历的annotate()查询中，避免重复触发不必要的全表计算。
• 若需确认生成的SQL是否符合预期，可通过django.db.connection.queries打印ORM实际执行的语句，无需修改代码层实现。

内容的提问来源于stack exchange，提问作者Hossein Seyyedi