Mercurial > gemma

comparison pkg/imports/agm.go @ 1995:59055c8301df

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Move import queue to its own database namespace Authorisation of the import queue has to be handled differently from the waterway-related data in the waterway schema. This is easier to handle, if both are in their own schema/namespace.
author Tom Gottfried <tom@intevation.de>
date Thu, 24 Jan 2019 12:56:31 +0100
parents 206b1dd31112
children 8a986d80e1c6
comparison
equal deleted inserted replaced
1994:a7c4005b723f 1995:59055c8301df
68 const ( 68 const (
69 // delete the old and keep the new measures. 69 // delete the old and keep the new measures.
70 agmStageDoneDeleteSQL = ` 70 agmStageDoneDeleteSQL = `
71 WITH staged AS ( 71 WITH staged AS (
72 SELECT key 72 SELECT key
73 FROM waterway.track_imports 73 FROM import.track_imports
74 WHERE import_id = $1 AND 74 WHERE import_id = $1 AND
75 relation = 'waterway.gauge_measurements'::regclass 75 relation = 'waterway.gauge_measurements'::regclass
76 ), 76 ),
77 to_delete AS ( 77 to_delete AS (
78 SELECT o.id AS id 78 SELECT o.id AS id
85 DELETE FROM waterway.gauge_measurements WHERE id IN (SELECT id from to_delete)` 85 DELETE FROM waterway.gauge_measurements WHERE id IN (SELECT id from to_delete)`
86 86
87 agmStageDoneSQL = ` 87 agmStageDoneSQL = `
88 UPDATE waterway.gauge_measurements SET staging_done = true 88 UPDATE waterway.gauge_measurements SET staging_done = true
89 WHERE id IN ( 89 WHERE id IN (
90 SELECT key FROM waterway.track_imports 90 SELECT key FROM import.track_imports
91 WHERE import_id = $1 AND 91 WHERE import_id = $1 AND
92 relation = 'waterway.gauge_measurements'::regclass)` 92 relation = 'waterway.gauge_measurements'::regclass)`
93 ) 93 )
94 94
95 func (agmJobCreator) StageDone( 95 func (agmJobCreator) StageDone(