laipeng/reflex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

type model

Browse Source
This commit is contained in:
Lendemor 2024-11-22 16:50:24 +01:00
parent e895907a49
commit 7a986695c5
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
reflex/model.py
View File

@ -15,6 +15,7 @@ import alembic.util
import sqlalchemy import sqlalchemy
import sqlalchemy.exc import sqlalchemy.exc
import sqlalchemy.orm import sqlalchemy.orm
from alembic.runtime.migration import MigrationContext
from reflex.base import Base from reflex.base import Base
from reflex.config import environment, get_config from reflex.config import environment, get_config
@ -304,7 +305,11 @@ class Model(Base, sqlmodel.SQLModel): # pyright: ignore [reportGeneralTypeIssue
writer = alembic.autogenerate.rewriter.Rewriter() writer = alembic.autogenerate.rewriter.Rewriter()
@writer.rewrites(alembic.operations.ops.AddColumnOp) @writer.rewrites(alembic.operations.ops.AddColumnOp)
def render_add_column_with_server_default(context, revision, op): def render_add_column_with_server_default(
context: MigrationContext,
revision: str | None,
op: Any,
):
# Carry the sqlmodel default as server_default so that newly added # Carry the sqlmodel default as server_default so that newly added
# columns get the desired default value in existing rows. # columns get the desired default value in existing rows.
if op.column.default is not None and op.column.server_default is None: if op.column.default is not None and op.column.server_default is None:
@ -313,7 +318,7 @@ class Model(Base, sqlmodel.SQLModel): # pyright: ignore [reportGeneralTypeIssue
) )
return op return op
def run_autogenerate(rev, context): def run_autogenerate(rev: str, context: MigrationContext):
revision_context.run_autogenerate(rev, context) revision_context.run_autogenerate(rev, context)
return [] return []
@ -355,7 +360,7 @@ class Model(Base, sqlmodel.SQLModel): # pyright: ignore [reportGeneralTypeIssue
""" """
config, script_directory = cls._alembic_config() config, script_directory = cls._alembic_config()
def run_upgrade(rev, context): def run_upgrade(rev: str, context: MigrationContext):
return script_directory._upgrade_revs(to_rev, rev) return script_directory._upgrade_revs(to_rev, rev)
with alembic.runtime.environment.EnvironmentContext( with alembic.runtime.environment.EnvironmentContext(