@@ -54,8 +54,8 @@ func (u *UpdateJoin) DebugString() string {
54
54
55
55
// GetUpdatable returns an updateJoinTable which implements sql.UpdatableTable.
56
56
func (u * UpdateJoin ) GetUpdatable () sql.UpdatableTable {
57
- return & UpdatableJoinTable {
58
- UpdateTargets : u .UpdateTargets ,
57
+ return & updatableJoinTable {
58
+ updateTargets : u .UpdateTargets ,
59
59
joinNode : u .Child .(* UpdateSource ).Child ,
60
60
}
61
61
}
@@ -94,47 +94,47 @@ func getUpdaters(updateTargets map[string]sql.Node, ctx *sql.Context) (map[strin
94
94
return updaterMap , nil
95
95
}
96
96
97
- // UpdatableJoinTable manages the update of multiple tables.
98
- type UpdatableJoinTable struct {
99
- UpdateTargets map [string ]sql.Node
97
+ // updatableJoinTable manages the update of multiple tables.
98
+ type updatableJoinTable struct {
99
+ updateTargets map [string ]sql.Node
100
100
joinNode sql.Node
101
101
}
102
102
103
- var _ sql.UpdatableTable = (* UpdatableJoinTable )(nil )
103
+ var _ sql.UpdatableTable = (* updatableJoinTable )(nil )
104
104
105
105
// Partitions implements the sql.UpdatableTable interface.
106
- func (u * UpdatableJoinTable ) Partitions (context * sql.Context ) (sql.PartitionIter , error ) {
106
+ func (u * updatableJoinTable ) Partitions (context * sql.Context ) (sql.PartitionIter , error ) {
107
107
panic ("this method should not be called" )
108
108
}
109
109
110
110
// PartitionsRows implements the sql.UpdatableTable interface.
111
- func (u * UpdatableJoinTable ) PartitionRows (context * sql.Context , partition sql.Partition ) (sql.RowIter , error ) {
111
+ func (u * updatableJoinTable ) PartitionRows (context * sql.Context , partition sql.Partition ) (sql.RowIter , error ) {
112
112
panic ("this method should not be called" )
113
113
}
114
114
115
115
// Name implements the sql.UpdatableTable interface.
116
- func (u * UpdatableJoinTable ) Name () string {
116
+ func (u * updatableJoinTable ) Name () string {
117
117
panic ("this method should not be called" )
118
118
}
119
119
120
120
// String implements the sql.UpdatableTable interface.
121
- func (u * UpdatableJoinTable ) String () string {
121
+ func (u * updatableJoinTable ) String () string {
122
122
panic ("this method should not be called" )
123
123
}
124
124
125
125
// Schema implements the sql.UpdatableTable interface.
126
- func (u * UpdatableJoinTable ) Schema () sql.Schema {
126
+ func (u * updatableJoinTable ) Schema () sql.Schema {
127
127
return u .joinNode .Schema ()
128
128
}
129
129
130
130
// Collation implements the sql.Table interface.
131
- func (u * UpdatableJoinTable ) Collation () sql.CollationID {
131
+ func (u * updatableJoinTable ) Collation () sql.CollationID {
132
132
return sql .Collation_Default
133
133
}
134
134
135
135
// Updater implements the sql.UpdatableTable interface.
136
- func (u * UpdatableJoinTable ) Updater (ctx * sql.Context ) sql.RowUpdater {
137
- updaters , _ := getUpdaters (u .UpdateTargets , ctx )
136
+ func (u * updatableJoinTable ) Updater (ctx * sql.Context ) sql.RowUpdater {
137
+ updaters , _ := getUpdaters (u .updateTargets , ctx )
138
138
return & updatableJoinUpdater {
139
139
updaterMap : updaters ,
140
140
schemaMap : RecreateTableSchemaFromJoinSchema (u .joinNode .Schema ()),
0 commit comments