Configure Azure SQL Database in a copy activity

This article outlines how to use the copy activity in data pipeline to copy data from and to Azure SQL Database.

Supported configuration

For the configuration of each tab under copy activity, go to the following sections respectively.

General

Refer to the General settings guidance to configure the General settings tab.

Source

The following properties are supported for Azure SQL Database under the Source tab of a copy activity.

Screenshot showing the source tab and the list of properties.

The following properties are required:

  • Data store type: Select External.
  • Connection: Select an Azure SQL Database connection from the connection list. If the connection doesn't exist, then create a new Azure SQL Database connection by selecting New.
  • Connection type: Select Azure SQL Database.
  • Table: Select the table in your database from the drop-down list. Or check Edit to enter your table name manually.
  • Preview data: Select Preview data to preview the data in your table.

Under Advanced, you can specify the following fields:

  • Use query: You can choose Table, Query, or Stored procedure. The following list describes the configuration of each setting:

    • Table: Read data from the table you specified in Table if you select this button.

    • Query: Specify the custom SQL query to read data. An example is select * from MyTable. Or select the pencil icon to edit in code editor.

      Screenshot showing choosing query.

    • Stored procedure: Use the stored procedure that reads data from the source table. The last SQL statement must be a SELECT statement in the stored procedure.

      • Stored procedure name: Select the stored procedure or specify the stored procedure name manually when checking the Edit box to read data from the source table.

      • Stored procedure parameters: Specify values for stored procedure parameters. Allowed values are name or value pairs. The names and casing of parameters must match the names and casing of the stored procedure parameters.

        Screenshot showing stored procedure settings.

  • Query timeout (minutes): Specify the timeout for query command execution, default is 120 minutes. If a parameter is set for this property, allowed values are timespan, such as "02:00:00" (120 minutes).

    Screenshot showing Query timeout settings.

  • Isolation level: Specifies the transaction locking behavior for the SQL source. The allowed values are: None, ReadCommitted, ReadUncommitted, RepeatableRead, Serializable, or Snapshot. If not specified, None isolation level is used. Refer to IsolationLevel Enum for more details.

    Screenshot showing Isolation level settings.

  • Partition option: Specify the data partitioning options used to load data from Azure SQL Database. Allowed values are: None (default), Physical partitions of table, and Dynamic range. When a partition option is enabled (that is, not None), the degree of parallelism to concurrently load data from an Azure SQL Database is controlled by the parallel copy setting on the copy activity.

    Screenshot showing Partition option settings.

    • None: Choose this setting to not use a partition.

    • Physical partitions of table: When you use a physical partition, the partition column and mechanism are automatically determined based on your physical table definition.

    • Dynamic range: When you use a query with parallel enabled, the range partition parameter(?DfDynamicRangePartitionCondition) is needed. Sample query: SELECT * FROM <TableName> WHERE ?DfDynamicRangePartitionCondition.

      • Partition column name: Specify the name of the source column in integer or date/datetime type (int, smallint, bigint, date, smalldatetime, datetime, datetime2, or datetimeoffset) that's used by range partitioning for parallel copy. If not specified, the index or the primary key of the table is autodetected and used as the partition column.
      • Partition upper bound: Specify the maximum value of the partition column for partition range splitting. This value is used to decide the partition stride, not for filtering the rows in table. All rows in the table or query result are partitioned and copied.
      • Partition lower bound: Specify the minimum value of the partition column for partition range splitting. This value is used to decide the partition stride, not for filtering the rows in table. All rows in the table or query result are partitioned and copied.
  • Additional columns: Add more data columns to store source files' relative path or static value. Expression is supported for the latter. For more information, go to Add additional columns during copy.

Destination

The following properties are supported for Azure SQL Database under the Destination tab of a copy activity.

Screenshot showing Destination tab.

The following properties are required:

  • Data store type: Select External.
  • Connection: Select an Azure SQL Database connection from the connection list. If the connection doesn't exist, then create a new Azure SQL Database connection by selecting New.
  • Connection type: Select Azure SQL Database.
  • Table: Select the table in your database from the drop-down list. Or check Edit to enter your table name manually.
  • Preview data: Select Preview data to preview the data in your table.

