Untitled

@router.post("/query", response_model=ResponseDataModel)
async def executeQuery(request:RequestModel=Body(...,examples=get_request_example("single")), headers: Headers = Depends()):
    sql = request.sql[0]
    data_file = request.data_file
    table_name = data_file.split('/')[-1]

@router.post("/oneQuery")
async def executeQuery(query: constr(regex=r'^(SELECT|select).*'),bucket_name: str):
    con =S3_funcs.getConnection(threading.get_ident())
    S3_funcs.verifyExistence(con=con,query=query,bucket_name=bucket_name)
    json_rows = S3_funcs.executeQuery(con=con,query=query)
    return json_rows