@@ -1100,6 +1100,103 @@ def execute_metaservice_cli_with_http_info(self, body, **kwargs): # noqa: E501
11001100 _request_timeout = params .get ('_request_timeout' ),
11011101 collection_formats = collection_formats )
11021102
1103+ def execute_query (self , body , ** kwargs ): # noqa: E501
1104+ """execute_query # noqa: E501
1105+
1106+ This method makes a synchronous HTTP request by default. To make an
1107+ asynchronous HTTP request, please pass async_req=True
1108+ >>> thread = api.execute_query(body, async_req=True)
1109+ >>> result = thread.get()
1110+
1111+ :param async_req bool
1112+ :param ExecuteQueryRequest body: (required)
1113+ :return: ExecuteQueryResponse
1114+ If the method is called asynchronously,
1115+ returns the request thread.
1116+ """
1117+ kwargs ['_return_http_data_only' ] = True
1118+ if kwargs .get ('async_req' ):
1119+ return self .execute_query_with_http_info (body , ** kwargs ) # noqa: E501
1120+ else :
1121+ (data ) = self .execute_query_with_http_info (body , ** kwargs ) # noqa: E501
1122+ return data
1123+
1124+ def execute_query_with_http_info (self , body , ** kwargs ): # noqa: E501
1125+ """execute_query # noqa: E501
1126+
1127+ This method makes a synchronous HTTP request by default. To make an
1128+ asynchronous HTTP request, please pass async_req=True
1129+ >>> thread = api.execute_query_with_http_info(body, async_req=True)
1130+ >>> result = thread.get()
1131+
1132+ :param async_req bool
1133+ :param ExecuteQueryRequest body: (required)
1134+ :return: ExecuteQueryResponse
1135+ If the method is called asynchronously,
1136+ returns the request thread.
1137+ """
1138+
1139+ all_params = ['body' ] # noqa: E501
1140+ all_params .append ('async_req' )
1141+ all_params .append ('_return_http_data_only' )
1142+ all_params .append ('_preload_content' )
1143+ all_params .append ('_request_timeout' )
1144+
1145+ params = locals ()
1146+ for key , val in six .iteritems (params ['kwargs' ]):
1147+ if key not in all_params :
1148+ raise TypeError (
1149+ "Got an unexpected keyword argument '%s'"
1150+ " to method execute_query" % key
1151+ )
1152+ params [key ] = val
1153+ del params ['kwargs' ]
1154+ # verify the required parameter 'body' is set
1155+ if self .api_client .client_side_validation and ('body' not in params or
1156+ params ['body' ] is None ): # noqa: E501
1157+ raise ValueError ("Missing the required parameter `body` when calling `execute_query`" ) # noqa: E501
1158+
1159+ collection_formats = {}
1160+
1161+ path_params = {}
1162+
1163+ query_params = []
1164+
1165+ header_params = {}
1166+
1167+ form_params = []
1168+ local_var_files = {}
1169+
1170+ body_params = None
1171+ if 'body' in params :
1172+ body_params = params ['body' ]
1173+ # HTTP header `Accept`
1174+ header_params ['Accept' ] = self .api_client .select_header_accept (
1175+ ['application/json' ]) # noqa: E501
1176+
1177+ # HTTP header `Content-Type`
1178+ header_params ['Content-Type' ] = self .api_client .select_header_content_type ( # noqa: E501
1179+ ['application/json' ]) # noqa: E501
1180+
1181+ # Authentication setting
1182+ auth_settings = ['volcengineSign' ] # noqa: E501
1183+
1184+ return self .api_client .call_api (
1185+ '/ExecuteQuery/2018-01-01/graph/post/application_json/' , 'POST' ,
1186+ path_params ,
1187+ query_params ,
1188+ header_params ,
1189+ body = body_params ,
1190+ post_params = form_params ,
1191+ files = local_var_files ,
1192+ response_type = 'ExecuteQueryResponse' , # noqa: E501
1193+ auth_settings = auth_settings ,
1194+ async_req = params .get ('async_req' ),
1195+ _return_http_data_only = params .get ('_return_http_data_only' ),
1196+ _preload_content = params .get ('_preload_content' , True ),
1197+ _request_timeout = params .get ('_request_timeout' ),
1198+ collection_formats = collection_formats )
1199+
11031200 def get_add_tables_ticket_options (self , body , ** kwargs ): # noqa: E501
11041201 """get_add_tables_ticket_options # noqa: E501
11051202
@@ -2361,6 +2458,103 @@ def graphrag_add_knowledge_base_with_http_info(self, body, **kwargs): # noqa: E
23612458 _request_timeout = params .get ('_request_timeout' ),
23622459 collection_formats = collection_formats )
23632460
2461+ def list_all_tables (self , body , ** kwargs ): # noqa: E501
2462+ """list_all_tables # noqa: E501
2463+
2464+ This method makes a synchronous HTTP request by default. To make an
2465+ asynchronous HTTP request, please pass async_req=True
2466+ >>> thread = api.list_all_tables(body, async_req=True)
2467+ >>> result = thread.get()
2468+
2469+ :param async_req bool
2470+ :param ListAllTablesRequest body: (required)
2471+ :return: ListAllTablesResponse
2472+ If the method is called asynchronously,
2473+ returns the request thread.
2474+ """
2475+ kwargs ['_return_http_data_only' ] = True
2476+ if kwargs .get ('async_req' ):
2477+ return self .list_all_tables_with_http_info (body , ** kwargs ) # noqa: E501
2478+ else :
2479+ (data ) = self .list_all_tables_with_http_info (body , ** kwargs ) # noqa: E501
2480+ return data
2481+
2482+ def list_all_tables_with_http_info (self , body , ** kwargs ): # noqa: E501
2483+ """list_all_tables # noqa: E501
2484+
2485+ This method makes a synchronous HTTP request by default. To make an
2486+ asynchronous HTTP request, please pass async_req=True
2487+ >>> thread = api.list_all_tables_with_http_info(body, async_req=True)
2488+ >>> result = thread.get()
2489+
2490+ :param async_req bool
2491+ :param ListAllTablesRequest body: (required)
2492+ :return: ListAllTablesResponse
2493+ If the method is called asynchronously,
2494+ returns the request thread.
2495+ """
2496+
2497+ all_params = ['body' ] # noqa: E501
2498+ all_params .append ('async_req' )
2499+ all_params .append ('_return_http_data_only' )
2500+ all_params .append ('_preload_content' )
2501+ all_params .append ('_request_timeout' )
2502+
2503+ params = locals ()
2504+ for key , val in six .iteritems (params ['kwargs' ]):
2505+ if key not in all_params :
2506+ raise TypeError (
2507+ "Got an unexpected keyword argument '%s'"
2508+ " to method list_all_tables" % key
2509+ )
2510+ params [key ] = val
2511+ del params ['kwargs' ]
2512+ # verify the required parameter 'body' is set
2513+ if self .api_client .client_side_validation and ('body' not in params or
2514+ params ['body' ] is None ): # noqa: E501
2515+ raise ValueError ("Missing the required parameter `body` when calling `list_all_tables`" ) # noqa: E501
2516+
2517+ collection_formats = {}
2518+
2519+ path_params = {}
2520+
2521+ query_params = []
2522+
2523+ header_params = {}
2524+
2525+ form_params = []
2526+ local_var_files = {}
2527+
2528+ body_params = None
2529+ if 'body' in params :
2530+ body_params = params ['body' ]
2531+ # HTTP header `Accept`
2532+ header_params ['Accept' ] = self .api_client .select_header_accept (
2533+ ['application/json' ]) # noqa: E501
2534+
2535+ # HTTP header `Content-Type`
2536+ header_params ['Content-Type' ] = self .api_client .select_header_content_type ( # noqa: E501
2537+ ['application/json' ]) # noqa: E501
2538+
2539+ # Authentication setting
2540+ auth_settings = ['volcengineSign' ] # noqa: E501
2541+
2542+ return self .api_client .call_api (
2543+ '/ListAllTables/2018-01-01/graph/post/application_json/' , 'POST' ,
2544+ path_params ,
2545+ query_params ,
2546+ header_params ,
2547+ body = body_params ,
2548+ post_params = form_params ,
2549+ files = local_var_files ,
2550+ response_type = 'ListAllTablesResponse' , # noqa: E501
2551+ auth_settings = auth_settings ,
2552+ async_req = params .get ('async_req' ),
2553+ _return_http_data_only = params .get ('_return_http_data_only' ),
2554+ _preload_content = params .get ('_preload_content' , True ),
2555+ _request_timeout = params .get ('_request_timeout' ),
2556+ collection_formats = collection_formats )
2557+
23642558 def list_cluster_tables (self , body , ** kwargs ): # noqa: E501
23652559 """list_cluster_tables # noqa: E501
23662560
0 commit comments