jdbc (DataFrameReader)

Construit un DataFrame représentant la table de base de données accessible via l'URL JDBC url. Les partitions de la table sont récupérées en parallèle si column ou predicates est spécifié. Si column et predicates sont tous deux spécifiés, column prend le pas.

Syntaxe

jdbc(url, table, column=None, lowerBound=None, upperBound=None,
     numPartitions=None, predicates=None, properties=None)

parameter

parameter	Type	Description
url	str	L’URL JDBC du format jdbc:subprotocol:subname.
table	str	Le nom de la table dans la base de données externe.
column	str, facultatif	La colonne à utiliser pour le partitionnement (alias de l'option partitionColumn). Nécessite lowerBound, upperBound et numPartitions.
lowerBound	int ou str, facultatif	La valeur minimale de column pour le partitionnement. Requis lorsque column est spécifié.
upperBound	int ou str, facultatif	La valeur maximale de column pour le partitionnement. Requis lorsque column est spécifié.
numPartitions	int, facultatif	Le nombre de partitions. Requis lorsque column est spécifié.
predicates	liste, facultative	Une liste d'expressions de clause WHERE, chacune définissant une partition du DataFrame. Ignoré si column est spécifié.
properties	dictionnaire, facultatif	Arguments de connexion JDBC, incluant généralement 'user' et 'password'. Par exemple, {'user': 'SYSTEM', 'password': 'mypassword'}.

parameter	Type	Description
url	str	L’URL JDBC du format jdbc:subprotocol:subname.
table	str	Le nom de la table dans la base de données externe.
column	str, facultatif	La colonne à utiliser pour le partitionnement (alias de l'option partitionColumn). Nécessite lowerBound, upperBound et numPartitions.
lowerBound	int ou str, facultatif	La valeur minimale de column pour le partitionnement. Requis lorsque column est spécifié.
upperBound	int ou str, facultatif	La valeur maximale de column pour le partitionnement. Requis lorsque column est spécifié.
numPartitions	int, facultatif	Le nombre de partitions. Requis lorsque column est spécifié.
predicates	liste, facultative	Une liste d'expressions de clause WHERE, chacune définissant une partition du DataFrame. Ignoré si column est spécifié.
properties	dictionnaire, facultatif	Arguments de connexion JDBC, incluant généralement 'user' et 'password'. Par exemple, {'user': 'SYSTEM', 'password': 'mypassword'}.

Renvoie

DataFrame

Notes

Évitez de créer trop de partitions en parallèle sur un grand cluster, car cela peut entraîner le crash de systèmes de bases de données externes.