Endpoint

Upsert documents

Name

upsert_documents

Description

Insert Or Update (Upserts) documents. If _id column not supplied then this acts like INSERT call. If _id column supplied and its found then UPDATE action happens else INSERT. Look at the Result column in the output to see if document was created or updated.

Related Tables

[Dynamic Table] , [Dynamic Table]

Parameters

Parameter	Label	Required	Options	Description
Index	Index	YES
Alias	Alias (Deprecated - Use Index instead)	NO

Output Columns

Label	Data Type (SSIS)	Data Type (SQL)	Length	Raw
ErrorFound	`DT_BOOL`	`bit`		`False`
Result	`DT_WSTR`	`nvarchar(4000)`	4000	`False`
HttpStatus	`DT_I4`	`int`		`False`
Id	`DT_WSTR`	`nvarchar(50)`	50	`False`
Index	`DT_WSTR`	`nvarchar(150)`	150	`False`
Type	`DT_WSTR`	`nvarchar(50)`	50	`False`
IndexUuid	`DT_WSTR`	`nvarchar(50)`	50	`False`
Reason	`DT_WSTR`	`nvarchar(4000)`	4000	`False`
ErrorType	`DT_WSTR`	`nvarchar(250)`	250	`False`
ErrorCausedByType	`DT_WSTR`	`nvarchar(250)`	250	`False`
ErrorCausedByreason	`DT_WSTR`	`nvarchar(2000)`	2000	`False`
Version	`DT_I4`	`int`		`False`
SequenceNo	`DT_I4`	`int`		`False`
PrimaryTerm	`DT_I4`	`int`		`False`
ShardsFailed	`DT_I4`	`int`		`False`
ShardsSuccessful	`DT_I4`	`int`		`False`
ShardsTotal	`DT_I4`	`int`		`False`
Took	`DT_I4`	`int`		`False`

If the column you are looking for is missing, consider customizing ElasticSearch Connector.

Input Columns

Label	Data Type (SSIS)	Data Type (SQL)	Length	Raw
_id	`DT_WSTR`	`nvarchar(150)`	150	`False`
[$parent.Pivot_Path$]	`DT_WSTR`	`nvarchar(4000)`	4000	`False`
[$parent.Pivot_Path$].lat	`DT_R8`	`float`		`False`
[$parent.Pivot_Path$].lon	`DT_R8`	`float`		`False`
[$parent.Pivot_Path$].type	`DT_WSTR`	`nvarchar(30)`	30	`False`
[$parent.Pivot_Path$].coordinates	`DT_TEXT`	`varchar(MAX)`		`True`

Required columns that you need to supply are bolded.

Examples

SSIS

Use ElasticSearch Connector in API Source component to read data or in API Destination component to read/write data:

Upsert rows into [Dynamic Table] table using API Destination

This Endpoint belongs to [Dynamic Table] table, therefore you cannot work with it directly. Use this table and table-operation pair instead:

ElasticSearch

[Dynamic Table]

Upsert

SSIS API Destination - Access table operation

ODBC application

Use these SQL queries in your ODBC application data source:

Upsert documents

-- We are out of SQL query examples for this Endpoint, sorry!
-- But will try to get some very very soon!

upsert_documents endpoint belongs to [Dynamic Table] , [Dynamic Table] table(s), and can therefore be used via those table(s).

SQL Server

Use these SQL queries in SQL Server after you create a data source in Data Gateway:

Upsert documents

DECLARE @MyQuery NVARCHAR(MAX) = '-- We are out of SQL query examples for this Endpoint, sorry!
-- But will try to get some very very soon!';

EXEC (@MyQuery) AT [LS_TO_ELASTICSEARCH_IN_GATEWAY];

upsert_documents endpoint belongs to [Dynamic Table] , [Dynamic Table] table(s), and can therefore be used via those table(s).