Realtime Compute for Apache Flink:Gérer les catalogs AnalyticDB for MySQL (ADB)

Informations générales

Limites

• Seul Realtime Compute for Apache Flink exécutant VVR 6.0.2 ou version ultérieure prend en charge les catalogs AnalyticDB for MySQL.

• Un catalog ne peut pas être modifié après sa création.

• Seules les tables de données peuvent faire l'objet de requêtes. La création, la modification ou la suppression de bases de données ou de tables est impossible.

• Les tables sont utilisables uniquement comme tables de dimension et tables de résultats, mais pas comme tables source.

• Les catalogs ne prennent pas en charge les connexions SSL. Pour établir une connexion SSL, définissez une table temporaire afin d'accéder à AnalyticDB for MySQL.

Créer un catalog AnalyticDB for MySQL

1. Pour créer un catalog AnalyticDB for MySQL, saisissez l'instruction dans l'éditeur Scripts.

   CREATE CATALOG <catalogName> WITH (
     'type' = 'adb3.0',
     'hostName' = '<hostname>',
     'port' = '<port>',
     'userName' = '<username>',
     'password' = '<password>',
     'defaultDatabase' = '<dbname>'
   );

   Paramètre	Type	Description	Obligatoire
   catalogName	String	Nom du catalog AnalyticDB for MySQL.	Oui
   type	String	Type du catalog. Valeur fixe : adb3.0.	Oui
   hostName	String	Adresse IP ou nom d'hôte de l'instance AnalyticDB for MySQL.	Oui
   port	Integer	Numéro de port de l'instance AnalyticDB for MySQL. Valeur par défaut : 3306.	Non
   userName	String	Nom d'utilisateur de l'instance AnalyticDB for MySQL.	Oui
   password	String	Mot de passe de l'instance AnalyticDB for MySQL.	Oui
   defaultDatabase	String	Nom de la base de données AnalyticDB for MySQL par défaut.	Oui

2. Sélectionnez l'instruction et cliquez sur Run à gauche du code.

   CREATE CATALOG <catalogName> WITH (
     'type' = 'adb3.0',
     'hostName' = '<hostname>',
     'port' = '<port>',
     'userName' = '<username>',
     'password' = '<password>',
     'defaultDatabase' = '<dbname>'
   );

Consulter un catalog AnalyticDB for MySQL

Après avoir configuré un catalog AnalyticDB for MySQL, suivez ces étapes pour consulter les métadonnées AnalyticDB for MySQL :

1. Accédez à la page Catalogs.

   1. Connectez-vous à la console Realtime Compute for Apache Flink.

   2. Dans la colonne Actions de l'espace de travail cible, cliquez sur Console.

   3. Dans le volet de navigation de gauche, cliquez sur Catalogs.

2. Sur la page Catalog List, consultez le Name et le Type.

   Remarque

   Pour afficher les bases de données et les tables d'un catalog, cliquez sur View.

Utiliser un catalog AnalyticDB for MySQL

• Utilisation d'une table d'un catalog AnalyticDB for MySQL comme table de dimension

  INSERT INTO ${other_sink_table}
  SELECT ...
  FROM ${other_source_table} AS e
  JOIN `${adb_mysql_catalog}`.`${db_name}`.`${table_name}` FOR SYSTEM_TIME AS OF e.proctime AS w
  ON e.id = w.id;

• Utilisation d'une table d'un catalog AnalyticDB for MySQL comme table de résultats

  INSERT INTO `${adb_mysql_catalog}`.`${db_name}`.`${table_name}`
  SELECT ...
  FROM ${other_source_table}

  Pour spécifier des paramètres WITH supplémentaires lors de l'utilisation d'une table issue d'un catalog AnalyticDB for MySQL, utilisez un SQL hint. Pour plus d'informations sur les paramètres, reportez-vous à la section Paramètres WITH. L'exemple suivant illustre l'ajout du paramètre replaceMode à une table de résultats AnalyticDB for MySQL 3,0.

  INSERT INTO `${adb_mysql_catalog}`.`${db_name}`.`${table_name}` /*+ OPTIONS('replaceMode'='true') */
  SELECT ...
  FROM ${other_source_table}

Supprimer un catalog AnalyticDB for MySQL

Supprimez un catalog AnalyticDB for MySQL via l'interface utilisateur ou une instruction SQL. Nous recommandons d'utiliser l'interface utilisateur.

Interface utilisateur

1. Accédez à la page Catalogs.

   1. Connectez-vous à la console Realtime Compute for Apache Flink.

   2. Dans la colonne Actions de l'espace de travail cible, cliquez sur Console.

   3. Dans le volet de navigation de gauche, cliquez sur Catalogs.

2. Sur la page Catalog List, localisez le catalog à supprimer et cliquez sur Delete dans la colonne Actions.

3. Dans la boîte de dialogue de confirmation, cliquez sur Delete.

4. Dans le volet Catalogs situé à gauche, vérifiez que le catalog a bien été supprimé.

Instruction SQL

1. Dans l'éditeur Scripts, saisissez l'instruction suivante.

   DROP CATALOG <catalogName>;

   Remplacez <catalogName> par le nom du catalog AnalyticDB for MySQL à supprimer.

2. Sélectionnez l'instruction, effectuez un clic droit, puis choisissez Run.

3. Dans le volet Catalogs situé à gauche, vérifiez que le catalog est bien supprimé.