| 948 | } |
| 949 | |
| 950 | func (s *Session) InsertAlignedTablets(tablets []*Tablet, sorted bool) error { |
| 951 | if !sorted { |
| 952 | for _, t := range tablets { |
| 953 | if err := t.Sort(); err != nil { |
| 954 | return err |
| 955 | } |
| 956 | } |
| 957 | } |
| 958 | request, err := s.genInsertTabletsReq(tablets, true) |
| 959 | if err != nil { |
| 960 | return err |
| 961 | } |
| 962 | r, err := s.client.InsertTablets(context.Background(), request) |
| 963 | if err != nil && r == nil { |
| 964 | if s.reconnect() { |
| 965 | request.SessionId = s.sessionId |
| 966 | r, err = s.client.InsertTablets(context.Background(), request) |
| 967 | } |
| 968 | } |
| 969 | if err != nil { |
| 970 | return err |
| 971 | } |
| 972 | return VerifySuccess(r) |
| 973 | } |
| 974 | |
| 975 | func (s *Session) ExecuteBatchStatement(inserts []string) error { |
| 976 | request := rpc.TSExecuteBatchStatementReq{ |