From b1fe8831ccc6d7f1d1cc281403ce3cd0393cd2ce Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 24 Oct 2025 16:10:37 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20base=20execute=5Fraw=5Fsql=20=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0timeout=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/utils/sql.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/utils/sql.py b/apps/utils/sql.py index e856c371..99497908 100644 --- a/apps/utils/sql.py +++ b/apps/utils/sql.py @@ -2,7 +2,7 @@ from django.db import connection from django.utils import timezone from datetime import datetime -def execute_raw_sql(sql: str, params=None): +def execute_raw_sql(sql: str, params=None, timeout=30): """执行原始sql并返回rows, columns数据 Args: @@ -10,7 +10,7 @@ def execute_raw_sql(sql: str, params=None): params (_type_, optional): 参数列表. Defaults to None. """ with connection.cursor() as cursor: - cursor.execute("SET statement_timeout TO %s;", [30000]) + cursor.execute(f"SET statement_timeout TO '{int(timeout*1000)}ms';") if params: cursor.execute(sql, params=params) else: