Skip to content

Commit

Permalink
fix: fix test case
Browse files Browse the repository at this point in the history
  • Loading branch information
newborn22 committed Dec 16, 2024
1 parent b020b41 commit a2dee82
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 30 deletions.
22 changes: 1 addition & 21 deletions go/vt/vtgate/engine/fake_vcursor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -105,22 +105,12 @@ func (t *noopVCursor) AnyAdvisoryLockTaken() bool {
panic("implement me")
}

func (t *noopVCursor) GetExecutorVSchema() *vindexes.VSchema {
// TODO implement me
panic("implement me")
}

func (t *noopVCursor) VSchemaAddKeyspaceIfNotExists(name string, KeyspaceSchema *vindexes.KeyspaceSchema) {
panic("implement me")

}

func (t *noopVCursor) VSchemaDeleteKeyspace(name string) {
panic("implement me")
}

func (t *noopVCursor) GetVSchema() *vindexes.VSchema {
// TODO implement me
panic("implement me")
}

func (t *noopVCursor) AddAdvisoryLock(_ string) {
Expand Down Expand Up @@ -840,20 +830,10 @@ func (f *loggingVCursor) SetPlannerVersion(querypb.ExecuteOptions_PlannerVersion
panic("implement me")
}

func (f *loggingVCursor) GetExecutorVSchema() *vindexes.VSchema {
panic("implement me")
}

func (f *loggingVCursor) VSchemaAddKeyspaceIfNotExists(name string, KeyspaceSchema *vindexes.KeyspaceSchema) {
panic("implement me")
}

func (f *loggingVCursor) VSchemaDeleteKeyspace(name string) {
panic("implement me")
}

func (f *loggingVCursor) GetVSchema() {
panic("implement me")
}

func (f *loggingVCursor) FindRoutedTable(tbl sqlparser.TableName) (*vindexes.Table, error) {
Expand Down
4 changes: 0 additions & 4 deletions go/vt/vtgate/engine/primitive.go
Original file line number Diff line number Diff line change
Expand Up @@ -129,13 +129,9 @@ type (

FindHealthyPrimaryTablet() (*discovery.TabletHealth, error)

//GetExecutorVSchema() *vindexes.VSchema

VSchemaAddKeyspaceIfNotExists(name string, KeyspaceSchema *vindexes.KeyspaceSchema)

VSchemaDeleteKeyspace(name string)

//GetVSchema() *vindexes.VSchema
}

// SessionActions gives primitives ability to interact with the session state
Expand Down
5 changes: 0 additions & 5 deletions go/vt/vtgate/vcursor_impl.go
Original file line number Diff line number Diff line change
Expand Up @@ -1217,11 +1217,6 @@ func (vc *vcursorImpl) ShowExec(ctx context.Context, command sqlparser.ShowComma
return nil, vterrors.Errorf(vtrpcpb.Code_INTERNAL, "bug: unexpected show command: %v", command)
}
}

func (vc *vcursorImpl) GetExecutorVSchema() *vindexes.VSchema {
return vc.executor.VSchema()
}

func (vc *vcursorImpl) VSchemaAddKeyspaceIfNotExists(name string, KeyspaceSchema *vindexes.KeyspaceSchema) {
vc.executor.VSchemaAddKeyspaceIfNotExists(name, KeyspaceSchema)
}
Expand Down

0 comments on commit a2dee82

Please sign in to comment.