Configurer MySQL dans une activité de copie

Cet article explique comment utiliser l’activité de copie dans un pipeline pour copier des données depuis et vers MySQL.

Ce connecteur prend en charge MySQL version 5.5, 5.6, 5.7, 8.0, 8.1 et 8.2.

Configuration prise en charge

Pour la configuration de chaque onglet sous activité de copie, accédez respectivement aux sections suivantes.

General

Reportez-vous aux instructions relatives aux paramètres Général pour configurer l’onglet Paramètres Général .

Origine

Les propriétés suivantes sont prises en charge pour MySQL sous l’onglet Source d’une activité de copie.

Les propriétés suivantes sont requises :

  • Connexion : sélectionnez une connexion MySQL dans la liste des connexions. Si aucune connexion n’existe, créez une connexion MySQL en sélectionnant Nouveau.
  • Utiliser la requête : sélectionnez à partir d’une table ou d’une requête.
    • Si vous sélectionnez Table :

      • Table : spécifiez le nom de la table dans la base de données MySQL pour lire les données. Sélectionnez le tableau dans la liste déroulante.

        Capture d’écran montrant Utiliser la requête - Table.

    • Si vous sélectionnez Requête :

      • Requête : spécifiez la requête SQL personnalisée pour lire les données. Par exemple : SELECT * FROM MyTable.

        Capture d’écran montrant Utiliser la requête - Requête.

Sous Avancé, vous pouvez spécifier les champs suivants :

  • Colonnes supplémentaires: Ajoutez des colonnes de données supplémentaires pour stocker le chemin relatif ou la valeur statique des fichiers sources. L’expression est prise en charge pour ce dernier.

Destination (aperçu)

Les propriétés suivantes sont prises en charge pour MySQL sous l’onglet Destination d’une activité de copie.

Les propriétés suivantes sont requises :

  • Connexion : sélectionnez une connexion MySQL dans la liste des connexions. Si aucune connexion n’existe, créez une connexion MySQL.

  • Table : sélectionnez le nom de la table dans la base de données MySQL.

Sous Avancé, vous pouvez spécifier les champs suivants :

  • Script de pré-copie : spécifiez une requête SQL pour l’activité de copie à exécuter avant d’écrire des données dans MySQL dans chaque exécution. Vous pouvez utiliser cette propriété pour nettoyer les données préchargées.

  • Délai d’attente d'écriture par lot : spécifiez le temps d'attente de l’opération d’insertion par lot à terminer avant qu’elle n’expire. La valeur autorisée est un intervalle de temps. La valeur par défaut est 00:00:30.

  • Écrire taille de lot : spécifiez le nombre de lignes à insérer dans la table MySQL par lot. La valeur autorisée est entier (nombre de lignes). Un nouveau lot est créé lorsque le lot actuel atteint la taille du lot d’écriture. La valeur par défaut est 10000.

  • Nombre maximal de connexions simultanées : spécifiez la limite supérieure des connexions simultanées établies au magasin de données pendant l’exécution de l’activité. Spécifiez une valeur uniquement lorsque vous souhaitez limiter les connexions simultanées. La valeur autorisée est entière.

Cartographie

Pour la configuration de l’onglet Mappage, consultez Configurer vos mappages sous l’onglet Mappage.

Paramètres

Pour configurer l’onglet Paramètres , allez à Configurer vos autres paramètres sous l’onglet .

Mappage de type de données pour MySQL

Lors de la copie de données de MySQL, les mappages suivants sont utilisés entre les types de données MySQL et les types de données intermédiaires utilisés par le service en interne.

