@latitude-data/bigquery-connector
Advanced tools
Comparing version 2.0.0 to 2.1.0
# @latitude-data/bigquery-connector | ||
## 2.1.0 | ||
### Minor Changes | ||
- 43179d6: Now query behaviour can be configured either in the source config file or the query themselves by adding a custom keyword. The first available option is `ttl`, that defines the cached lifetime of the query results in the server, before having to be refetched again. | ||
### Patch Changes | ||
- Updated dependencies [43179d6] | ||
- @latitude-data/base-connector@1.1.0 | ||
## 2.0.0 | ||
@@ -4,0 +15,0 @@ |
@@ -15,3 +15,3 @@ import { BaseConnector, CompiledQuery, ResolvedParam } from '@latitude-data/base-connector'; | ||
resolve(value: unknown, index: number): ResolvedParam; | ||
runQuery(query: CompiledQuery): Promise<QueryResult>; | ||
runQuery(compiledQuery: CompiledQuery): Promise<QueryResult>; | ||
private buildCredentials; | ||
@@ -18,0 +18,0 @@ private buildQueryParams; |
@@ -18,8 +18,8 @@ import { BigQuery } from '@google-cloud/bigquery'; | ||
} | ||
async runQuery(query) { | ||
async runQuery(compiledQuery) { | ||
const client = this.createClient(); | ||
try { | ||
const [job] = await client.createQueryJob({ | ||
query: query.sql, | ||
params: this.buildQueryParams(query.params), | ||
query: compiledQuery.sql, | ||
params: this.buildQueryParams(compiledQuery.resolvedParams), | ||
}); | ||
@@ -26,0 +26,0 @@ // Wait for the query to finish |
{ | ||
"name": "@latitude-data/bigquery-connector", | ||
"version": "2.0.0", | ||
"version": "2.1.0", | ||
"license": "LGPL", | ||
@@ -19,3 +19,3 @@ "description": "BigQuery connector for Latitude", | ||
"google-auth-library": "^9.6.3", | ||
"@latitude-data/base-connector": "^1.0.3", | ||
"@latitude-data/base-connector": "^1.1.0", | ||
"@latitude-data/query_result": "^0.2.0" | ||
@@ -22,0 +22,0 @@ }, |
@@ -38,3 +38,3 @@ import { BigQuery, BigQueryOptions } from '@google-cloud/bigquery' | ||
async runQuery(query: CompiledQuery): Promise<QueryResult> { | ||
async runQuery(compiledQuery: CompiledQuery): Promise<QueryResult> { | ||
const client = this.createClient() | ||
@@ -44,4 +44,4 @@ | ||
const [job] = await client.createQueryJob({ | ||
query: query.sql, | ||
params: this.buildQueryParams(query.params), | ||
query: compiledQuery.sql, | ||
params: this.buildQueryParams(compiledQuery.resolvedParams), | ||
}) | ||
@@ -48,0 +48,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
30609