perf: Support not only pgsql but mysql

This commit is contained in:
fit2cloud-chenyw
2025-08-04 18:21:55 +08:00
parent 6a9b5eab65
commit 80484c3c5c
6 changed files with 64 additions and 65 deletions
@@ -20,7 +20,7 @@ depends_on = None
def upgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.add_column('sys_user', sa.Column('language', sa.VARCHAR(length=255), server_default=sa.text("'zh-CN'::character varying"), nullable=False))
op.add_column('sys_user', sa.Column('language', sa.VARCHAR(length=255), server_default=sa.text("'zh-CN'"), nullable=False))
# ### end Alembic commands ###
+5 -8
View File
@@ -23,8 +23,8 @@ def upgrade():
existing_type=sa.INTEGER(),
type_=sa.BigInteger(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1, maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True
)
op.alter_column('chat', 'datasource',
existing_type=sa.INTEGER(),
type_=sa.BigInteger(),
@@ -33,8 +33,7 @@ def upgrade():
existing_type=sa.INTEGER(),
type_=sa.BigInteger(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1, maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True)
op.alter_column('chat_record', 'chat_id',
existing_type=sa.INTEGER(),
type_=sa.BigInteger(),
@@ -68,8 +67,7 @@ def downgrade():
existing_type=sa.BigInteger(),
type_=sa.INTEGER(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1, maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True)
op.alter_column('chat', 'datasource',
existing_type=sa.BigInteger(),
type_=sa.INTEGER(),
@@ -78,6 +76,5 @@ def downgrade():
existing_type=sa.BigInteger(),
type_=sa.INTEGER(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1, maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True)
# ### end Alembic commands ###
@@ -24,9 +24,7 @@ def upgrade():
existing_type=sa.INTEGER(),
type_=sa.BigInteger(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1,
maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True)
# ### end Alembic commands ###
@@ -36,8 +34,6 @@ def downgrade():
existing_type=sa.BigInteger(),
type_=sa.INTEGER(),
existing_nullable=False,
autoincrement=True,
existing_server_default=sa.Identity(always=True, start=1, increment=1, minvalue=1,
maxvalue=2147483647, cycle=False, cache=1))
autoincrement=True)
op.drop_column('ds_rules', 'oid')
# ### end Alembic commands ###
+45 -45
View File
@@ -1,6 +1,7 @@
from collections import defaultdict
from typing import Optional
from fastapi import APIRouter, HTTPException, Query
from sqlmodel import func, or_, select, delete as sqlmodel_delete
from sqlmodel import SQLModel, func, or_, select, delete as sqlmodel_delete
from apps.system.crud.user import check_account_exists, check_email_exists, check_email_format, check_pwd_format, get_db_user, single_delete, user_ws_options
from apps.system.models.system_model import UserWsModel, WorkspaceModel
from apps.system.models.user import UserModel
@@ -11,6 +12,7 @@ from common.core.pagination import Paginator
from common.core.schemas import PaginatedResponse, PaginationParams
from common.core.security import default_md5_pwd, md5pwd, verify_md5pwd
from common.core.sqlbot_cache import clear_cache
router = APIRouter(tags=["user"], prefix="/user")
@router.get("/info")
@@ -30,43 +32,15 @@ async def pager(
pagination = PaginationParams(page=pageNum, size=pageSize)
paginator = Paginator(session)
filters = {}
stmt = (
select(
UserModel,
func.coalesce(
func.array_remove(
func.array_agg(UserWsModel.oid),
None
),
[]
).label("oid_list")
#func.coalesce(func.string_agg(WorkspaceModel.name, ','), '').label("space_name")
)
.join(UserWsModel, UserModel.id == UserWsModel.uid, isouter=True)
#.join(WorkspaceModel, UserWsModel.oid == WorkspaceModel.id, isouter=True)
.where(UserModel.id != 1)
.group_by(UserModel.id)
.order_by(UserModel.create_time)
)
if status is not None:
stmt = stmt.where(UserModel.status == status)
origin_stmt = select(UserModel.id).join(UserWsModel, UserModel.id == UserWsModel.uid).where(UserModel.id != 1).distinct()
if oidlist:
user_filter = (
select(UserModel.id)
.join(UserWsModel, UserModel.id == UserWsModel.uid)
.where(UserWsModel.oid.in_(oidlist))
.distinct()
)
stmt = stmt.where(UserModel.id.in_(user_filter))
""" if origins is not None:
stmt = stmt.where(UserModel.origin == origins) """
origin_stmt = origin_stmt.where(UserWsModel.oid.in_(oidlist))
if status is not None:
origin_stmt = origin_stmt.where(UserModel.status == status)
if keyword:
keyword_pattern = f"%{keyword}%"
stmt = stmt.where(
origin_stmt = origin_stmt.where(
or_(
UserModel.account.ilike(keyword_pattern),
UserModel.name.ilike(keyword_pattern),
@@ -75,21 +49,47 @@ async def pager(
)
user_page = await paginator.get_paginated_response(
stmt=stmt,
stmt=origin_stmt,
pagination=pagination,
**filters)
""" for item in user_page.items:
space_name: str = item['space_name']
if space_name and 'i18n_default_workspace' in space_name:
parts = list(map(
lambda x: trans(x) if x == "i18n_default_workspace" else x,
space_name.split(',')
))
output_str = ','.join(parts)
item['space_name'] = output_str """
uid_list = [item.get('id') for item in user_page.items]
if not uid_list:
return user_page
stmt = (
select(UserModel, UserWsModel.oid.label('ws_oid'))
.join(UserWsModel, UserModel.id == UserWsModel.uid, isouter=True)
.where(UserModel.id.in_(uid_list))
.order_by(UserModel.create_time)
)
user_workspaces = session.exec(stmt).all()
merged = defaultdict(list)
extra_attrs = {}
for (user, ws_oid) in user_workspaces:
item = {}
item.update(user.model_dump())
user_id = item['id']
merged[user_id].append(ws_oid)
if user_id not in extra_attrs:
extra_attrs[user_id] = {k: v for k, v in item.items() if k != "ws_oid"}
# 组合结果
result = [
{**extra_attrs[user_id], "oid_list": oid_list}
for user_id, oid_list in merged.items()
]
user_page.items = result
return user_page
def format_user_dict(row) -> dict:
result_dict = {}
for item, key in zip(row, row._fields):
if isinstance(item, SQLModel):
result_dict.update(item.model_dump())
else:
result_dict[key] = item
return result_dict
@router.get("/ws")
async def ws_options(session: SessionDep, current_user: CurrentUser, trans: Trans) -> list[UserWs]:
return await user_ws_options(session, current_user.id, trans)
+9 -5
View File
@@ -44,11 +44,13 @@ class Settings(BaseSettings):
self.FRONTEND_HOST
]
POSTGRES_SERVER: str
POSTGRES_SERVER: str = 'localhost'
POSTGRES_PORT: int = 5432
POSTGRES_USER: str
POSTGRES_PASSWORD: str = ""
POSTGRES_DB: str = ""
POSTGRES_USER: str = 'root'
POSTGRES_PASSWORD: str = "123456"
POSTGRES_DB: str = "sqlbot"
SQLBOT_DB_URL: str = ''
#SQLBOT_DB_URL: str = 'mysql+pymysql://root:Password123%[email protected]:3306/sqlbot'
TOKEN_KEY: str = "X-SQLBOT-TOKEN"
DEFAULT_PWD: str = "SQLBot@123456"
@@ -64,7 +66,9 @@ class Settings(BaseSettings):
@computed_field # type: ignore[prop-decorator]
@property
def SQLALCHEMY_DATABASE_URI(self) -> PostgresDsn:
def SQLALCHEMY_DATABASE_URI(self) -> PostgresDsn | str:
if self.SQLBOT_DB_URL:
return self.SQLBOT_DB_URL
return MultiHostUrl.build(
scheme="postgresql+psycopg",
username=self.POSTGRES_USER,
+2
View File
@@ -12,6 +12,8 @@ class Paginator:
self.session = session
def _process_result_row(self, row: Row) -> Dict[str, Any]:
result_dict = {}
if isinstance(row, int):
return {'id': row}
for item, key in zip(row, row._fields):
if isinstance(item, SQLModel):
result_dict.update(item.model_dump())