Under Advanced, you can specify the following fields:

  • Write behavior: Defines the write behavior when the source is files from a file-based data store. You can choose Insert, Upsert or Stored procedure.

    Screenshot of write behavior tab.

    • Insert: Choose this option if your source data has inserts.

    • Upsert: Choose this option if your source data has both inserts and updates.

      • Use TempDB: Specify whether to use a global temporary table or physical table as the interim table for upsert. By default, the service uses global temporary table as the interim table and this checkbox is selected.

        Screenshot showing select Use TempDB.

      • Select user DB schema: When the Use TempDB checkbox isn't selected, specify the interim schema for creating an interim table if a physical table is used.

        Note

        You must have the permission for creating and deleting tables. By default, an interim table will share the same schema as a destination table.

        Screenshot showing not select Use TempDB.

      • Key columns: Specify the column names for unique row identification. Either a single key or a series of keys can be used. If not specified, the primary key is used.

    • Stored procedure: Use the stored procedure that defines how to apply source data into a target table. This stored procedure is invoked per batch.

      • Stored procedure name: Select the stored procedure or specify the stored procedure name manually when checking the Edit box to read data from the source table.

      • Stored procedure parameters: Specify values for stored procedure parameters. Allowed values are name or value pairs. The names and casing of parameters must match the names and casing of the stored procedure parameters.

        Screenshot showing stored procedure settings.

  • Bulk insert table lock: Choose Yes or No. Use this setting to improve copy performance during a bulk insert operation on a table with no index from multiple clients. For more information, go to BULK INSERT (Transact-SQL)

  • Table option: Specifies whether to automatically create the destination table if the table doesn't exist based on the source schema. Choose None or Auto create table. Auto table creation isn't supported when destination specifies a stored procedure.

  • Pre-copy script: Specify a script for Copy Activity to execute before writing data into a destination table in each run. You can use this property to clean up the preloaded data.

  • Write batch timeout: Specify the wait time for the batch insert operation to finish before it times out. The allowed value is timespan. The default value is "00:30:00" (30 minutes).

  • Write batch size: Specify the number of rows to insert into the SQL table per batch. The allowed value is integer (number of rows). By default, the service dynamically determines the appropriate batch size based on the row size.

  • Max concurrent connections: Specify the upper limit of concurrent connections established to the data store during the activity run. Specify a value only when you want to limit concurrent connections.

  • Disable performance metrics analytics: This setting is used to collect metrics, such as DTU, DWU, RU, and so on, for copy performance optimization and recommendations. If you're concerned with this behavior, select this checkbox.

Mapping

For the Mapping tab configuration, if you don't apply Azure SQL Database with auto create table as your destination, go to Mapping.

If you apply Azure SQL Database with auto create table as your destination, except the configuration in Mapping, you can edit the type for your destination columns. After selecting Import schemas, you can specify the column type in your destination.

For example, the type for ID column in source is int, and you can change it to float type when mapping to the destination column.

Screenshot of mapping destination column type.

Settings

For Settings tab configuration, go to Configure your other settings under settings tab.

Parallel copy from Azure SQL Database

The Azure SQL Database connector in copy activity provides built-in data partitioning to copy data in parallel. You can find data partitioning options on the Source tab of the copy activity.

When you enable partitioned copy, copy activity runs parallel queries against your Azure SQL Database source to load data by partitions. The parallel degree is controlled by the Degree of copy parallelism in the copy activity settings tab. For example, if you set Degree of copy parallelism to four, the service concurrently generates and runs four queries based on your specified partition option and settings, and each query retrieves a portion of data from your Azure SQL Database.

You are suggested to enable parallel copy with data partitioning especially when you load large amount of data from your Azure SQL Database. The following are suggested configurations for different scenarios. When copying data into file-based data store, it's recommended to write to a folder as multiple files (only specify folder name), in which case the performance is better than writing to a single file.

Scenario Suggested settings
Full load from large table, with physical partitions. Partition option: Physical partitions of table.

During execution, the service automatically detects the physical partitions, and copies data by partitions.

To check if your table has physical partition or not, you can refer to this query.
Full load from large table, without physical partitions, while with an integer or datetime column for data partitioning. Partition options: Dynamic range partition.
Partition column (optional): Specify the column used to partition data. If not specified, the index or primary key column is used.
Partition upper bound and partition lower bound (optional): Specify if you want to determine the partition stride. This is not for filtering the rows in table, all rows in the table will be partitioned and copied. If not specified, copy activities auto detect the values.

For example, if your partition column "ID" has values range from 1 to 100, and you set the lower bound as 20 and the upper bound as 80, with parallel copy as 4, the service retrieves data by 4 partitions - IDs in range <=20, [21, 50], [51, 80], and >=81, respectively.
Load a large amount of data by using a custom query, without physical partitions, while with an integer or date/datetime column for data partitioning. Partition options: Dynamic range partition.
Query: SELECT * FROM <TableName> WHERE ?DfDynamicRangePartitionCondition AND <your_additional_where_clause>.
Partition column: Specify the column used to partition data.
Partition upper bound and partition lower bound (optional): Specify if you want to determine the partition stride. This is not for filtering the rows in table, all rows in the query result will be partitioned and copied. If not specified, copy activity auto detect the value.

For example, if your partition column "ID" has values range from 1 to 100, and you set the lower bound as 20 and the upper bound as 80, with parallel copy as 4, the service retrieves data by 4 partitions- IDs in range <=20, [21, 50], [51, 80], and >=81, respectively.

