Skip to content

Commit

Permalink
remove some codes
Browse files Browse the repository at this point in the history
  • Loading branch information
lcwangchao committed Jul 4, 2022
1 parent 6a0e51b commit dcdce8a
Showing 1 changed file with 0 additions and 31 deletions.
31 changes: 0 additions & 31 deletions executor/batch_point_get.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,37 +113,6 @@ func (e *BatchPointGetExec) Open(context.Context) error {
return nil
}

//func (e *BatchPointGetExec) verifyTxnScope() error {
// if e.txnScope == "" || e.txnScope == kv.GlobalTxnScope {
// return nil
// }
//
// var tblID int64
// var tblName string
// var partName string
// is := e.ctx.GetInfoSchema().(infoschema.InfoSchema)
// if e.partInfo != nil {
// tblID = e.partInfo.ID
// tblInfo, _, partInfo := is.FindTableByPartitionID(tblID)
// tblName = tblInfo.Meta().Name.String()
// partName = partInfo.Name.String()
// } else {
// tblID = e.tblInfo.ID
// tblInfo, _ := is.TableByID(tblID)
// tblName = tblInfo.Meta().Name.String()
// }
// valid := distsql.VerifyTxnScope(e.txnScope, tblID, is)
// if valid {
// return nil
// }
// if len(partName) > 0 {
// return dbterror.ErrInvalidPlacementPolicyCheck.GenWithStackByArgs(
// fmt.Sprintf("table %v's partition %v can not be read by %v txn_scope", tblName, partName, e.txnScope))
// }
// return dbterror.ErrInvalidPlacementPolicyCheck.GenWithStackByArgs(
// fmt.Sprintf("table %v can not be read by %v txn_scope", tblName, e.txnScope))
//}

// CacheTable always use memBuffer in session as snapshot.
// cacheTableSnapshot inherits kv.Snapshot and override the BatchGet methods and Get methods.
type cacheTableSnapshot struct {
Expand Down

0 comments on commit dcdce8a

Please sign in to comment.