PTah
47 lines
1003 B
Go
47 lines
1003 B
Go
package store
|
|
|
|
import (
|
|
"database/sql"
|
|
_ "embed"
|
|
)
|
|
|
|
//go:embed sql/001_init.sql
|
|
var initSQL string
|
|
|
|
//go:embed sql/002_scan_interfaces.sql
|
|
var scanInterfacesSQL string
|
|
|
|
//go:embed sql/003_scan_port_devices.sql
|
|
var scanPortDevicesSQL string
|
|
|
|
//go:embed sql/004_scan_port_devices_bridge_port.sql
|
|
var scanPortDevicesBridgePortSQL string
|
|
|
|
//go:embed sql/005_scan_port_devices_vlan.sql
|
|
var scanPortDevicesVlanSQL string
|
|
|
|
//go:embed sql/006_scan_port_devices_mac_index.sql
|
|
var scanPortDevicesMacIndexSQL string
|
|
|
|
func RunMigrations(db *sql.DB) error {
|
|
if _, err := db.Exec(initSQL); err != nil {
|
|
return err
|
|
}
|
|
if _, err := db.Exec(scanInterfacesSQL); err != nil {
|
|
return err
|
|
}
|
|
if _, err := db.Exec(scanPortDevicesSQL); err != nil {
|
|
return err
|
|
}
|
|
if _, err := db.Exec(scanPortDevicesBridgePortSQL); err != nil {
|
|
return err
|
|
}
|
|
if _, err := db.Exec(scanPortDevicesVlanSQL); err != nil {
|
|
return err
|
|
}
|
|
if _, err := db.Exec(scanPortDevicesMacIndexSQL); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|