pub async fn insert_records<T: KineticaRecord>( &self, table_name: String, data: Vec<T>, ) -> Result<InsertRecordsResponse, KineticaError>
Add records to specified table
Adds multiple records to the specified table. The operation is synchronous, meaning that a response will not be returned until all the records are fully inserted and available. The response payload provides the counts of the number of records actually inserted and/or updated, and can provide the unique identifier of each added record.
The options parameter can be used to customize this function’s behavior.
The update_on_existing_pk option specifies the record collision policy for inserting into a table with a primary key, but is ignored if no primary key exists.
The return_record_ids option indicates that the database should return the unique identifiers of inserted records.
The records are encoded by the schema of the first.
table_name- Name of table to which the records are to be added, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table.data- The records to send.
pub async fn insert_records_with_opts<T: KineticaRecord>( &self, table_name: String, data: Vec<T>, options: InsertRecordsRequestOptions, ) -> Result<InsertRecordsResponse, KineticaError>
Add records to specified table
Adds multiple records to the specified table. The operation is synchronous, meaning that a response will not be returned until all the records are fully inserted and available. The response payload provides the counts of the number of records actually inserted and/or updated, and can provide the unique identifier of each added record.
The options parameter can be used to customize this function’s behavior.
The update_on_existing_pk option specifies the record collision policy for inserting into a table with a primary key, but is ignored if no primary key exists.
The return_record_ids option indicates that the database should return the unique identifiers of inserted records.
The records are encoded by the schema of the first.
table_name- Name of table to which the records are to be added, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table.data- The records to send.options- The optional parameters; any left unset take the server’s defaults.
pub async fn insert_records_request<T: KineticaRecord>( &self, request: &InsertRecordsRequest<T>, ) -> Result<InsertRecordsResponse, KineticaError>
Sends a pre-built InsertRecordsRequest to the /insert/records endpoint, its records encoded by the schema of the first.
pub async fn insert_records_raw( &self, request: &RawInsertRecordsRequest, ) -> Result<InsertRecordsResponse, KineticaError>
Sends a pre-built RawInsertRecordsRequest to the /insert/records endpoint, returning the response as the server sends it.
pub async fn insert_records_from_url( &self, url: &str, request: &RawInsertRecordsRequest, ) -> Result<InsertRecordsResponse, KineticaError>
Sends a pre-built RawInsertRecordsRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.