SQuiz/common
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update queries

Browse Source
This commit is contained in:
Pavel 2024-04-19 11:30:09 +03:00
parent 630c321e51
commit f1be15ae1b
1 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
dal/db_query/queries.sql
View File

@ -764,11 +764,11 @@ SELECT * FROM inserted_tags;
-- name: CheckPipelines :many -- name: CheckPipelines :many
WITH new_pipelines AS ( WITH new_pipelines AS (
SELECT (pipeline->>'AmoID')::INT, SELECT (pipeline->>'AmoID')::INT AS amoID,
(pipeline->>'AccountID')::INT, (pipeline->>'AccountID')::INT AS accountID,
COALESCE(pipeline->>'Name', '')::varchar(50), COALESCE(pipeline->>'Name', '')::varchar(50) AS name,
CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END, CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END AS isArchive,
CURRENT_TIMESTAMP CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($1::json) AS pipeline FROM json_array_elements($1::json) AS pipeline
), inserted_pipelines AS( ), inserted_pipelines AS(
INSERT INTO pipelines (amoID, accountID, name, isArchive, createdAt) INSERT INTO pipelines (amoID, accountID, name, isArchive, createdAt)
@ -776,7 +776,7 @@ WITH new_pipelines AS (
np.accountID, np.accountID,
np.name, np.name,
np.isArchive, np.isArchive,
CURRENT_TIMESTAMP np.createdAt
FROM new_pipelines np FROM new_pipelines np
ON CONFLICT (amoID, accountID) DO NOTHING ON CONFLICT (amoID, accountID) DO NOTHING
RETURNING * RETURNING *
@ -789,12 +789,12 @@ WITH user_data AS (
FROM users FROM users
WHERE users.AccountID = $1 WHERE users.AccountID = $1
), new_fields AS ( ), new_fields AS (
SELECT (field->>'AmoID')::INT, SELECT (field->>'AmoID')::INT AS amoID,
COALESCE(field->>'Code', '')::varchar(255), COALESCE(field->>'Code', '')::varchar(255) AS code,
COALESCE(field->>'Name', '')::varchar(50), COALESCE(field->>'Name', '')::varchar(50) AS name,
CAST(field->>'Entity' AS entitytype), CAST(field->>'Entity' AS entitytype) AS Entity,
COALESCE(field->>'Type', '')::varchar(50), COALESCE(field->>'Type', '')::varchar(50) AS type,
CURRENT_TIMESTAMP CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($2::json) AS field FROM json_array_elements($2::json) AS field
), inserted_fields AS( ), inserted_fields AS(
INSERT INTO fields (amoID, code, accountID, name, Entity, type, createdAt) INSERT INTO fields (amoID, code, accountID, name, Entity, type, createdAt)
@ -804,7 +804,7 @@ WITH user_data AS (
nf.name, nf.name,
nf.Entity, nf.Entity,
nf.type, nf.type,
CURRENT_TIMESTAMP nf.createdAt
FROM new_fields nf FROM new_fields nf
JOIN user_data ud ON true JOIN user_data ud ON true
ON CONFLICT (amoID, accountID, entity) DO NOTHING ON CONFLICT (amoID, accountID, entity) DO NOTHING
@ -815,12 +815,12 @@ SELECT * from inserted_fields;
-- name: CheckSteps :many -- name: CheckSteps :many
WITH new_steps AS ( WITH new_steps AS (
SELECT (step->>'AmoID')::INT, SELECT (step->>'AmoID')::INT AS amoID,
(step->>'PipelineID')::INT, (step->>'PipelineID')::INT AS pipelineID,
(step->>'AccountID')::INT, (step->>'AccountID')::INT AS accountID,
COALESCE(step->>'Name', '')::varchar(50), COALESCE(step->>'Name', '')::varchar(50) AS name,
COALESCE(step->>'Color', '')::varchar(50), COALESCE(step->>'Color', '')::varchar(50) AS color,
CURRENT_TIMESTAMP CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($1::json) AS step FROM json_array_elements($1::json) AS step
), inserted_steps AS ( ), inserted_steps AS (
INSERT INTO steps (amoID, pipelineID, accountID, name, color, createdAt) INSERT INTO steps (amoID, pipelineID, accountID, name, color, createdAt)
@ -829,7 +829,7 @@ WITH new_steps AS (
ns.accountID, ns.accountID,
ns.name, ns.name,
ns.color, ns.color,
CURRENT_TIMESTAMP ns.createdAt
FROM new_steps ns FROM new_steps ns
ON CONFLICT (amoID, accountID, PipelineID) DO NOTHING ON CONFLICT (amoID, accountID, PipelineID) DO NOTHING
RETURNING * RETURNING *