storage

var (
	// table: version
	CreateVersionTable = `` /* 141-byte string literal not displayed */

	// insert version
	InsertVersion = `INSERT INTO version(version, lastconfirm) VALUES(?, "")`

	// set version
	SetVersion = `UPDATE version SET version = ?, lastconfirm = ? WHERE id = ?`

	// select version
	SelectVersion = `SELECT * FROM version`
)

var (
	// table: hosts
	CreateHostsTable = `` /* 142-byte string literal not displayed */

	// insert hosts
	InsertHosts = `INSERT INTO hosts(data, lastmodified_time) VALUES(?, datetime('now','localtime'))`

	// set hosts
	SetHosts = `UPDATE hosts SET data = ?, lastmodified_time = datetime('now','localtime') WHERE id = ?`

	// select hosts
	SelectHosts = `SELECT * FROM hosts`
)

var (
	// table: clusters
	CreateClustersTable = `` /* 262-byte string literal not displayed */

	// insert cluster
	InsertCluster = `` /* 133-byte string literal not displayed */

	// delete cluster
	DeleteCluster = `DELETE from clusters WHERE name = ?`

	// select cluster
	SelectCluster = `SELECT * FROM clusters WHERE name LIKE ?`

	// get current cluster
	GetCurrentCluster = `SELECT * FROM clusters WHERE current = 1`

	// checkout cluster
	CheckoutCluster = `
		UPDATE clusters
		SET current = CASE name
			WHEN ? THEN 1
			ELSE 0
		END
	`

	// set cluster topology
	SetClusterTopology = `UPDATE clusters SET topology = ? WHERE id = ?`

	// set cluster pool
	SetClusterPool = `UPDATE clusters SET topology = ?, pool = ? WHERE id = ?`
)

var (
	// table: containers
	// id: clusterId_role_host_(sequence/name)
	CreateContainersTable = `` /* 134-byte string literal not displayed */

	// insert service
	InsertService = `INSERT INTO containers(id, cluster_id, container_id) VALUES(?, ?, ?)`

	// select service
	SelectService = `SELECT * FROM containers WHERE id = ?`

	// select services in cluster
	SelectServicesInCluster = `SELECT * FROM containers WHERE cluster_id = ?`

	// set service container id
	SetContainerId = `UPDATE containers SET container_id = ? WHERE id = ?`
)

var (
	// table: clients
	CreateClientsTable = `` /* 172-byte string literal not displayed */

	// insert client
	InsertClient = `INSERT INTO clients(id, kind, host, container_id, aux_info) VALUES(?, ?, ?, ?, ?)`

	// set client aux info
	SetClientAuxInfo = `UPDATE clients SET aux_info = ? WHERE id = ?`

	// select clients
	SelectClients = `SELECT * FROM clients`

	// select client by id
	SelectClientById = `SELECT * FROM clients WHERE id = ?`

	// delete client
	DeleteClient = `DELETE from clients WHERE id = ?`
)

var (
	// table: playground
	CreatePlaygroundTable = `` /* 204-byte string literal not displayed */

	// insert playground
	InsertPlayground = `` /* 133-byte string literal not displayed */

	// set playground status
	SetPlaygroundStatus = `UPDATE playgrounds SET status = ? WHERE name = ?`

	// select playground
	SelectPlayground = `SELECT * FROM playgrounds WHERE name LIKE ?`

	// select playground by id
	SelectPlaygroundById = `SELECT * FROM playgrounds WHERE id = ?`

	// delete playground
	DeletePlayground = `DELETE from playgrounds WHERE name = ?`
)

var (
	// table: audit
	CreateAuditTable = `` /* 235-byte string literal not displayed */

	// insert audit log
	InsertAuditLog = `
		INSERT INTO audit(execute_time, work_directory, command, status)
		            VALUES(?, ?, ?, ?)
	`

	// set audit log status
	SetAuditLogStatus = `UPDATE audit SET status = ?, error_code = ? WHERE id = ?`

	// select audit log
	SelectAuditLog = `SELECT * FROM audit`

	// select audit log by id
	SelectAuditLogById = `SELECT * FROM audit WHERE id = ?`
)

var (
	// table: any
	CreateAnyTable = `
		CREATE TABLE IF NOT EXISTS any (
			id TEXT PRIMARY KEY,
			data TEXT NOT NULL
		)
	`

	// insert item
	InsertAnyItem = `INSERT INTO any(id, data) VALUES(?, ?)`

	// set item
	SetAnyItem = `UPDATE any SET data = ? WHERE id = ?`

	// select item by id
	SelectAnyItem = `SELECT * FROM any WHERE id = ?`

	// delete item
	DeleteAnyItem = `DELETE from any WHERE id = ?`
)

var (
	// check pool column
	CheckPoolColumn = `
		SELECT COUNT(*) AS total
		FROM pragma_table_info('clusters')
		WHERE name='pool'
	`

	// rename clusters table
	RenameClustersTable = `ALTER TABLE clusters RENAME TO clusters_old`

	// insert clusters from old table
	InsertClustersFromOldTable = `` /* 185-byte string literal not displayed */

	// statement: drom old clusters table
	DropOldClustersTable = `DROP TABLE clusters_old`
)

var (
	// monitor
	CreateMonitorTable = `
		CREATE TABLE IF NOT EXISTS monitors (
			cluster_id INTEGER PRIMARY KEY,
			monitor TEXT NOT NULL
		)
	`
	// monitor
	InsertMonitor = `INSERT INTO monitors(cluster_id, monitor) VALUES(?, ?)`

	UpdateMonitor = `UPDATE monitors SET monitor = ? WHERE cluster_id = ?`

	SelectMonitor = `SELECT monitor FROM monitors WHERE cluster_id = ?`

	DeleteMonitor = `DELETE FROM monitors WHERE cluster_id = ?`

	ReplaceMonitor = `REPLACE INTO monitors (cluster_id, monitor) VALUES(?, ?)`
)

var (
	ErrInvalidDBUrl = fmt.Errorf("invalid database url")
)