Skip to content

Commit

Permalink
addressed review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Harshit Gangal <[email protected]>
  • Loading branch information
harshit-gangal committed Dec 30, 2024
1 parent 802cbbe commit 2ff63d3
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 19 deletions.
31 changes: 14 additions & 17 deletions go/vt/vtgate/engine/fake_vcursor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -400,6 +400,20 @@ func (t *noopVCursor) GetDBDDLPluginName() string {
panic("unimplemented")
}

func (t *noopVCursor) SetLastInsertID(uint64) {}
func (t *noopVCursor) VExplainLogging() {}
func (t *noopVCursor) DisableLogging() {}
func (t *noopVCursor) GetVExplainLogs() []ExecuteEntry {
return nil
}
func (t *noopVCursor) GetLogs() ([]ExecuteEntry, error) {
return nil, nil
}

// RecordMirrorStats implements VCursor.
func (t *noopVCursor) RecordMirrorStats(sourceExecTime, targetExecTime time.Duration, targetErr error) {
}

var (
_ VCursor = (*loggingVCursor)(nil)
_ SessionActions = (*loggingVCursor)(nil)
Expand Down Expand Up @@ -893,23 +907,6 @@ func (t *loggingVCursor) RecordMirrorStats(sourceExecTime, targetExecTime time.D
}
}

func (t *loggingVCursor) SetLastInsertID(id uint64) {}
func (t *noopVCursor) SetLastInsertID(id uint64) {}

func (t *noopVCursor) VExplainLogging() {}
func (t *noopVCursor) DisableLogging() {}
func (t *noopVCursor) GetVExplainLogs() []ExecuteEntry {
return nil
}

func (t *noopVCursor) GetLogs() ([]ExecuteEntry, error) {
return nil, nil
}

// RecordMirrorStats implements VCursor.
func (t *noopVCursor) RecordMirrorStats(sourceExecTime, targetExecTime time.Duration, targetErr error) {
}

func expectResult(t *testing.T, result, want *sqltypes.Result) {
t.Helper()
fieldsResult := fmt.Sprintf("%v", result.Fields)
Expand Down
1 change: 0 additions & 1 deletion go/vt/vtgate/evalengine/fn_misc.go
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,6 @@ func (call *builtinInetNtoa) compile(c *compiler) (ctype, error) {
c.compileToUint64(arg, 1)
col := typedCoercionCollation(sqltypes.VarChar, call.collate)
c.asm.Fn_INET_NTOA(col)

c.asm.jumpDestination(skip)

return ctype{Type: sqltypes.VarChar, Flag: flagNullable, Col: col}, nil
Expand Down
2 changes: 1 addition & 1 deletion go/vt/vtgate/planbuilder/plan_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -666,7 +666,7 @@ func (s *planTestSuite) testFile(filename string, vschema *vschemawrapper.VSchem
current := PlanTest{
Comment: tcase.Comment,
Query: tcase.Query,
SkipE2E: true,
SkipE2E: tcase.SkipE2E,
}
vschema.Version = Gen4
out := getPlanOutput(tcase, vschema, render)
Expand Down

0 comments on commit 2ff63d3

Please sign in to comment.