Here are more sample queries for different scenarios:
• Query the whole table:
SELECT * FROM <TableName> WHERE ?DfDynamicRangePartitionCondition
• Query from a table with column selection and additional where-clause filters:
SELECT <column_list> FROM <TableName> WHERE ?DfDynamicRangePartitionCondition AND <your_additional_where_clause>
• Query with subqueries:
SELECT <column_list> FROM (<your_sub_query>) AS T WHERE ?DfDynamicRangePartitionCondition AND <your_additional_where_clause>
• Query with partition in subquery:
SELECT <column_list> FROM (SELECT <your_sub_query_column_list> FROM <TableName> WHERE ?DfDynamicRangePartitionCondition) AS T

Best practices to load data with partition option:

  • Choose distinctive column as partition column (like primary key or unique key) to avoid data skew.
  • If the table has built-in partition, use partition option Physical partitions of table to get better performance.

Sample query to check physical partition

SELECT DISTINCT s.name AS SchemaName, t.name AS TableName, pf.name AS PartitionFunctionName, c.name AS ColumnName, iif(pf.name is null, 'no', 'yes') AS HasPartition
FROM sys.tables AS t
LEFT JOIN sys.objects AS o ON t.object_id = o.object_id
LEFT JOIN sys.schemas AS s ON o.schema_id = s.schema_id
LEFT JOIN sys.indexes AS i ON t.object_id = i.object_id 
LEFT JOIN sys.index_columns AS ic ON ic.partition_ordinal > 0 AND ic.index_id = i.index_id AND ic.object_id = t.object_id 
LEFT JOIN sys.columns AS c ON c.object_id = ic.object_id AND c.column_id = ic.column_id 
LEFT JOIN sys.partition_schemes ps ON i.data_space_id = ps.data_space_id 
LEFT JOIN sys.partition_functions pf ON pf.function_id = ps.function_id 
WHERE s.name='[your schema]' AND t.name = '[your table name]'

If the table has physical partition, you would see "HasPartition" as "yes" like the following.

Sql query result.

Table summary

The following tables contain more information about the copy activity in Azure SQL Database.

Source

Name Description Value Required JSON script property
Data store type Your data store type. External Yes /
Connection Your connection to the source data store. <your connection> Yes connection
Connection type Your connection type. Select Azure SQL Database. Azure SQL Database Yes /
Table Your source data table. <name of your destination table> Yes schema
table
Use query The custom SQL query to read data. • None
• Query
• Stored procedure
No

• sqlReaderQuery
• sqlReaderStoredProcedureName, storedProcedureParameters
Query timeout The timeout for query command execution, default is 120 minutes. timespan No queryTimeout
Isolation level Specifies the transaction locking behavior for the SQL source. • None
• ReadCommitted
• ReadUncommitted
• RepeatableRead
• Serializable
• Snapshot
No isolationLevel
Partition option The data partitioning options used to load data from Azure SQL Database. • None
• Physical partitions of table
• Dynamic range
No partitionOption:
• PhysicalPartitionsOfTable
• DynamicRange
Additional columns Add more data columns to store source files' relative path or static value. Expression is supported for the latter. • Name
• Value
No additionalColumns:
• name
• value

Destination

Name Description Value Required JSON script property
Data store type Your data store type. External Yes /
Connection Your connection to the destination data store. <your connection > Yes connection
Connection type Your connection type. Select Azure SQL Database. Azure SQL Database Yes /
Table Your destination data table. <name of your destination table> Yes schema
table
Write behavior Defines the write behavior when the source is files from a file-based data store. • Insert
• Upsert
• Stored procedure
No writeBehavior:
• insert
• upsert
• sqlWriterStoredProcedureName, sqlWriterTableType, storedProcedureParameters
Bulk insert table lock Use this setting to improve copy performance during a bulk insert operation on a table with no index from multiple clients. Yes or No No sqlWriterUseTableLock:
true or false
Table option Specifies whether to automatically create the destination table if it doesn't exist based on the source schema. • None
• Auto create table
No tableOption:
• autoCreate
Pre-copy script A script for Copy Activity to execute before writing data into a destination table in each run. You can use this property to clean up the preloaded data. <pre-copy script>
(string)
No preCopyScript
Write batch timeout The wait time for the batch insert operation to finish before it times out. The allowed value is timespan. The default value is "00:30:00" (30 minutes). timespan No writeBatchTimeout
Write batch size The number of rows to insert into the SQL table per batch. By default, the service dynamically determines the appropriate batch size based on the row size. <number of rows>
(integer)
No writeBatchSize
Max concurrent connections The upper limit of concurrent connections established to the data store during the activity run. Specify a value only when you want to limit concurrent connections. <upper limit of concurrent connections>
(integer)
No maxConcurrentConnections
Disable performance metrics analytics This setting is used to collect metrics, such as DTU, DWU, RU, and so on, for copy performance optimization and recommendations. If you're concerned with this behavior, select this checkbox. select or unselect No disableMetricsCollection:
true or false