support new Cursor attribute that provides information on completed commands

Ouverte

#388 ouverte le 25/4/2024 1 commentaire 1 réaction 0 personnes assignées Voir sur GitHub

Personne n'a encore pris cette issue.

Évaluation

Difficulté: 4/5
Temps estimé: 3-5 jours
Accessibilité débutants: 35/100

Type d'issue: Fonctionnalité
Clarté: Plutôt claire
Activité: À l'abandon
Stack technique: python, sql
Domaine: databases

Piste de recherche

Commencez par DatabricksConnectionManager.get_response() dans dbt-databricks, où l’issue identifie le message "OK" codé en dur, et examinez le curseur du connecteur ainsi que la gestion des résultats des commandes. Comparez la sortie attendue avec les balises CommandComplete de PostgreSQL et les attributs du pilote listés. Le travail est terminé lorsque les commandes exécutées exposent un attribut de curseur approprié et que get_response() indique l’opération ainsi que le nombre de lignes affectées.

Rédigé par le modèle d'indexation à partir du texte de l'issue.

Description

enhancement

While a Cursor attribute providing SQL State Code is not officially a part of PEP 249: Python DB API 2.0 spec, it's a common enough convention and would greatly enhance the user experience of dbt-databricks users (👀 @benc-db)

Many database drivers provide this as a Cursor attribute, dbt was able to depend on these drivers to provide it for a ConnectionManager.get_response() method, which reports to users after successful queries the kind of operation performed (SELECT, INSERT, CREATE) and the numbers of rows affected.

However, this is not fully supported today in dbt-databrick, see DatabricksConnectionManager.get_response() where message is hardcoded as "OK" instead of returning more information.

Support for SQL state amongst popular analytics database drivers

Driver	`Cursor` attribute (docs)
psycopg2	`statusmessage`
`snowflake-connector-python`	`sqlstate`

Ideal implementation

Follow Postgres's CommandComplete message

Command	Tag	`rows` indicates the number of rows
`INSERT`	`INSERT 0 rows`	inserted
`DELETE`	`DELETE rows`	deleted
`UPDATE`	`UPDATE rows`	updated
`MERGE`	`MERGE rows`	inserted, updated, or deleted
`SELECT` / `CREATE TABLE AS`	`SELECT rows`	retrieved
`MOVE`	`MOVE rows`	ursor's position has been changed by
`FETCH`	`FETCH rows`	that have been retrieved from the cursor
`COPY`	`COPY rows`	copied, only in `PostgreSQL` 8.2 and later

Langage dominant: Python
Étoiles: 233
Forks: 152
Merge moyen: 21 h 5 min
PR mergées (30 j): 10

Guide de contribution

Ouvrir le guide de contribution

Par où commencer

Lisez l'issue en entier, puis le guide de contribution du projet.
Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
Forkez le dépôt et travaillez sur une branche.
Ouvrez une pull request qui référence le numéro de l'issue.