Type de données MySQL Type de données intermédiaire
BIGINT Int64
Type de données BIGINT UNSIGNED UInt64
BIT(1) UInt64
BIT(M), M>1 UInt64
BLOB Tableau d’octets
BOOL Booléen
(Si TreatTinyAsBoolean=false, il est mappé en tant que SByte. TreatTinyAsBoolean a la valeur true par défaut)
CHAR Chaîne
DATE DateTime
DateHeure DateTime
DÉCIMAL Decimal
DOUBLE Double
DOUBLE PRÉCISION Double
ENUM Chaîne
FLOAT Célibataire
INT Int32
INT NON SIGNÉ Int64
INTEGER Int32
ENTIER NON SIGNÉ UInt32
JSON Chaîne
LONG VARBINARY (un type de données utilisé dans les bases de données) Tableau d’octets
LONG VARCHAR Chaîne
LONGBLOB Tableau d’octets
LONGTEXT Chaîne
MEDIUMBLOB Tableau d’octets
MEDIUMINT Int32
MEDIUMINT NON SIGNÉ UInt32
MEDIUMTEXT Chaîne
NUMÉRIQUE Decimal
RÉEL Double
SET Chaîne
SMALLINT Int16
SMALLINT NON SIGNÉ UInt16
TEXTE Chaîne
TIME TimeSpan
TIMESTAMP DateTime
TINYBLOB Tableau d’octets
TINYINT SByte
TINYINT non signé Int16
TINYTEXT Chaîne
VARCHAR Chaîne
YEAR Integer

Lors de la copie de données vers MySQL, les mappages suivants sont utilisés à partir de types de données intermédiaires utilisés par le service en interne vers les types de données MySQL.

Type de données intermédiaire Type de données MySQL
Booléen BOOL, BOOLEAN
Byte TINYINT
Int16 SMALLINT, YEAR
UInt16 SMALLINT NON SIGNÉ
Int32 MEDIUMINT, INT, INTEGER
UInt32 INT UNSIGNED, MEDIUMINT UNSIGNED
Int64 BIGINT
UInt64 Type de données BIGINT UNSIGNED
Decimal DÉCIMAL
Célibataire FLOAT
Double DOUBLE
Chaîne VARCHAR, CHAR, VARSTRING, TEXT, TINYTEXT, MEDIUMTEXT, LONGTEXT, ENUM, SET, JSON
Tableau d’octets BINARY, VARBINARY, BLOB, TINYBLOB, MEDIUMBLOB, LONGBLOB, BIT, GEOMETRY
Date DATE
DateTime DATETIME, TIMESTAMP
TimeSpan TIME
GUID GUID (Identifiant Unique Global), UUID (Identifiant Universel Unique)

Résumé du tableau

Les tableaux suivants contiennent plus d’informations sur l’activité de copie dans MySQL.

Informations sur la source

Nom Descriptif Valeur Obligatoire Propriété de script JSON
Connexion Votre connexion au magasin de données source. < votre connexion MySQL > Oui connexion
Utiliser la requête La façon de lire des données à partir de MySQL. Appliquez la table pour lire les données de la table spécifiée ou appliquer la requête pour lire des données à l’aide de requêtes SQL. Tableau
Requête
Oui /
Table Nom de la table dans la base de données MySQL. < nom de table > Non tableName
Requête Utiliser la requête SQL personnalisée pour lire les données. Par exemple : SELECT * FROM MyTable. < Requêtes SQL > Non query
Colonnes supplémentaires Ajoutez des colonnes de données supplémentaires pour stocker le chemin d’accès relatif ou la valeur statique des fichiers sources. L’expression est prise en charge pour ce dernier. •Nom
•Valeur
Non colonnes supplémentaires :
• nom
•valeur

Informations de destination (préversion)

Nom Descriptif Valeur Obligatoire Propriété de script JSON
Connexion Votre connexion au magasin de données de destination. < votre connexion MySQL > Oui connexion
Table Nom de la table dans la base de données MySQL. < nom de table > Oui tableName
Script de pré-copie Requête SQL pour l’activité de copie à exécuter avant d’écrire des données dans MySQL dans chaque exécution. Vous pouvez utiliser cette propriété pour nettoyer les données préchargées. < votre script de pré-copie > Non preCopyScript
Comportement d’écriture Définit le comportement d’écriture. insérer (par défaut) Non writeBehavior
Écrire la taille du lot Nombre de lignes à insérer dans la table MySQL par lot. La valeur autorisée est entier (nombre de lignes). < Entier >
10000 (valeur par défaut)
Non writeBatchSize
Écrire le délai d’expiration du traitement par lots Temps d’attente pour que l’opération d’insertion par lot soit terminée avant d’expirer. La valeur autorisée est timespan. < Timespan >
00:00:30 (valeur par défaut)
Non writeBatchTimeout
Nombre maximal de connexions simultanées La limite maximale des connexions simultanées établies à l’entrepôt de données pendant l’exécution de l’activité. La valeur autorisée est entière. < Entier > Non maxConcurrentConnections