Skip to content

Commit

Permalink
correct column name
Browse files Browse the repository at this point in the history
  • Loading branch information
@philipperolet
philipperolet committed Dec 20, 2024
1 parent a194bdc commit 35ef12d
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions core/src/stores/postgres.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1307,7 +1307,7 @@ impl Store for PostgresStore {

let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -1830,7 +1830,7 @@ impl Store for PostgresStore {

let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -1947,7 +1947,7 @@ impl Store for PostgresStore {

let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -2602,7 +2602,7 @@ impl Store for PostgresStore {
let tx = c.transaction().await?;
let r = tx
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -2857,7 +2857,7 @@ impl Store for PostgresStore {
// Get the data source row id.
let stmt = c
.prepare(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
)
.await?;
let r = c.query(&stmt, &[&project_id, &data_source_id]).await?;
Expand Down Expand Up @@ -2979,7 +2979,7 @@ impl Store for PostgresStore {
// get the data source row id
let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -3187,7 +3187,7 @@ impl Store for PostgresStore {
let tx = c.transaction().await?;
let r = tx
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -3307,7 +3307,7 @@ impl Store for PostgresStore {
// get the data source row id
let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down Expand Up @@ -3469,7 +3469,7 @@ impl Store for PostgresStore {

let r = c
.query(
"SELECT id, data_source_internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
"select id, internal_id FROM data_sources WHERE project = $1 AND data_source_id = $2 LIMIT 1",
&[&project_id, &data_source_id],
)
.await?;
Expand Down

0 comments on commit 35ef12d

Please sign in to comment.