/
queries.go
40 lines (36 loc) · 1.48 KB
/
queries.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
// Copyright 2022 Red Hat, Inc
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package storage
func (storage OCPRecommendationsDBStorage) getReportUpsertQuery() string {
return `
INSERT INTO report(org_id, cluster, report, reported_at, last_checked_at, kafka_offset, gathered_at)
VALUES ($1, $2, $3, $4, $5, $6, $7)
ON CONFLICT (cluster)
DO UPDATE SET org_id = $1, report = $3, reported_at = $4, last_checked_at = $5, kafka_offset = $6, gathered_at = $7
`
}
func (storage OCPRecommendationsDBStorage) getReportInfoUpsertQuery() string {
return `
INSERT INTO report_info(org_id, cluster_id, version_info)
VALUES ($1, $2, $3)
ON CONFLICT (cluster_id)
DO UPDATE SET org_id = $1, version_info = $3
`
}
func (storage DVORecommendationsDBStorage) getReportInsertQuery() string {
return `
INSERT INTO dvo.dvo_report(org_id, cluster_id, namespace_id, namespace_name, report, recommendations, objects, reported_at, last_checked_at)
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
`
}