support new Cursor attribute that provides information on completed commands

Aberta

#388 aberta em 25/4/2024 1 comentário 1 reação 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade: 4/5
Tempo estimado: 3-5 dias
Facilidade para iniciantes: 35/100

Tipo de issue: Funcionalidade
Clareza: Razoavelmente clara
Status de atividade: Estagnada
Stack de tecnologia: python, sql
Domínio: databases

Direção de pesquisa

Comece com DatabricksConnectionManager.get_response() em dbt-databricks, onde a issue identifica a mensagem "OK" codificada diretamente, e inspecione o cursor do conector e o tratamento dos resultados dos comandos. Compare a saída desejada com as tags CommandComplete do PostgreSQL e os atributos do driver listados. Considera-se concluído quando os comandos concluídos expõem um atributo apropriado do cursor e get_response() informa a operação e a quantidade de linhas afetadas.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

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

Linguagem predominante: Python
Estrelas: 233
Forks: 152
Merge médio: 21h 5min
PRs com merge (30d): 10

Guia de contribuição

Abrir o guia de contribuição

Primeiros passos

Leia a issue inteira e depois o guia de contribuição do projeto.
Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
Faça um fork do repositório e trabalhe em uma branch.
Abra um pull request que referencie o número da issue.