add model code gen

Author: LuisLuii

dist/fastapi_quickcrud-0.2.1.tar.gz

@@ -594,7 +594,7 @@ def _extra_foreign_table_from_declarative_base(self, model) -> Dict[str, Table]:
                         reference_table_instance_ = column.table
 
                 reference_mapper[local_column_] = {"foreign_table": foreign_table,
-                                                        "foreign_table_name": foreign_table_name}
+                                                   "foreign_table_name": foreign_table_name}
                 local_reference_pairs.append({'local': {"local_table": local_table_,
                                                         "local_column": local_column_},
                                               "reference": {"reference_table": reference_table_,
@@ -957,7 +957,6 @@ def create_one(self) -> Tuple:
         request_fields = []
         response_fields = []
 
-
         # Create Request and Response Model
         all_field = deepcopy(self.all_field)
         for i in all_field:
@@ -1189,7 +1188,56 @@ def find_one(self) -> Tuple:
         if self.table_of_foreign:
             request_validation.append(lambda self_object: self._assign_join_table_instance(self_object,
                                                                                            self.table_of_foreign))
-
+        from jinja2 import Template
+
+        template ='''
+            {% for decorator in decorators -%}
+            {{ decorator }}
+            {% endfor -%}
+            class {{ class_name }}:
+            {%- if description %}
+                """
+                {{ description }}
+                """
+            {%- endif %}
+            {%- if config %}
+            {%- filter indent(4) %}
+            {% include 'Config.jinja2' %}
+            {%- endfilter %}
+            {%- endif %}
+            {%- if not fields %}
+                pass
+            {%- else %}
+                {% for field in fields -%}
+                {{ field.name }} = {{ field.name }}
+                {% endfor -%}
+                {%- set field = fields[0] %}
+                {%- if not field.annotated and field.field %}
+                __root__: {{ field.type_hint }} = {{ field.field }}
+                {%- else %}
+                {%- if field.annotated %}
+                __root__: {{ field.annotated }}
+                {%- else %}
+                __root__: {{ field.type_hint }}
+                {%- endif %}
+                {%- if not (field.required or (field.represented_default == 'None' and field.strip_default_none))
+                        %} = {{ field.represented_default }}
+                {%- endif -%}
+                {%- endif %}
+            {%- endif %}
+
+        '''
+        data = {
+            "decorator": "@dataclass",
+            "class_name": f'{self.db_name + str(uuid.uuid4())}_FindOneRequestBody',
+            "description": "request query model for find one api",
+            "ntp_server_pri": "0.pool.ntp.org",
+            "ntp_server_sec": "1.pool.ntp.org",
+        }
+
+        j2_template = Template(template)
+
+        print(j2_template.render(data))
         request_query_model = make_dataclass(f'{self.db_name + str(uuid.uuid4())}_FindOneRequestBody',
                                              request_fields,
                                              namespace={
@@ -1209,7 +1257,7 @@ def find_one(self) -> Tuple:
         response_model = _add_orm_model_config_into_pydantic_model(response_model, config=OrmConfig)
 
         response_model = create_model(
-            f'{self.db_name + str(uuid.uuid4())}_FindOneResponseListModel',
+            f'{self.db_name + str(uuid.uuid4())}_111FindOneResponseListModel',
             **{'__root__': (response_model, None), '__base__': ExcludeUnsetBaseModel}
         )
 

dist/fastapi_quickcrud-0.2.2.tar.gz

@@ -1,11 +1,70 @@
+import os
+
 from fastapi import FastAPI
-from fastapi_quickcrud import crud_router_builder
+from sqlalchemy.dialects.postgresql import INTERVAL, JSONB, UUID
+
+from fastapi_quickcrud import crud_router_builder, CrudMethods
 from sqlalchemy import *
 from sqlalchemy.orm import *
 from fastapi_quickcrud.crud_router import generic_sql_crud_router_builder
 
 Base = declarative_base()
 
+TEST_DATABASE_URL = os.environ.get('TEST_DATABASE_URL', 'postgresql://postgres:[email protected]:5432/postgres')
+
+app = FastAPI()
+
+Base = declarative_base()
+metadata = Base.metadata
+
+from sqlalchemy import create_engine
+
+engine = create_engine(TEST_DATABASE_URL, future=True, echo=True,
+                       pool_use_lifo=True, pool_pre_ping=True, pool_recycle=7200)
+async_session = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+
+
+def get_transaction_session():
+    try:
+        db = async_session()
+        yield db
+    finally:
+        db.close()
+
+
+class UUIDTable(Base):
+    primary_key_of_table = "primary_key"
+    unique_fields = ['primary_key', 'int4_value', 'float4_value']
+    __tablename__ = 'test_uuid_primary_sync'
+    __table_args__ = (
+        UniqueConstraint('primary_key', 'int4_value', 'float4_value'),
+    )
+    primary_key = Column(Integer, primary_key=True, info={'alias_name': 'primary_key'}, autoincrement=True,
+                         server_default="nextval('test_build_myself_id_seq'::regclass)")
+    bool_value = Column(Boolean, nullable=False, server_default=text("false"))
+    char_value = Column(CHAR(10))
+    date_value = Column(Date, server_default=text("now()"))
+    float4_value = Column(Float, nullable=False)
+    float8_value = Column(Float(53), nullable=False, server_default=text("10.10"))
+    int2_value = Column(SmallInteger, nullable=False)
+    int4_value = Column(Integer, nullable=False)
+    int8_value = Column(BigInteger, server_default=text("99"))
+    interval_value = Column(INTERVAL)
+    json_value = Column(JSON)
+    jsonb_value = Column(JSONB(astext_type=Text()))
+    numeric_value = Column(Numeric)
+    text_value = Column(Text)
+    time_value = Column(Time)
+    timestamp_value = Column(DateTime)
+    timestamptz_value = Column(DateTime(True))
+    timetz_value = Column(Time(True))
+    varchar_value = Column(String)
+    array_value = Column(ARRAY(Integer()))
+    array_str__value = Column(ARRAY(String()))
+
+
+UUIDTable.__table__.create(engine, checkfirst=True)
+
 
 class Account(Base):
     __tablename__ = "account"
@@ -29,33 +88,16 @@ class BlogComment(Base):
 
 
 crud_route_parent = crud_router_builder(
-    db_model=Account,
+    db_model=UUIDTable,
     prefix="/account",
     tags=["account"],
-    foreign_include=[BlogComment, BlogPost]
-
-)
-print("BlogPost222")
-
-crud_route_child1 = generic_sql_crud_router_builder(
-    db_model=BlogPost,
-    prefix="/blog_post",
-    tags=["blog_post"],
-    foreign_include=[BlogComment, Account]
-
-)
-print("BlogComment111")
-
-crud_route_child2 = generic_sql_crud_router_builder(
-    db_model=BlogComment,
-    prefix="/blog_comment",
-    tags=["blog_comment"],
-    foreign_include=[BlogPost]
+    crud_methods=[CrudMethods.UPDATE_MANY],
+    db_session=get_transaction_session,
 
 )
 
 app = FastAPI()
-[app.include_router(i) for i in [crud_route_parent, crud_route_child1, crud_route_child2]]
+[app.include_router(i) for i in [crud_route_parent]]
 
 
 @app.get("/", tags=["child"])
@@ -65,4 +107,5 @@ async def root():
 
 import uvicorn
 
-uvicorn.run(app, host="0.0.0.0", port=8002, debug=False)
+uvicorn.run(app, host="0.0.0.0", port=8003
+            , debug=False)

src/fastapi_quick_crud_template/test_build_myself/model/test_build_myself.py

@@ -0,0 +1,5 @@
+from .misc.utils import sqlalchemy_to_pydantic
+from .crud_router import crud_router_builder
+from .misc.type import CrudMethods
+
+