Skip to main content
Source

​
pub async fn insert_records_from_query( &self, table_name: String, remote_query: String, modify_columns: HashMap<String, HashMap<String, String>>, create_table_options: HashMap<String, String>, ) -> Result<InsertRecordsFromQueryResponse, KineticaError>

Insert records from external database from a given query into the specified target table

Computes remote query result and inserts the result data into a new or existing table.

  • table_name - Name of the table into which the data will be inserted, in [schema_name.]table_name format, using standard name resolution rules. If the table does not exist, the table will be created using either an existing type_id or the type inferred from the remote query, and the new table name will have to meet standard table naming criteria.
  • remote_query - Query for which result data needs to be imported.
  • modify_columns - Not implemented yet.
  • create_table_options - Options used when creating the target table.

Insert records from external database from a given query into the specified target table

Computes remote query result and inserts the result data into a new or existing table.

  • table_name - Name of the table into which the data will be inserted, in [schema_name.]table_name format, using standard name resolution rules. If the table does not exist, the table will be created using either an existing type_id or the type inferred from the remote query, and the new table name will have to meet standard table naming criteria.
  • remote_query - Query for which result data needs to be imported.
  • modify_columns - Not implemented yet.
  • create_table_options - Options used when creating the target table.
  • options - The optional parameters; any left unset take the server’s defaults.

Sends a pre-built InsertRecordsFromQueryRequest to the /insert/records/fromquery endpoint.

Sends a pre-built InsertRecordsFromQueryRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.