This is an automated email from the ASF dual-hosted git repository. francischuang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/calcite-avatica-go.git
commit f71ef3e831f73c2f9aa5e75ca55843f3c70be4a7 Author: Francis Chuang <[email protected]> AuthorDate: Mon Oct 10 09:10:38 2022 +1100 [CALCITE-5320] Switch from deprecated_first_frame_max_size to first_frame_max_size protobuf member for setting the first frame max size --- statement.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/statement.go b/statement.go index 36e9ad6..c9f9521 100644 --- a/statement.go +++ b/statement.go @@ -115,9 +115,9 @@ func (s *stmt) exec(ctx context.Context, args []namedValue) (driver.Result, erro } if s.conn.config.frameMaxSize <= -1 { - msg.DeprecatedFirstFrameMaxSize = math.MaxInt64 + msg.FirstFrameMaxSize = math.MaxInt32 } else { - msg.DeprecatedFirstFrameMaxSize = uint64(s.conn.config.frameMaxSize) + msg.FirstFrameMaxSize = s.conn.config.frameMaxSize } res, err := s.conn.httpClient.post(ctx, msg) @@ -160,9 +160,9 @@ func (s *stmt) query(ctx context.Context, args []namedValue) (driver.Rows, error } if s.conn.config.frameMaxSize <= -1 { - msg.DeprecatedFirstFrameMaxSize = math.MaxInt64 + msg.FirstFrameMaxSize = math.MaxInt32 } else { - msg.DeprecatedFirstFrameMaxSize = uint64(s.conn.config.frameMaxSize) + msg.FirstFrameMaxSize = s.conn.config.frameMaxSize } res, err := s.conn.httpClient.post(ctx, msg)
