-
Notifications
You must be signed in to change notification settings - Fork 123
/
ctequery.go
141 lines (113 loc) · 3.96 KB
/
ctequery.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
// Copyright 2024 Huan Du. All rights reserved.
// Licensed under the MIT license that can be found in the LICENSE file.
package sqlbuilder
const (
cteQueryMarkerInit injectionMarker = iota
cteQueryMarkerAfterTable
cteQueryMarkerAfterAs
)
// CTETable creates a new CTE query builder with default flavor, marking it as a table.
//
// The resulting CTE query can be used in a `SelectBuilder“, where its table name will be
// automatically included in the FROM clause.
func CTETable(name string, cols ...string) *CTEQueryBuilder {
return DefaultFlavor.NewCTEQueryBuilder().AddToTableList().Table(name, cols...)
}
// CTEQuery creates a new CTE query builder with default flavor.
func CTEQuery(name string, cols ...string) *CTEQueryBuilder {
return DefaultFlavor.NewCTEQueryBuilder().Table(name, cols...)
}
func newCTEQueryBuilder() *CTEQueryBuilder {
return &CTEQueryBuilder{
args: &Args{},
injection: newInjection(),
}
}
// CTEQueryBuilder is a builder to build one table in CTE (Common Table Expression).
type CTEQueryBuilder struct {
name string
cols []string
builderVar string
// if true, this query's table name will be automatically added to the table list
// in FROM clause of SELECT statement.
autoAddToTableList bool
args *Args
injection *injection
marker injectionMarker
}
var _ Builder = new(CTEQueryBuilder)
// CTETableBuilder is an alias of CTEQueryBuilder for backward compatibility.
//
// Deprecated: use CTEQueryBuilder instead.
type CTETableBuilder = CTEQueryBuilder
// Table sets the table name and columns in a CTE table.
func (ctetb *CTEQueryBuilder) Table(name string, cols ...string) *CTEQueryBuilder {
ctetb.name = name
ctetb.cols = cols
ctetb.marker = cteQueryMarkerAfterTable
return ctetb
}
// As sets the builder to select data.
func (ctetb *CTEQueryBuilder) As(builder Builder) *CTEQueryBuilder {
ctetb.builderVar = ctetb.args.Add(builder)
ctetb.marker = cteQueryMarkerAfterAs
return ctetb
}
// AddToTableList sets flag to add table name to table list in FROM clause of SELECT statement.
func (ctetb *CTEQueryBuilder) AddToTableList() *CTEQueryBuilder {
ctetb.autoAddToTableList = true
return ctetb
}
// ShouldAddToTableList returns flag to add table name to table list in FROM clause of SELECT statement.
func (ctetb *CTEQueryBuilder) ShouldAddToTableList() bool {
return ctetb.autoAddToTableList
}
// String returns the compiled CTE string.
func (ctetb *CTEQueryBuilder) String() string {
sql, _ := ctetb.Build()
return sql
}
// Build returns compiled CTE string and args.
func (ctetb *CTEQueryBuilder) Build() (sql string, args []interface{}) {
return ctetb.BuildWithFlavor(ctetb.args.Flavor)
}
// BuildWithFlavor builds a CTE with the specified flavor and initial arguments.
func (ctetb *CTEQueryBuilder) BuildWithFlavor(flavor Flavor, initialArg ...interface{}) (sql string, args []interface{}) {
buf := newStringBuilder()
ctetb.injection.WriteTo(buf, cteQueryMarkerInit)
if ctetb.name != "" {
buf.WriteLeadingString(ctetb.name)
if len(ctetb.cols) > 0 {
buf.WriteLeadingString("(")
buf.WriteStrings(ctetb.cols, ", ")
buf.WriteString(")")
}
ctetb.injection.WriteTo(buf, cteQueryMarkerAfterTable)
}
if ctetb.builderVar != "" {
buf.WriteLeadingString("AS (")
buf.WriteString(ctetb.builderVar)
buf.WriteRune(')')
ctetb.injection.WriteTo(buf, cteQueryMarkerAfterAs)
}
return ctetb.args.CompileWithFlavor(buf.String(), flavor, initialArg...)
}
// SetFlavor sets the flavor of compiled sql.
func (ctetb *CTEQueryBuilder) SetFlavor(flavor Flavor) (old Flavor) {
old = ctetb.args.Flavor
ctetb.args.Flavor = flavor
return
}
// Flavor returns flavor of builder
func (ctetb *CTEQueryBuilder) Flavor() Flavor {
return ctetb.args.Flavor
}
// SQL adds an arbitrary sql to current position.
func (ctetb *CTEQueryBuilder) SQL(sql string) *CTEQueryBuilder {
ctetb.injection.SQL(ctetb.marker, sql)
return ctetb
}
// TableName returns the CTE table name.
func (ctetb *CTEQueryBuilder) TableName() string {
return ctetb.name
}