ApsaraDB for SelectDB:Sources de données JDBC

Syntaxe

CREATE CATALOG <catalog_name>
PROPERTIES ("key"="value", ...)

Paramètres

Chemin du package de pilotes

Le paramètre driver_url accepte deux formats :

• Nom de fichier — par exemple, mysql-connector-java-8.0.25.jar. SelectDB recherche le fichier dans le répertoire local jdbc_drivers/. Les quatre packages de pilotes suivants sont préinstallés :

  • mysql-connector-java-8.0.25.jar

  • postgresql-42.5.1.jar

  • mssql-jdbc-11.2.3.jre8.jar

  • ojdbc8.jar

• URL HTTP — par exemple, https://doris-community-test-1308700295.cos.ap-hongkong.myqcloud.com/jdbc_driver/mysql-connector-java-8.0.25.jar. SelectDB télécharge le fichier depuis cette URL. Seuls les services HTTP sans authentification sont pris en charge.

Synchronisation des noms en minuscules

Lorsque lower_case_table_names=true, SelectDB maintient un mappage entre les noms en minuscules et les noms réels. Vous pouvez ainsi interroger les bases de données et les tables en utilisant des noms en minuscules, quelle que soit leur casse d'origine.

Comportement selon la version :

• SelectDB 2.X — Applicable uniquement à Oracle. Tous les noms de bases de données et de tables sont convertis en majuscules avant l'envoi de la requête à Oracle. Par exemple, si vous définissez lower_case_table_names=true et qu'Oracle contient une table nommée TEST dans le schéma TEST, vous pouvez l'interroger avec SELECT * FROM oracle_catalog.test.test. SelectDB convertit automatiquement test.test en TEST.TEST.

• SelectDB 3.X et versions ultérieures — Applicable à toutes les bases de données. Les noms sont convertis vers leur casse réelle avant l'exécution de la requête. Après une mise à niveau depuis une version antérieure, exécutez REFRESH <catalog_name> pour appliquer ce changement.

Contraintes :

• Si deux noms de bases de données ou de tables diffèrent uniquement par la casse (par exemple, SelectDB et selectdb), SelectDB ne peut pas les interroger en raison de l'ambiguïté.

• Si le paramètre frontend (FE) lower_case_table_names est défini à 1 ou 2, définissez le paramètre lower_case_table_names du Catalog JDBC à true. Si le paramètre FE est 0, vous pouvez le définir à true ou false (valeur par défaut : false).

Synchroniser des bases de données spécifiques

Combinez only_specified_database, include_database_list et exclude_database_list pour limiter les bases de données synchronisées par SelectDB.

Lors d'une connexion via JDBC, vous pouvez également présélectionner une base de données directement dans la jdbc_url — par exemple, en spécifiant le nom de la base de données dans l'URL MySQL, ou en utilisant currentSchema dans l'URL PostgreSQL.

Lors de l'utilisation de include_database_list ou exclude_database_list avec Oracle, utilisez ojdbc8.jar ou une version ultérieure.

SELECT * FROM mysql_catalog.mysql_database.mysql_table WHERE k1 > 1000 AND k3 = 'term';

Pushdown des prédicats

SelectDB transfère les conditions de la clause WHERE vers la source de données externe afin de filtrer les données à la source. Cela réduit les transferts inutiles et améliore les performances des requêtes.

Lorsque enable_func_pushdown=true (variable de session), SelectDB transfère également les fonctions de la clause WHERE vers la source de données externe. Cette fonctionnalité est prise en charge uniquement pour MySQL. Les fonctions suivantes sont exclues du pushdown : DATE_TRUNC et MONEY_FORMAT. Pour désactiver le pushdown des fonctions, définissez enable_func_pushdown=false. Exécutez EXPLAIN pour vérifier quelles conditions sont transférées.

Limite du nombre de lignes

Si une requête contient le mot-clé LIMIT, SelectDB le traduit dans la syntaxe appropriée pour la base de données cible.

-- Write a single row
INSERT INTO mysql_catalog.mysql_database.mysql_table VALUES(1, "doris");

-- Write query results
INSERT INTO mysql_catalog.mysql_database.mysql_table SELECT * FROM table;

Transactions

Les données provenant de SelectDB sont écrites par lots dans un Catalog JDBC. Si une importation est interrompue, les données précédemment écrites peuvent nécessiter une annulation (rollback). Pour gérer cela, le Catalog JDBC prend en charge les transactions pour les écritures de données. Pour activer la prise en charge des transactions, définissez la variable de session enable_odbc_transcation :

SET enable_odbc_transcation = TRUE;

Les transactions garantissent l'atomicité des écritures vers les tables externes JDBC, mais réduisent les performances d'écriture. Activez les transactions uniquement lorsque la cohérence des données est critique.