mig_0003_populate_event_tables.go

Copyright 2020, 2021, 2022, 2023 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
 
main

Definition of up and down steps for migration #0003

Generated documentation is available at: https://pkg.go.dev/github.com/RedHatInsights/ccx-notification-writer/

Documentation in literate-programming-style is available at: https://redhatinsights.github.io/ccx-notification-writer/packages/mig0003populateeventtables.html

 


import
 
(

	
"database/sql"


	
mig
 
"github.com/RedHatInsights/insights-operator-utils/migrations"

	
types
 
"github.com/RedHatInsights/insights-results-types"

	
"github.com/rs/zerolog/log"


)

mig0003PopulateEventTables migration add all existing event targets into event_targets table. Currently Notification Backend and ServiceLog targets exist and will be inserted to the table.

Also reported table content is changed by this migration: all existing records are updated to contain foreign key to event_target == notification backend.

 
var
 
mig0003PopulateEventTables
 
=
 
mig
.
Migration
{

up step: migrate database to version #0003

 
	
StepUp
:
 
func
(
tx
 
*
sql
.
Tx
,
 
_
 
types
.
DBDriver
)
 
error
 
{

		
log
.
Debug
(
)
.
Msg
(
"Executing mig0003PopulateEventTables stepUp function"
)

		
query
 
:=
 
`
 			INSERT INTO event_targets (id, name, metainfo) 
 				VALUES (1, 'notifications backend', 'the target of the report is the ccx notification service back end'),
 				       (2, 'service log', 'the target of the report is the ServiceLog')`

		
result
,
 
err
 
:=
 
executeQuery
(
tx
,
 
query
)

		
if
 
err
 
==
 
nil
 
{

			
rows
,
 
_
 
:=
 
result
.
RowsAffected
(
)

			
log
.
Debug
(
)
.
Int64
(
rowsInsertedMessage
,
 
rows
)
.
Msg
(
"Table event_targets altered successfully"
)

		
}

		
return
 
err

	
}
,

up down: migrate database to version #0002

 
	
StepDown
:
 
func
(
tx
 
*
sql
.
Tx
,
 
_
 
types
.
DBDriver
)
 
error
 
{

		
log
.
Debug
(
)
.
Msg
(
"Executing mig0003PopulateEventTables stepDown function"
)

		
query
 
:=
 
"DELETE FROM event_targets"

		
result
,
 
err
 
:=
 
executeQuery
(
tx
,
 
query
)

		
if
 
err
 
==
 
nil
 
{

			
rows
,
 
_
 
:=
 
result
.
RowsAffected
(
)

			
log
.
Debug
(
)
.
Int64
(
rowsDeletedMessage
,
 
rows
)
.
Msg
(
"Table event_targets cleaned up successfully"
)

		
}

		
return
 
err

	
}
,


}