Skip to content
This repository was archived by the owner on Jan 28, 2021. It is now read-only.

Commit 685c869

Browse files
Shorten receiver names, adhering to Go conventions
Signed-off-by: Alejandro García Montoro <alejandro.garciamontoro@gmail.com>
1 parent 660fb4f commit 685c869

File tree

2 files changed

+51
-51
lines changed

2 files changed

+51
-51
lines changed

sql/plan/create_view.go

Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -39,78 +39,78 @@ func NewCreateView(
3939
}
4040

4141
// View returns the view that will be created by this node.
42-
func (create *CreateView) View() sql.View {
43-
return sql.NewView(create.Name, create.Child)
42+
func (cv *CreateView) View() sql.View {
43+
return sql.NewView(cv.Name, cv.Child)
4444
}
4545

4646
// Children implements the Node interface. It returns the Child of the
4747
// CreateView node; i.e., the definition of the view that will be created.
48-
func (create *CreateView) Children() []sql.Node {
49-
return []sql.Node{create.Child}
48+
func (cv *CreateView) Children() []sql.Node {
49+
return []sql.Node{cv.Child}
5050
}
5151

5252
// Resolved implements the Node interface. This node is resolved if and only if
5353
// the database and the Child are both resolved.
54-
func (create *CreateView) Resolved() bool {
55-
_, ok := create.database.(sql.UnresolvedDatabase)
56-
return !ok && create.Child.Resolved()
54+
func (cv *CreateView) Resolved() bool {
55+
_, ok := cv.database.(sql.UnresolvedDatabase)
56+
return !ok && cv.Child.Resolved()
5757
}
5858

5959
// RowIter implements the Node interface. When executed, this function creates
6060
// (or replaces) the view. It can error if the CraeteView's IsReplace member is
6161
// set to false and the view already exists. The RowIter returned is always
6262
// empty.
63-
func (create *CreateView) RowIter(ctx *sql.Context) (sql.RowIter, error) {
64-
view := sql.NewView(create.Name, create.Child)
65-
registry := create.Catalog.ViewRegistry
63+
func (cv *CreateView) RowIter(ctx *sql.Context) (sql.RowIter, error) {
64+
view := sql.NewView(cv.Name, cv.Child)
65+
registry := cv.Catalog.ViewRegistry
6666

67-
if create.IsReplace {
68-
err := registry.Delete(create.database.Name(), view.Name())
67+
if cv.IsReplace {
68+
err := registry.Delete(cv.database.Name(), view.Name())
6969
if err != nil && !sql.ErrNonExistingView.Is(err) {
7070
return sql.RowsToRowIter(), err
7171
}
7272
}
7373

74-
return sql.RowsToRowIter(), registry.Register(create.database.Name(), view)
74+
return sql.RowsToRowIter(), registry.Register(cv.database.Name(), view)
7575
}
7676

7777
// Schema implements the Node interface. It always returns nil.
78-
func (create *CreateView) Schema() sql.Schema { return nil }
78+
func (cv *CreateView) Schema() sql.Schema { return nil }
7979

8080
// String implements the fmt.Stringer interface, using sql.TreePrinter to
8181
// generate the string.
82-
func (create *CreateView) String() string {
82+
func (cv *CreateView) String() string {
8383
pr := sql.NewTreePrinter()
84-
_ = pr.WriteNode("CreateView(%s)", create.Name)
84+
_ = pr.WriteNode("CreateView(%s)", cv.Name)
8585
_ = pr.WriteChildren(
86-
fmt.Sprintf("Columns (%s)", strings.Join(create.Columns, ", ")),
87-
create.Child.String(),
86+
fmt.Sprintf("Columns (%s)", strings.Join(cv.Columns, ", ")),
87+
cv.Child.String(),
8888
)
8989
return pr.String()
9090
}
9191

9292
// WithChildren implements the Node interface. It only succeeds if the length
9393
// of the specified children equals 1.
94-
func (create *CreateView) WithChildren(children ...sql.Node) (sql.Node, error) {
94+
func (cv *CreateView) WithChildren(children ...sql.Node) (sql.Node, error) {
9595
if len(children) != 1 {
96-
return nil, sql.ErrInvalidChildrenNumber.New(create, len(children), 1)
96+
return nil, sql.ErrInvalidChildrenNumber.New(cv, len(children), 1)
9797
}
9898

99-
newCreate := create
99+
newCreate := cv
100100
newCreate.Child = children[0]
101101
return newCreate, nil
102102
}
103103

104104
// Database implements the Databaser interface, and it returns the database in
105105
// which CreateView will create the view.
106-
func (create *CreateView) Database() sql.Database {
107-
return create.database
106+
func (cv *CreateView) Database() sql.Database {
107+
return cv.database
108108
}
109109

110110
// Database implements the Databaser interface, and it returns a copy of this
111111
// node with the specified database.
112-
func (create *CreateView) WithDatabase(database sql.Database) (sql.Node, error) {
113-
newCreate := *create
112+
func (cv *CreateView) WithDatabase(database sql.Database) (sql.Node, error) {
113+
newCreate := *cv
114114
newCreate.database = database
115115
return &newCreate, nil
116116
}

sql/viewregistry.go

Lines changed: 26 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -24,13 +24,13 @@ func NewView(name string, definition Node) View {
2424
}
2525

2626
// Name returns the name of the view.
27-
func (view *View) Name() string {
28-
return view.name
27+
func (v *View) Name() string {
28+
return v.name
2929
}
3030

3131
// Definition returns the definition of the view.
32-
func (view *View) Definition() Node {
33-
return view.definition
32+
func (v *View) Definition() Node {
33+
return v.definition
3434
}
3535

3636
// Views are scoped by the databases in which they were defined, so a key in
@@ -60,66 +60,66 @@ func NewViewRegistry() *ViewRegistry {
6060

6161
// Register adds the view specified by the pair {database, view.Name()},
6262
// returning an error if there is already an element with that key.
63-
func (registry *ViewRegistry) Register(database string, view View) error {
64-
registry.mutex.Lock()
65-
defer registry.mutex.Unlock()
63+
func (r *ViewRegistry) Register(database string, view View) error {
64+
r.mutex.Lock()
65+
defer r.mutex.Unlock()
6666

6767
key := newViewKey(database, view.Name())
6868

69-
if _, ok := registry.views[key]; ok {
69+
if _, ok := r.views[key]; ok {
7070
return ErrExistingView.New(database, view.Name())
7171
}
7272

73-
registry.views[key] = view
73+
r.views[key] = view
7474
return nil
7575
}
7676

7777
// Delete deletes the view specified by the pair {databaseName, viewName},
7878
// returning an error if it does not exist.
79-
func (registry *ViewRegistry) Delete(databaseName, viewName string) error {
80-
registry.mutex.Lock()
81-
defer registry.mutex.Unlock()
79+
func (r *ViewRegistry) Delete(databaseName, viewName string) error {
80+
r.mutex.Lock()
81+
defer r.mutex.Unlock()
8282

8383
key := newViewKey(databaseName, viewName)
8484

85-
if _, ok := registry.views[key]; !ok {
85+
if _, ok := r.views[key]; !ok {
8686
return ErrNonExistingView.New(databaseName, viewName)
8787
}
8888

89-
delete(registry.views, key)
89+
delete(r.views, key)
9090
return nil
9191
}
9292

9393
// View returns a pointer to the view specified by the pair {databaseName,
9494
// viewName}, returning an error if it does not exist.
95-
func (registry *ViewRegistry) View(databaseName, viewName string) (*View, error) {
96-
registry.mutex.RLock()
97-
defer registry.mutex.RUnlock()
95+
func (r *ViewRegistry) View(databaseName, viewName string) (*View, error) {
96+
r.mutex.RLock()
97+
defer r.mutex.RUnlock()
9898

9999
key := newViewKey(databaseName, viewName)
100100

101-
if view, ok := registry.views[key]; ok {
101+
if view, ok := r.views[key]; ok {
102102
return &view, nil
103103
}
104104

105105
return nil, ErrNonExistingView.New(databaseName, viewName)
106106
}
107107

108108
// AllViews returns the map of all views in the registry.
109-
func (registry *ViewRegistry) AllViews() map[viewKey]View {
110-
registry.mutex.RLock()
111-
defer registry.mutex.RUnlock()
109+
func (r *ViewRegistry) AllViews() map[viewKey]View {
110+
r.mutex.RLock()
111+
defer r.mutex.RUnlock()
112112

113-
return registry.views
113+
return r.views
114114
}
115115

116116
// ViewsInDatabase returns an array of all the views registered under the
117117
// specified database.
118-
func (registry *ViewRegistry) ViewsInDatabase(databaseName string) (views []View) {
119-
registry.mutex.RLock()
120-
defer registry.mutex.RUnlock()
118+
func (r *ViewRegistry) ViewsInDatabase(databaseName string) (views []View) {
119+
r.mutex.RLock()
120+
defer r.mutex.RUnlock()
121121

122-
for key, value := range registry.views {
122+
for key, value := range r.views {
123123
if key.dbName == databaseName {
124124
views = append(views, value)
125125
}

0 commit comments

Comments
 (0)