cassandra

const (
	MaxJobStepLogRecord    = 20
	InsertJobQueryTemplate = `INSERT INTO job_info (` +
		`service, task, domain, job_date, job_id, user_id, engine, spec, started_time, finished_time, state, steps, detail, version) ` +
		`VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) IF NOT EXISTS USING TTL ?`
	InsertJobStepLogQueryTemplate = `INSERT INTO log_info (` +
		`service, task, domain, job_id, step_id, log_time, data) ` +
		`VALUES(?, ?, ?, ?, ?, ?, ?) IF NOT EXISTS USING TTL ?`

	DeleteJobStepLogQueryTemplate = `DELETE FROM log_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_id = ? ` +
		`and step_id = ?`

	DeleteJobLogQueryTemplate = `DELETE FROM log_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_id = ? `

	DeleteJobQueryTemplate = `DELETE FROM job_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_date = ? ` +
		`and job_id = ?`

	UpdateJobQueryTemplate = `UPDATE job_info ` +
		`SET started_time = ?, ` +
		`finished_time = ?, ` +
		`state = ?, ` +
		`steps = ?, ` +
		`detail = ?, ` +
		`version = ?` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_date = ? ` +
		`and job_id = ?` +
		`IF version = ?`
	GetJobQueryTemplate = `SELECT service, task, domain, job_id, user_id, engine, spec, started_time, finished_time, state, steps, detail, version ` +
		`FROM job_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_date = ? ` +
		`and job_id IN ? `

	GetJobLogQueryTemplate = `SELECT log_time, data ` +
		`FROM log_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_id = ? ` +
		`and step_id = ?` +
		`and log_time > ?` +
		`LIMIT ?`

	GetJobLastLogQueryTemplate = `SELECT data ` +
		`FROM log_info ` +
		`WHERE service = ? ` +
		`and task = ? ` +
		`and domain = ? ` +
		`and job_id = ? ` +
		`and step_id = ?` +
		`ORDER BY log_time DESC LIMIT 1`
)

const (
	PluginName = "cassandra"
)