1package dialectquery
 2
 3import "fmt"
 4
 5type Sqlserver struct{}
 6
 7var _ Querier = (*Sqlserver)(nil)
 8
 9func (s *Sqlserver) CreateTable(tableName string) string {
10	q := `CREATE TABLE %s (
11		id INT NOT NULL IDENTITY(1,1) PRIMARY KEY,
12		version_id BIGINT NOT NULL,
13		is_applied BIT NOT NULL,
14		tstamp DATETIME NULL DEFAULT CURRENT_TIMESTAMP
15	)`
16	return fmt.Sprintf(q, tableName)
17}
18
19func (s *Sqlserver) InsertVersion(tableName string) string {
20	q := `INSERT INTO %s (version_id, is_applied) VALUES (@p1, @p2)`
21	return fmt.Sprintf(q, tableName)
22}
23
24func (s *Sqlserver) DeleteVersion(tableName string) string {
25	q := `DELETE FROM %s WHERE version_id=@p1`
26	return fmt.Sprintf(q, tableName)
27}
28
29func (s *Sqlserver) GetMigrationByVersion(tableName string) string {
30	q := `SELECT TOP 1 tstamp, is_applied FROM %s WHERE version_id=@p1 ORDER BY tstamp DESC`
31	return fmt.Sprintf(q, tableName)
32}
33
34func (s *Sqlserver) ListMigrations(tableName string) string {
35	q := `SELECT version_id, is_applied FROM %s ORDER BY id DESC`
36	return fmt.Sprintf(q, tableName)
37}
38
39func (s *Sqlserver) GetLatestVersion(tableName string) string {
40	q := `SELECT MAX(version_id) FROM %s`
41	return fmt.Sprintf(q, tableName)
42}