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

update sqlc gen

Browse Source
This commit is contained in:
Pavel 2024-04-19 11:31:54 +03:00
parent f1be15ae1b
commit b6b37bac24
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/sqlcgen/queries.sql.go
View File

@ -173,12 +173,12 @@ WITH user_data AS (
FROM users
WHERE users.AccountID = $1
), new_fields AS (
SELECT (field->>'AmoID')::INT,
COALESCE(field->>'Code', '')::varchar(255),
COALESCE(field->>'Name', '')::varchar(50),
CAST(field->>'Entity' AS entitytype),
COALESCE(field->>'Type', '')::varchar(50),
CURRENT_TIMESTAMP
SELECT (field->>'AmoID')::INT AS amoID,
COALESCE(field->>'Code', '')::varchar(255) AS code,
COALESCE(field->>'Name', '')::varchar(50) AS name,
CAST(field->>'Entity' AS entitytype) AS Entity,
COALESCE(field->>'Type', '')::varchar(50) AS type,
CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($2::json) AS field
), inserted_fields AS(
INSERT INTO fields (amoID, code, accountID, name, Entity, type, createdAt)
@ -188,7 +188,7 @@ WITH user_data AS (
nf.name,
nf.Entity,
nf.type,
CURRENT_TIMESTAMP
nf.createdAt
FROM new_fields nf
JOIN user_data ud ON true
ON CONFLICT (amoID, accountID, entity) DO NOTHING
@ -249,11 +249,11 @@ func (q *Queries) CheckFields(ctx context.Context, arg CheckFieldsParams) ([]Che
const checkPipelines = `-- name: CheckPipelines :many
WITH new_pipelines AS (
SELECT (pipeline->>'AmoID')::INT,
(pipeline->>'AccountID')::INT,
COALESCE(pipeline->>'Name', '')::varchar(50),
CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END,
CURRENT_TIMESTAMP
SELECT (pipeline->>'AmoID')::INT AS amoID,
(pipeline->>'AccountID')::INT AS accountID,
COALESCE(pipeline->>'Name', '')::varchar(50) AS name,
CASE WHEN (pipeline->>'IsArchive') = 'true' THEN TRUE ELSE FALSE END AS isArchive,
CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($1::json) AS pipeline
), inserted_pipelines AS(
INSERT INTO pipelines (amoID, accountID, name, isArchive, createdAt)
@ -261,7 +261,7 @@ WITH new_pipelines AS (
np.accountID,
np.name,
np.isArchive,
CURRENT_TIMESTAMP
np.createdAt
FROM new_pipelines np
ON CONFLICT (amoID, accountID) DO NOTHING
RETURNING id, amoid, accountid, name, isarchive, deleted, createdat
@ -358,12 +358,12 @@ func (q *Queries) CheckResultsOwner(ctx context.Context, arg CheckResultsOwnerPa
const checkSteps = `-- name: CheckSteps :many
WITH new_steps AS (
SELECT (step->>'AmoID')::INT,
(step->>'PipelineID')::INT,
(step->>'AccountID')::INT,
COALESCE(step->>'Name', '')::varchar(50),
COALESCE(step->>'Color', '')::varchar(50),
CURRENT_TIMESTAMP
SELECT (step->>'AmoID')::INT AS amoID,
(step->>'PipelineID')::INT AS pipelineID,
(step->>'AccountID')::INT AS accountID,
COALESCE(step->>'Name', '')::varchar(50) AS name,
COALESCE(step->>'Color', '')::varchar(50) AS color,
CURRENT_TIMESTAMP AS createdAt
FROM json_array_elements($1::json) AS step
), inserted_steps AS (
INSERT INTO steps (amoID, pipelineID, accountID, name, color, createdAt)
@ -372,7 +372,7 @@ WITH new_steps AS (
ns.accountID,
ns.name,
ns.color,
CURRENT_TIMESTAMP
ns.createdAt
FROM new_steps ns
ON CONFLICT (amoID, accountID, PipelineID) DO NOTHING
RETURNING id, amoid, pipelineid, accountid, name, color, deleted, createdat