nathan/vctp2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

more db fixes
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Nathan Coad
2026-02-11 10:20:20 +11:00
parent f4d5577de1
commit a0556e3ac8
2 changed files with 172 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

107
db/queries/query.sql
View File

@@ -1,33 +1,65 @@
-- name: ListInventory :many
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
ORDER BY "Name";
-- name: GetReportInventory :many
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
ORDER BY "CreationTime";
-- name: GetInventoryByName :many
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "Name" = ?;
-- name: GetInventoryByVcenter :many
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "Vcenter" = ?;
-- name: GetInventoryVmId :one
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "VmId" = sqlc.arg('vmId') AND "Datacenter" = sqlc.arg('datacenterName');
-- name: GetInventoryVmUuid :one
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "VmUuid" = sqlc.arg('vmUuid') AND "Datacenter" = sqlc.arg('datacenterName');
-- name: GetInventoryVcUrl :many
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "Vcenter" = sqlc.arg('vc');
-- name: GetInventoryEventId :one
SELECT * FROM inventory
SELECT
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid"
FROM inventory
WHERE "CloudId" = ? LIMIT 1;
-- name: CreateInventory :one
@@ -36,7 +68,10 @@ INSERT INTO inventory (
) VALUES(
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
)
RETURNING *;
RETURNING
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid";
-- name: InventoryUpdate :exec
UPDATE inventory
@@ -51,17 +86,26 @@ WHERE "VmId" = sqlc.arg('vmId') AND "Datacenter" = sqlc.arg('datacenterName');
-- name: InventoryCleanup :exec
DELETE FROM inventory
WHERE "VmId" = sqlc.arg('vmId') AND "Datacenter" = sqlc.arg('datacenterName')
RETURNING *;
RETURNING
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid";
-- name: InventoryCleanupVcenter :exec
DELETE FROM inventory
WHERE "Vcenter" = sqlc.arg('vc')
RETURNING *;
RETURNING
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid";
-- name: InventoryCleanupTemplates :exec
DELETE FROM inventory
WHERE "IsTemplate" = 'TRUE'
RETURNING *;
RETURNING
"Iid", "Name", "Vcenter", "VmId", "EventKey", "CloudId", "CreationTime", "DeletionTime",
"ResourcePool", "Datacenter", "Cluster", "Folder", "ProvisionedDisk", "InitialVcpus",
"InitialRam", "IsTemplate", "PoweredOn", "SrmPlaceholder", "VmUuid";
-- name: CreateUpdate :one
INSERT INTO updates (
@@ -69,25 +113,37 @@ INSERT INTO updates (
) VALUES(
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
)
RETURNING *;
RETURNING
"Uid", "InventoryId", "UpdateTime", "UpdateType", "NewVcpus", "NewRam", "NewResourcePool",
"EventKey", "EventId", "NewProvisionedDisk", "UserName", "PlaceholderChange", "Name", "RawChangeString";
-- name: GetReportUpdates :many
SELECT * FROM updates
SELECT
"Uid", "InventoryId", "UpdateTime", "UpdateType", "NewVcpus", "NewRam", "NewResourcePool",
"EventKey", "EventId", "NewProvisionedDisk", "UserName", "PlaceholderChange", "Name", "RawChangeString"
FROM updates
ORDER BY "UpdateTime";
-- name: GetVmUpdates :many
SELECT * FROM updates
SELECT
"Uid", "InventoryId", "UpdateTime", "UpdateType", "NewVcpus", "NewRam", "NewResourcePool",
"EventKey", "EventId", "NewProvisionedDisk", "UserName", "PlaceholderChange", "Name", "RawChangeString"
FROM updates
WHERE "UpdateType" = sqlc.arg('updateType') AND "InventoryId" = sqlc.arg('InventoryId');
-- name: CleanupUpdates :exec
DELETE FROM updates
WHERE "UpdateType" = sqlc.arg('updateType') AND "UpdateTime" <= sqlc.arg('updateTime')
RETURNING *;
RETURNING
"Uid", "InventoryId", "UpdateTime", "UpdateType", "NewVcpus", "NewRam", "NewResourcePool",
"EventKey", "EventId", "NewProvisionedDisk", "UserName", "PlaceholderChange", "Name", "RawChangeString";
-- name: CleanupUpdatesNullVm :exec
DELETE FROM updates
WHERE "InventoryId" IS NULL
RETURNING *;
RETURNING
"Uid", "InventoryId", "UpdateTime", "UpdateType", "NewVcpus", "NewRam", "NewResourcePool",
"EventKey", "EventId", "NewProvisionedDisk", "UserName", "PlaceholderChange", "Name", "RawChangeString";
-- name: CreateEvent :one
INSERT INTO events (
@@ -95,14 +151,22 @@ INSERT INTO events (
) VALUES(
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
)
RETURNING *;
RETURNING
"Eid", "CloudId", "Source", "EventTime", "ChainId", "VmId", "EventKey", "DatacenterName",
"ComputeResourceName", "UserName", "Processed", "DatacenterId", "ComputeResourceId", "VmName", "EventType";
-- name: ListEvents :many
SELECT * FROM events
SELECT
"Eid", "CloudId", "Source", "EventTime", "ChainId", "VmId", "EventKey", "DatacenterName",
"ComputeResourceName", "UserName", "Processed", "DatacenterId", "ComputeResourceId", "VmName", "EventType"
FROM events
ORDER BY "EventTime";
-- name: ListUnprocessedEvents :many
SELECT * FROM events
SELECT
"Eid", "CloudId", "Source", "EventTime", "ChainId", "VmId", "EventKey", "DatacenterName",
"ComputeResourceName", "UserName", "Processed", "DatacenterId", "ComputeResourceId", "VmName", "EventType"
FROM events
WHERE "Processed" = 0
AND "EventTime" > sqlc.arg('eventTime')
ORDER BY "EventTime";
@@ -118,7 +182,8 @@ INSERT INTO inventory_history (
) VALUES(
?, ?, ?, ?, ?, ?, ?
)
RETURNING *;
RETURNING
"Hid", "InventoryId", "ReportDate", "UpdateTime", "PreviousVcpus", "PreviousRam", "PreviousResourcePool", "PreviousProvisionedDisk";
-- name: SqliteTableExists :one
SELECT COUNT(1) AS count