diff pkg/imports/track.go @ 1168:930fdd8b474f

Track successfull imports in a separate table to be able to remove them later.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Wed, 14 Nov 2018 12:23:10 +0100
parents
children d753ce6cf588
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/pkg/imports/track.go	Wed Nov 14 12:23:10 2018 +0100
@@ -0,0 +1,30 @@
+// This is Free Software under GNU Affero General Public License v >= 3.0
+// without warranty, see README.md and license for details.
+//
+// SPDX-License-Identifier: AGPL-3.0-or-later
+// License-Filename: LICENSES/AGPL-3.0.txt
+//
+// Copyright (C) 2018 by via donau
+//   – Österreichische Wasserstraßen-Gesellschaft mbH
+// Software engineering by Intevation GmbH
+//
+// Author(s):
+//  * Sascha L. Teichmann <sascha.teichmann@intevation.de>
+
+package imports
+
+import (
+	"context"
+	"database/sql"
+)
+
+const (
+	trackImportSQL = `
+    INSERT INTO waterway.track_imports (import_id, relation, key)
+	VALUES ($1, $2::regclass, $3)`
+)
+
+func track(tx *sql.Tx, ctx context.Context, importID int64, relation string, key int64) error {
+	_, err := tx.ExecContext(ctx, trackImportSQL, importID, relation, key)
+	return err
+}