Skip to content

Fix pgsql syntax error in code generation #808

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 7 commits into from
Sep 11, 2025
Merged

Fix pgsql syntax error in code generation #808

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
f338088
Fix ensurepip_install
byte-voyager Sep 10, 2025
3bcd33c
fix code format
byte-voyager Sep 10, 2025
32962d0
Merge branch 'fastapi-practices:master' into master
byte-voyager Sep 11, 2025
ed2c799
Update title field in OperaLogSchemaBase to allow None values
Sep 11, 2025
cbd8723
Update response type in get_all_tables to allow None values in dictio…
Sep 11, 2025
94b435c
Fix code generation error in PostgreSQL
Sep 11, 2025
046c51e
Update opera_log.py
byte-voyager Sep 11, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion backend/plugin/code_generator/api/v1/code.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
@router.get('/tables', summary='获取数据库表')
async def get_all_tables(
table_schema: Annotated[str, Query(description='数据库名')] = 'fba',
) -> ResponseSchemaModel[list[dict[str, str]]]:
) -> ResponseSchemaModel[list[dict[str, str | None]]]:
data = await gen_service.get_tables(table_schema=table_schema)
return response_base.success(data=data)

Expand Down
4 changes: 3 additions & 1 deletion backend/plugin/code_generator/crud/crud_code.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ async def get_all_tables(db: AsyncSession, table_schema: str) -> Sequence[RowMap
WHERE table_name NOT LIKE 'sys_gen_%'
AND table_schema = :table_schema;
"""
stmt = text(sql).bindparams(table_schema=table_schema)
else:
sql = """
SELECT c.relname AS table_name, obj_description(c.oid) AS table_comment
Expand All @@ -36,7 +37,7 @@ async def get_all_tables(db: AsyncSession, table_schema: str) -> Sequence[RowMap
AND n.nspname = 'public' -- schema 通常是 'public'
AND c.relname NOT LIKE 'sys_gen_%';
"""
stmt = text(sql).bindparams(table_schema=table_schema)
stmt = text(sql)
result = await db.execute(stmt)
return result.mappings().all()

Expand All @@ -63,6 +64,7 @@ async def get_table(db: AsyncSession, table_name: str) -> Row[tuple]:
LEFT JOIN pg_namespace n ON n.oid = c.relnamespace
WHERE c.relkind = 'r'
AND n.nspname = 'public' -- schema 通常是 'public'
AND c.relname = :table_name
AND c.relname NOT LIKE 'sys_gen_%';
"""
stmt = text(sql).bindparams(table_name=table_name)
Expand Down