Microsoft Azure Synapse Analytics
This page shows how to set up and use the Microsoft Azure Synapse Analytics destination. The Microsoft Azure Synapse Analytics destination loads data to an Azure Synapse SQL Pool.
Requirements
To use the Azure Synapse Analytics SQL Pool destination, you need:
- An Azure Analytics SQL database.
- Azure portal firewall rules that grant access for the IP addresses Xtract Universal is running on.
Create a new Microsoft Azure Synapse Analytics Destination
Follow the steps below to add a new Microsoft Azure Synapse Analytics destination to Xtract Universal:
- In the main window of the Designer, navigate to Server > Manage Destinations. The window “Manage Destinations” opens.
- Click [Add] to create a new destination. The window "Destination Details" opens.
- Enter a Name for the destination.
- Select the destination type Microsoft Azure Synapse Analytics from the drop-down menu. A list of connection details opens.
- Fill out the destination details to connect to the destination.
- Click [OK] to confirm your input.
The destination can now be assigned to extractions.
Destination Details
The destination details define the connection to the destination.
Server Name
Enter the name of the Azure Servers in the following format:
[servername].database.windows.net
User Name
Enter the user name.
Password
Enter the password.
Database Name
Enter the name of the Azure Synapse SQl Pool.
Test Connection
Check the database connection.
Assign the Microsoft Azure Synapse Analytics Destination to an Extraction
Extractions write data to their assigned destination. Follow the steps below to assign a destination to an extraction:
- In the main window of the Designer, select an extraction.
- Click [ Destination]. The window “Destination Settings” opens.
- In the “Destination Settings” window, select a destination from the dropdown list.
- Optional: edit the destination settings.
- Click [OK] to confirm your input.
When running the extraction, the extracted SAP data is now written to the destination.
Destination Settings
The destination settings only affect the extraction that the destination is assigned to. To open the destination settings, select an extraction in the main window of the Designer and click [ Destination]. The window "Destination Settings" opens.
File Name
Determines the name of the target table. The following options are available:
Option | Description |
---|---|
Same as name of SAP object | Copy the name of the SAP object. |
Same as name of extraction | Adopt the name of the extraction. |
Fully qualified extraction name | Adopt the name of the extraction, including the path of the extraction. This option avoids conflicts, when the extraction names are not unique. Use ta Fully qualified extraction name when the same extraction name is used in multiple extraction groups. |
Custom | Define a name of your choice. |
Append timestamp
Add the timestamp in the UTC format (_YYYY_MM_DD_hh_mm_ss_fff) to the file name of the extraction
Use Script Expressions as Dynamic File Names
Script expressions can be used to generate a dynamic file name. This allows generating file names that are composed of an extraction's properties, e.g. extraction name, SAP source object. This scenario supports script expressions based on .NET and the following XU-specific custom script expressions:
Input | Description |
---|---|
#{Source.Name}# | Name of the extraction's SAP source. |
#{Extraction.ExtractionName}# | Name of the extraction. |
#{Extraction.Type}# | Extraction type (Table, ODP, BAPI, etc.). |
#{Extraction.SapObjectName}# | Name of the SAP object the extraction is extracting data from. |
#{Extraction.Timestamp}# | Timestamp of the extraction. |
#{Extraction.SapObjectName.TrimStart("/".ToCharArray())}# | Removes the first slash '/' of an SAP object. Example: /BIO/TMATERIAL to BIO/TMATERIAL - prevents creating an empty folder in a file path. |
#{Extraction.SapObjectName.Replace('/', '_')}# | Replaces all slashes '/' of an SAP object. Example /BIO/TMATERIAL to _BIO_TMATERIAL - prevents splitting the SAP object name by folders in a file path. |
#{Extraction.Fields["FISCPER"].RangeSelections[0].LowerValue}# | Lower value of the range selection. |
#{Extraction.Fields["FISCPER"].RangeSelections[0].UpperValue}# | Upper value of the range selection. |
#{Extraction.Context}# | Only for ODP extractions: returns the context of the ODP object (SAPI, ABAP_CDS, etc). |
#{Extraction.Fields["[NameSelectionFiels]"].Selections[0].Value}# | Only for ODP extractions: returns the input value of a defined selection / filter. |
#{Odp.UpdateMode}# | Only for ODP extractions: returns the update mode (Delta, Full, Repeat) of the extraction. |
#{TableExtraction.WhereClause}# | Only for Table extractions: returns the WHERE clause of the extraction. |
Column Name Style
Defines the style of the column name. Following options are available:
Option | Description |
---|---|
Code | The SAP technical column name is used as column name in the destination e.g., MAKTX. |
PrefixedCode | The SAP technical column name is prefixed by SAP object name and the tilde character e.g., MAKT~MAKTX |
CodeAndText | The SAP technical column name and the SAP description separated by an underscore are used as column name in the destination e.g., MAKTX_Material Description (Short Text). |
TextAndCode | The SAP description and the SAP technical column name description separated by an underscore are used as column name in the destination e.g., Material Description (Short Text)_MAKTX. |
Text | The SAP description is used as column name in the destination e.g., Material Description (Short Text). |
Convert dates
Converts the character-type SAP date (YYYYMMDD, e.g., 19900101) to a special date format (YYYY-MM-DD, e.g., 1990-01-01). Target data uses a real date data-type and not the string data-type to store dates.
Year 0
Converts the SAP date 00000000 to the entered value.
Year 9999
Converts the SAP date 9999XXXX to the entered value.
Invalid values
If an SAP date cannot be converted to a valid date format, the invalid date is converted to the entered value. NULL is supported as a value. When converting the SAP date the two special cases 00000000 and 9999XXXX are checked first.
Preparation
Defines the action on the target database before the data is inserted into the target table.
Option | Description |
---|---|
Drop & Create | Remove table if available and create new table (default). |
Truncate Or Create | Empty table if available, otherwise create. |
Create If Not Exists | Create table if not available. |
Prepare Merge | Prepares the merge process and creates e.g. a temporary staging table, see Merge Data. |
None | No action. |
Custom SQL | Here you can define your own script, see Custom SQL Statements. |
To only create the table in the first step and not insert any data, you have two options:
- Copy the SQL statement and execute it directly on the target data database.
- Select the None option for Row Processing and execute the extraction.
Once the table is created, it is up to you to change the table definition, e.g., by creating corresponding key fields and indexes or additional fields.
Row Processing
Defines how the data is inserted into the target table.
Option | Description |
---|---|
Insert | Insert records (default). |
Fill merge staging table | Insert records into the staging table. |
None | No action. |
Custom SQL | Define your own script, see Custom SQL Statements. |
Finalization
Defines the action on the target database after the data has been successfully inserted into the target table.
Option | Description |
---|---|
Finalize Merge | Closes the merge process and deletes the temporary staging table, for example. |
None | No action (default). |
Custom SQL | Define your own script, see Custom SQL Statements. |
Debugging
Warning
Performance decrease!
The performance decreases when bulk insert is disabled. Disable the bulk insert only when necessary, e.g., upon request of the support team.
By activating the checkbox Disable bulk operations, the default bulk insert is deactivated when writing to a database.
This option enables detailed error analysis, if certain data rows cannot be persisted on the database. Possible causes for the incorrect behavior are incorrect values with regard to the stored data type.
Debugging needs to be deactivated again, after the successful error analysis, otherwise the performance of the database write processes remains low.
Note
Bulk operations are not supported when using Custom SQL statements, e.g., in Row Processing. Bulk operations lead to performance decrease. To increase performance when using Custom SQL statements, it is recommended to perform the custom processing in the Finalization step.
Transaction style
Note
The available options for Transaction Style vary depending on the destination.
RowProcessingOnly
Only Row Processing is executed in a transaction. Preparation and Finalization without an explicit transaction (implicit commits).
- Advantage: DDL in 'Preparation and Finalization* for DBMS that do not allow DDL in explicit transactions (e.g. AzureDWH)
- Disadvantage: no rollback of Preparation/Finalization.
No Transaction
No explicit transactions.
- Advantage: no transaction management required by DBMS (locking, DB transaction log, etc.). This means no locking and possible performance advantages.
- Disadvantage: no rollback
Merge Data
The following example depicts the update of the existing data records in a database by running an extraction to merge data. In this case, merging means changing a value of a field or inserting a new data row or updating an existing record in SAP.
With a merge command, the updated value is written to the destination database table. The merge command ensures delta processing: new records are inserted into the database and / or existing records are updated.
Tip
Alternatively to merging, the data can be also updated by means of full load. The full load method is less efficient.
Prerequisites
You need a table with existing SAP data, in which new data can be merged.
Ideally, the table with existing data is created in the initial load with the corresponding Preparation option and filled with data with the Row Processing option Insert.
After the table is created, open SAP and change a field value in the SAP table that is used for the data merge.
Warning
Faulty merge.
Merge commands require a primary key. If no primary key is set, the merge command runs into an error. Create an appropriate primary key in the General Settings of the extraction type to execute the merge command.
Merge Command
The merge process is performed using a staging table and takes place in three steps:
- A temporary table is created.
- The data is inserted in the temporary table.
- The temporary table is merged with the target table and then the temporary table is deleted.
Follow the steps below to set up the merge process in Xtract Universal:
- In the main window of the Xtract Universal Designer, select an extraction from the list of extractions.
- Click [ Destination]. The window "Destination Settings" opens.
- Make sure to assign Microsoft Azure Synapse Analytics destination to the extraction.
- Apply the following destination settings:
- Click [OK] and run the extraction.
More information about the updated fields can be found in the SQL statement.
It is possible to edit the SQL statement if necessary, e.g., to exclude certain columns from the update.
Fields that do not appear in the SQL statement are not affected by changes.
Custom SQL Statements
The Microsoft Azure Synapse Analytics destination supports the use of custom SQl statements in the staging steps of the database. Follow the steps below to create custom SQL statements in the Microsoft Azure Synapse Analytics destination:
- In the main window of the Xtract Universal Designer, select an extraction from the list of extractions..
- Click [ Destination], the window "Destination Settings" opens.
- Make sure to assign the Microsoft Azure Synapse Analytics destination to the extraction.
-
Select the option Custom SQL from the drop-down list in one of the following sections:
-
Click [Edit SQL] . The window "Edit SQL" opens.
- Enter your custom SQL statement and click [OK] to confirm your input.
Use Templates
Existing SQL commands can be used as templates.
You can write your user-defined SQL expressions and adapt the loading of the data to your needs. You can additionally execute stored procedures that exist in the database. To do so, use the SQL templates provided in the following staging steps:
- Preparation, e.g., in Drop & Create or Create if Not Exists
- Row Processing, e.g., in Insert or Merge
- Finalization
Follow the steps below to generate a Custom SQL command from a template:
- In one of the staging steps, select the Custom SQL option from the drop-down list .
- Click [Edit SQL] . The dialogue "Edit SQL" opens.
- Navigate to the drop-down menu and select an existing command .
- Click [Generate Statement]. A new statement is generated.
- Click [Copy] to copy the statement to the clipboard.
- Click [OK] to confirm your input.
Check out the Microsoft SQL Server example for details on predefined expressions.
Note
The custom SQL code is used for SQL Server destinations. A syntactic adaptation of the code is necessary to use the custom SQL code for other database destinations.
Use Script Expressions
You can use script expressions for Custom SQL commands. The following Xtract Universal specific custom script expressions are supported:
Input | Description |
---|---|
#{Extraction.ExtractionName}# | Name of the extraction. If the extraction is part of an extraction group, the name of the extraction group is included in the extraction name, e.g, group,extraction , Tables,KNA1 . |
#{Extraction.TableName }# | Name of the database table extracted data is written to. |
#{Extraction.RowsCount }# | Count of the extracted rows. |
#{Extraction.RunState}# | Status of the extraction (Running, FinishedNoErrors, FinishedErrors). |
#{(int)Extraction.RunState}# | Status of the extraction as number (2 = Running, 3 = FinishedNoErrors, 4 = FinishedErrors). |
#{Extraction.Timestamp}# | Timestamp of the extraction. |
For more information, see Script Expressions.
Example: Verify the existence of a table in a database using 'ExistsTable' | |
---|---|
Create a Status Overview
The table "ExtractionStatistics" provides an overview and status of the executed Xtract Universal extractions. To create the "ExtractionStatistics" table, create an SQL table according to the following example:
Create ExtractionStatistics | |
---|---|
The ExtractionStatistics table is filled in the Finalization process step, using the following SQL statement:
Fill ExtractionStatistics | |
---|---|