| 28915 | } |
| 28916 | |
| 28917 | func (p *IClientRPCServiceExecuteStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 28918 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 28919 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 28920 | } |
| 28921 | |
| 28922 | |
| 28923 | for { |
| 28924 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 28925 | if err != nil { |
| 28926 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 28927 | } |
| 28928 | if fieldTypeId == thrift.STOP { break; } |
| 28929 | switch fieldId { |
| 28930 | case 1: |
| 28931 | if fieldTypeId == thrift.STRUCT { |
| 28932 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 28933 | return err |
| 28934 | } |
| 28935 | } else { |
| 28936 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28937 | return err |
| 28938 | } |
| 28939 | } |
| 28940 | default: |
| 28941 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28942 | return err |
| 28943 | } |
| 28944 | } |
| 28945 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 28946 | return err |
| 28947 | } |
| 28948 | } |
| 28949 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 28950 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 28951 | } |
| 28952 | return nil |
| 28953 | } |
| 28954 | |
| 28955 | func (p *IClientRPCServiceExecuteStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 28956 | p.Req = &TSExecuteStatementReq{} |