async added
This commit is contained in:
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -15,8 +15,10 @@ def exec_procedure(session, proc_name, params, database: str = None):
|
|||||||
EXEC @return_value = {dbstr}[dbo].[{proc_name}] {params};
|
EXEC @return_value = {dbstr}[dbo].[{proc_name}] {params};
|
||||||
SELECT 'Return Value' = @return_value;
|
SELECT 'Return Value' = @return_value;
|
||||||
""".format(dbstr=dbstr, proc_name=proc_name, params=sql_params)
|
""".format(dbstr=dbstr, proc_name=proc_name, params=sql_params)
|
||||||
|
data = session.execute(sql_string).fetchall()
|
||||||
return session.execute(sql_string).fetchall()
|
session.commit()
|
||||||
|
session.expire_all()
|
||||||
|
return data
|
||||||
|
|
||||||
|
|
||||||
def exec_procedure_wo_result(session, proc_name, params, database: str = None):
|
def exec_procedure_wo_result(session, proc_name, params, database: str = None):
|
||||||
|
@ -21,7 +21,10 @@ def exec_procedure(session, proc_name, params, database: str = None):
|
|||||||
SELECT 'Return Value' = @return_value;
|
SELECT 'Return Value' = @return_value;
|
||||||
""".format(dbstr=dbstr, proc_name=proc_name, params=sql_params)
|
""".format(dbstr=dbstr, proc_name=proc_name, params=sql_params)
|
||||||
print(sql_string)
|
print(sql_string)
|
||||||
return session.execute(sql_string).fetchall()
|
data = session.execute(sql_string).fetchall()
|
||||||
|
session.commit()
|
||||||
|
session.expire_all()
|
||||||
|
return data
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@ -48,9 +48,10 @@ class AdvancedSearchInit(AccountInit, CityInit):
|
|||||||
Patronymic: Optional[str] = None
|
Patronymic: Optional[str] = None
|
||||||
|
|
||||||
|
|
||||||
class FilterTypeInit(UserInit):
|
class FilterTypeInit(BaseModel):
|
||||||
IDUser: int
|
IDUser: int
|
||||||
GetType: int
|
GetType: int
|
||||||
|
NeedClear: bool
|
||||||
|
|
||||||
|
|
||||||
class FilterListInit(UserInit):
|
class FilterListInit(UserInit):
|
||||||
|
Reference in New Issue
Block a user