Support Phoenix 4.8.0 and Calcite/Avatica 1.8.0.


Branch: refs/heads/master
Commit: a87e02f2a8e040c2c22f80245fa68611fe2d952a
Parents: f5d6dfb
Author: Francis Chuang <>
Authored: Mon Aug 22 16:35:22 2016 +1000
Committer: Julian Hyde <>
Committed: Thu Aug 10 18:47:08 2017 -0700

----------------------------------------------------------------------               |  20 +++-
 connection.go           |  30 +++--
 driver_test.go          |   5 +-
 dsn.go                  |  34 +++---
 dsn_test.go             |  32 ++---
 gen-protobuf.bat        |   2 +-         |   2 +-
 message/common.pb.go    | 278 ++++++++++++++++++++++---------------------
 message/requests.pb.go  | 167 ++++++++++++++++++--------
 message/responses.pb.go | 122 +++++++++++--------
 moby.yml                |   4 +-
 rows.go                 |  10 +-
 statement.go            |  10 +-
 transaction.go          |   2 +-
 vendor/vendor.json      |  22 ++--
 wercker.yml             |   2 +-
 16 files changed, 419 insertions(+), 323 deletions(-)
diff --git a/ b/
index 90c00f5..69293e7 100644
--- a/
+++ b/
@@ -47,11 +47,18 @@ The following parameters are supported:
 The `location` will be set as the location of unserialized `time.Time` values. 
It must be a valid timezone.
 If you want to use the local timezone, use `Local`. By default, this is set to 
-#### maxRowCount
+#### maxRowsTotal
-The `maxRowCount` sets the number of rows to fetch from the avatica server. 
Setting a high number causes avatica
-to return a large number of rows and setting a low number will cause avatica 
to return a small amount of rows
-and fetch more from the server if required. By default, this is set to `100`.
+The `maxRowsTotal` parameter sets the maximum number of rows to return for a 
given query. By default, this is set to
+`-1`, so that there is no limit on the number of rows returned.
+#### frameMaxSize
+The `frameMaxSize` parameter sets the maximum number of rows to return in a 
frame. Depending on the number of rows
+returned and subject to the limits of `maxRowsTotal`, a query result set can 
contain rows in multiple frames. These
+additional frames are then fetched on a as-needed basis. `frameMaxSize` allows 
you to control the number of rows
+in each frame to suit your application's performance profile. By default this 
is set to `-1`, so that there is no limit
+on the number of rows in a frame.
 ### time.Time support
@@ -64,6 +71,11 @@ in your DSN is set to the same value as the location of the 
`time.Time` values y
 We recommend using `UTC`, which is the default value of `location`.
+## Version compatibility
+| Driver Version  | Phoenix Version | Calcite/Avatica Version |
+| --------------- | -------------   | ----------------------- |
+| 1.0.0           | 4.8.0           | 1.8.0                   |
 ## Development
 To run tests, but skip tests in the vendor directory, run:
diff --git a/connection.go b/connection.go
index 3c80d06..24cad3b 100644
--- a/connection.go
+++ b/connection.go
@@ -22,7 +22,7 @@ func (c *conn) Prepare(query string) (driver.Stmt, error) {
        response, err :=, 
                ConnectionId: c.connectionId,
                Sql:          query,
-               MaxRowCount:  c.config.maxRowCount,
+               MaxRowsTotal: c.config.maxRowsTotal,
        if err != nil {
@@ -74,7 +74,7 @@ func (c *conn) Begin() (driver.Tx, error) {
                ConnProps: &message.ConnectionProperties{
                        AutoCommit:           false,
                        HasAutoCommit:        true,
-                       TransactionIsolation: 8,
+                       TransactionIsolation: 4,
@@ -107,10 +107,11 @@ func (c *conn) Exec(query string, args []driver.Value) 
(driver.Result, error) {
        res, err :=, 
-               ConnectionId: c.connectionId,
-               StatementId:  st.(*message.CreateStatementResponse).StatementId,
-               Sql:          query,
-               MaxRowCount:  c.config.maxRowCount,
+               ConnectionId:      c.connectionId,
+               StatementId:       
+               Sql:               query,
+               MaxRowsTotal:      c.config.maxRowsTotal,
+               FirstFrameMaxSize: c.config.frameMaxSize,
        if err != nil {
@@ -134,11 +135,7 @@ func (c *conn) Query(query string, args []driver.Value) 
(driver.Rows, error) {
                return nil, driver.ErrBadConn
-       return nil, driver.ErrSkip
-       // Disabled due to CALCITE-1181
-       /*if len(args) != 0 {
+       if len(args) != 0 {
                return nil, driver.ErrSkip
@@ -151,10 +148,11 @@ func (c *conn) Query(query string, args []driver.Value) 
(driver.Rows, error) {
        res, err :=, 
-               ConnectionId: c.connectionId,
-               StatementId:  st.(*message.CreateStatementResponse).StatementId,
-               Sql:          query,
-               MaxRowCount:  maxRowCount,
+               ConnectionId:      c.connectionId,
+               StatementId:       
+               Sql:               query,
+               MaxRowsTotal:      c.config.maxRowsTotal,
+               FirstFrameMaxSize: c.config.frameMaxSize,
        if err != nil {
@@ -164,5 +162,5 @@ func (c *conn) Query(query string, args []driver.Value) 
(driver.Rows, error) {
        // Currently there is only 1 ResultSet per response
        resultSet := res.(*message.ExecuteResponse).Results[0]
-       return NewRows(c, st.(*message.CreateStatementResponse).StatementId, 
resultSet), nil*/
+       return newRows(c, st.(*message.CreateStatementResponse).StatementId, 
resultSet), nil
diff --git a/driver_test.go b/driver_test.go
index a91f137..babc1c5 100644
--- a/driver_test.go
+++ b/driver_test.go
@@ -633,7 +633,7 @@ func TestRollingBackTransactions(t *testing.T) {
 func TestFetchingMoreRows(t *testing.T) {
-       query := "?maxRowCount=1"
+       query := "?maxRowsTotal=-1&frameMaxSize=1"
        runTests(t, dsn+query, func(dbt *DBTest) {
@@ -700,10 +700,9 @@ func TestExecuteShortcut(t *testing.T) {
-// This test needs to wait for CALCITE-1181 to be fixed
 func TestQueryShortcut(t *testing.T) {
-       query := "?maxRowCount=1"
+       query := "?maxRowsTotal=-1&frameMaxSize=1"
        runTests(t, dsn+query, func(dbt *DBTest) {
diff --git a/dsn.go b/dsn.go
index 3fc8e1c..0467a2c 100644
--- a/dsn.go
+++ b/dsn.go
@@ -9,19 +9,19 @@ import (
 // Config is a configuration parsed from a DSN string
 type Config struct {
-       endpoint         string
-       maxRowCount      uint64
-       fetchMaxRowCount uint32
-       location         *time.Location
+       endpoint     string
+       maxRowsTotal int64
+       frameMaxSize int32
+       location     *time.Location
 // ParseDSN parses a DSN string to a Config
 func ParseDSN(dsn string) (*Config, error) {
        conf := &Config{
-               maxRowCount:      100,
-               fetchMaxRowCount: 100,
-               location:         time.UTC,
+               maxRowsTotal: -1,
+               frameMaxSize: -1,
+               location:     time.UTC,
        parsed, err := url.ParseRequestURI(dsn)
@@ -32,20 +32,26 @@ func ParseDSN(dsn string) (*Config, error) {
        queries := parsed.Query()
-       if v := queries.Get("maxRowCount"); v != "" {
+       if v := queries.Get("maxRowsTotal"); v != "" {
-               maxRowCount, err := strconv.Atoi(v)
+               maxRowTotal, err := strconv.Atoi(v)
                if err != nil {
-                       return nil, fmt.Errorf("Invalid value for maxRowCount: 
%s", err)
+                       return nil, fmt.Errorf("Invalid value for maxRowsTotal: 
%s", err)
-               if maxRowCount <= 0 {
-                       return nil, fmt.Errorf("maxRowCount must be greater 
than 0")
+               conf.maxRowsTotal = int64(maxRowTotal)
+       }
+       if v := queries.Get("frameMaxSize"); v != "" {
+               maxRowTotal, err := strconv.Atoi(v)
+               if err != nil {
+                       return nil, fmt.Errorf("Invalid value for frameMaxSize: 
%s", err)
-               conf.fetchMaxRowCount = uint32(maxRowCount)
-               conf.maxRowCount = uint64(maxRowCount)
+               conf.frameMaxSize = int32(maxRowTotal)
        if v := queries.Get("location"); v != "" {
diff --git a/dsn_test.go b/dsn_test.go
index bd22f55..2cf9f6f 100644
--- a/dsn_test.go
+++ b/dsn_test.go
@@ -7,7 +7,7 @@ import (
 func TestParseDSN(t *testing.T) {
-       config, err := 
+       config, err := 
        if err != nil {
                t.Fatalf("Unexpected error: %s", err)
@@ -17,12 +17,12 @@ func TestParseDSN(t *testing.T) {
                t.Errorf("Expected endpoint to be %s, got %s", 
"http://localhost:8765";, config.endpoint)
-       if config.fetchMaxRowCount != 1 {
-               t.Errorf("Expected fetchMaxRowCount to be %d, got %d", 1, 
+       if config.frameMaxSize != 1 {
+               t.Errorf("Expected frameMaxSize to be %d, got %d", 1, 
-       if config.maxRowCount != 1 {
-               t.Errorf("Expected maxRowCount to be %d, got %d", 1, 
+       if config.maxRowsTotal != 1 {
+               t.Errorf("Expected maxRowsTotal to be %d, got %d", 1, 
        if config.location.String() != "Australia/Melbourne" {
@@ -51,12 +51,12 @@ func TestDSNDefaults(t *testing.T) {
                t.Error("There was no timezone set.")
-       if config.maxRowCount == 0 {
-               t.Error("There was no maxRowCount set.")
+       if config.maxRowsTotal == 0 {
+               t.Error("There was no maxRowsTotal set.")
-       if config.fetchMaxRowCount == 0 {
-               t.Error("There was no fetchMaxRowCount set.")
+       if config.frameMaxSize == 0 {
+               t.Error("There was no fetchMaxSize set.")
@@ -81,21 +81,15 @@ func TestBadInput(t *testing.T) {
                t.Fatal("Expected error due to invalid location, but did not 
receive any.")
-       _, err = ParseDSN("http://localhost:8765?maxRowCount=abc";)
+       _, err = ParseDSN("http://localhost:8765?maxRowsTotal=abc";)
        if err == nil {
-               t.Fatal("Expected error due to invalid maxRowCount, but did not 
receive any.")
+               t.Fatal("Expected error due to invalid maxRowsTotal, but did 
not receive any.")
-       _, err = ParseDSN("http://localhost:8765?maxRowCount=0";)
+       _, err = ParseDSN("http://localhost:8765?frameMaxSize=abc";)
        if err == nil {
-               t.Fatal("Expected error due to invalid maxRowCount, but did not 
receive any.")
-       }
-       _, err = ParseDSN("http://localhost:8765?maxRowCount=-1";)
-       if err == nil {
-               t.Fatal("Expected error due to invalid maxRowCount, but did not 
receive any.")
+               t.Fatal("Expected error due to invalid frameMaxSize, but did 
not receive any.")
diff --git a/gen-protobuf.bat b/gen-protobuf.bat
index c19b275..7fd1993 100644
--- a/gen-protobuf.bat
+++ b/gen-protobuf.bat
@@ -1,4 +1,4 @@
-SET CALCITE_VER=calcite-1.7.0
+SET CALCITE_VER=calcite-1.8.0
 rmdir /Q /S message
 rmdir /Q /S calcite-tmp
diff --git a/ b/
index 7dfebd4..fa7b459 100644
--- a/
+++ b/
@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
-export CALCITE_VER=calcite-1.7.0
+export CALCITE_VER=calcite-1.8.0
 rm -rf message
 rm -rf calcite-tmp
diff --git a/message/common.pb.go b/message/common.pb.go
index 510faf5..ec754d4 100644
--- a/message/common.pb.go
+++ b/message/common.pb.go
@@ -45,6 +45,9 @@ It has these top-level messages:
+       PrepareAndExecuteBatchRequest
+       UpdateBatch
+       ExecuteBatchRequest
@@ -61,6 +64,7 @@ It has these top-level messages:
+       ExecuteBatchResponse
 package message
@@ -707,7 +711,7 @@ type TypedValue struct {
        StringValue string 
        NumberValue int64  
        // includes numeric types and date/time types.
-       BytesValues []byte  
+       BytesValue  []byte  
        DoubleValue float64 
        Null        bool    `protobuf:"varint,7,opt,name=null" 
@@ -780,140 +784,140 @@ func init() {
 var fileDescriptor0 = []byte{
-       // 2157 bytes of a gzipped FileDescriptorProto
-       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x84, 0x58, 
0xcd, 0x6e, 0xdb, 0xd8,
-       0x15, 0xae, 0x2c, 0xc9, 0x96, 0x8e, 0x7e, 0x4c, 0xd1, 0x4e, 0xa2, 0x24, 
0x33, 0xd3, 0x54, 0x45,
-       0x3b, 0x33, 0x46, 0xa1, 0xa2, 0x99, 0x76, 0xd5, 0x15, 0x2d, 0xd1, 0x36, 
0x33, 0x92, 0xa8, 0xb9,
-       0xa4, 0xe2, 0xf1, 0x66, 0x08, 0x5a, 0xa2, 0x1d, 0x02, 0x32, 0xa9, 0x92, 
0x54, 0x02, 0xf5, 0x2d,
-       0xfa, 0x04, 0x2d, 0xfa, 0x10, 0x7d, 0x8f, 0x2e, 0x8a, 0xae, 0xba, 0x29, 
0x50, 0xa0, 0xdb, 0xbe,
-       0x41, 0xcf, 0x39, 0x97, 0x7f, 0xca, 0x0f, 0x66, 0x65, 0xde, 0xef, 0x7c, 
0xf7, 0xdc, 0xf3, 0x7f,
-       0xaf, 0x0c, 0xed, 0x65, 0xf8, 0xf0, 0x10, 0x06, 0xc3, 0x4d, 0x14, 0x26, 
0xe1, 0xe0, 0xaf, 0x07,
-       0x70, 0x3a, 0x0a, 0x83, 0xc0, 0x5b, 0x26, 0x7e, 0x18, 0xcc, 0xa3, 0x70, 
0xe3, 0x45, 0x89, 0xef,
-       0xc5, 0xea, 0x53, 0x68, 0xf8, 0xb1, 0xb3, 0xf2, 0xa3, 0x64, 0xd7, 0xaf, 
0xbc, 0xa8, 0x7c, 0xd5,
-       0x10, 0x47, 0x7e, 0x3c, 0xa6, 0xa5, 0xfa, 0x53, 0x68, 0xb9, 0xdb, 0x24, 
0x74, 0x48, 0x91, 0x9f,
-       0xf4, 0x0f, 0x58, 0x0a, 0x04, 0x8d, 0x18, 0x51, 0x7f, 0x09, 0xc7, 0x6f, 
0xdc, 0xd8, 0x29, 0x93,
-       0x8e, 0x98, 0xd4, 0x41, 0x58, 0x2b, 0x78, 0xcf, 0xa1, 0x19, 0x79, 0xee, 
0xca, 0x09, 0x83, 0xf5,
-       0xae, 0x5f, 0x65, 0x46, 0x83, 0x00, 0x13, 0xd7, 0xea, 0x00, 0x88, 0xed, 
0x14, 0x84, 0x06, 0x13,
-       0x5a, 0x08, 0x8a, 0x8c, 0xf3, 0x0d, 0x3c, 0x4a, 0x22, 0x37, 0x88, 0x5d, 
0xb6, 0xde, 0xf1, 0xe3,
-       0x70, 0xed, 0xd2, 0x57, 0xbf, 0x86, 0xdc, 0x8e, 0x38, 0x2d, 0x09, 0x8d, 
0x4c, 0xa6, 0xf6, 0xe1,
-       0x68, 0xe9, 0x26, 0xee, 0x3a, 0xbc, 0xef, 0xd7, 0x91, 0xd6, 0x14, 0xd9, 
0x52, 0x7d, 0x0c, 0x87,
-       0xf1, 0xf2, 0x8d, 0xf7, 0xe0, 0xf6, 0x0f, 0x59, 0x90, 0xae, 0x06, 0x1b, 
0x38, 0xb6, 0x12, 0x37,
-       0xf1, 0x1e, 0xbc, 0x20, 0xb9, 0x72, 0x83, 0xd5, 0xda, 0x53, 0x7f, 0x0e, 
0x9d, 0x65, 0x1e, 0x36,
-       0xc7, 0x5f, 0x71, 0x8c, 0x9a, 0xa2, 0x5d, 0x80, 0xc6, 0x4a, 0xed, 0xc2, 
0x01, 0x4a, 0x0e, 0xd8,
-       0x16, 0xfc, 0x52, 0xbf, 0x82, 0x66, 0xec, 0xdf, 0x07, 0x6e, 0xb2, 0x8d, 
0x3c, 0xf6, 0xb7, 0xf5,
-       0x12, 0x86, 0x56, 0x86, 0x88, 0x42, 0x38, 0xf8, 0x6f, 0x05, 0x9a, 0xb9, 
0x40, 0xfd, 0x1a, 0x2d,
-       0x0e, 0xd7, 0xdb, 0x87, 0x20, 0xc6, 0x63, 0xaa, 0xb8, 0xeb, 0x78, 0x38, 
0xe2, 0xf5, 0xd4, 0x4b,
-       0xdc, 0x31, 0x1a, 0x2f, 0x32, 0xb9, 0xaa, 0x40, 0x35, 0xfe, 0xc3, 0x9a, 
0xcf, 0x6c, 0x0a, 0xfa,
-       0x54, 0x7f, 0x03, 0xb0, 0x71, 0x23, 0xf7, 0xc1, 0x4b, 0xbc, 0x28, 0xc6, 
0x53, 0x69, 0x7f, 0x6f,
-       0xa8, 0xbd, 0xc5, 0x60, 0x2c, 0xdd, 0x79, 0x26, 0x11, 0x25, 0x92, 0xfa, 
0x3b, 0xe8, 0x2e, 0xb7,
-       0x51, 0x1c, 0x46, 0xce, 0x1d, 0x06, 0x2f, 0x8c, 0x76, 0x1c, 0xcf, 0xd6, 
0xcb, 0xee, 0x70, 0xc4,
-       0xf0, 0x85, 0x44, 0x45, 0x67, 0x59, 0x5e, 0xaa, 0xbf, 0x85, 0x4e, 0x9c, 
0x85, 0xc9, 0xde, 0x6d,
-       0x3c, 0x0e, 0x6f, 0x17, 0x77, 0x59, 0x65, 0x54, 0xec, 0x93, 0x06, 0x7f, 
0xaa, 0x43, 0x77, 0xdf,
-       0x1b, 0xca, 0x50, 0x18, 0xad, 0xfc, 0xc0, 0x5d, 0x73, 0x58, 0x3b, 0x22, 
0x5b, 0xaa, 0xbf, 0x80,
-       0x2e, 0x57, 0x95, 0x1f, 0x2c, 0x23, 0x56, 0x91, 0x56, 0x5f, 0x87, 0x50, 
0x23, 0x03, 0x89, 0xb6,
-       0x74, 0x63, 0xcf, 0x89, 0xbd, 0x20, 0xf6, 0x13, 0xff, 0xad, 0x97, 0x56, 
0x57, 0x87, 0x50, 0x2b,
-       0x03, 0xd5, 0x2f, 0x00, 0x62, 0xcf, 0x8d, 0x96, 0x6f, 0xdc, 0xdb, 0xb5, 
0xc7, 0x3e, 0x62, 0x1d,
-       0x17, 0x88, 0xfa, 0x0c, 0x1a, 0xe8, 0x61, 0xe4, 0x05, 0xcb, 0x1d, 0xfb, 
0x82, 0xe5, 0x99, 0xad,
-       0x49, 0x16, 0x6c, 0xd7, 0x6b, 0xde, 0x79, 0xc8, 0x46, 0xe6, 0x6b, 0xae, 
0x23, 0x4c, 0x9e, 0xb7,
-       0x4a, 0xcb, 0x3e, 0x5d, 0xa9, 0x3f, 0x83, 0xf6, 0xca, 0x8f, 0x37, 0x6b, 
0x77, 0xe7, 0xc4, 0xfe,
-       0x1f, 0x3d, 0xae, 0xe8, 0x8e, 0x68, 0xa5, 0x98, 0x85, 0x90, 0x7a, 0x0a, 
0x75, 0xd4, 0xe1, 0xad,
-       0xfb, 0x4d, 0xce, 0xa0, 0x5c, 0x50, 0xc7, 0xc9, 0x04, 0x3b, 0x01, 0xe6, 
0xa8, 0x0f, 0x2c, 0x03,
-       0x09, 0xcd, 0x10, 0x21, 0x82, 0xac, 0x55, 0x49, 0x68, 0x49, 0x82, 0x84, 
0x98, 0xf0, 0x19, 0x34,
-       0x37, 0x91, 0xb7, 0xf4, 0x63, 0xea, 0x8e, 0x36, 0x9f, 0x5b, 0x00, 0x74, 
0x6a, 0xbc, 0x74, 0xd1,
-       0x93, 0x0e, 0x4b, 0xe4, 0x42, 0xfd, 0x1c, 0x20, 0x21, 0x7f, 0xa4, 0xce, 
0x2e, 0xeb, 0x6c, 0x32,
-       0xc2, 0x2a, 0xd1, 0x9b, 0xb4, 0x71, 0x24, 0xe1, 0x98, 0x09, 0xad, 0x14, 
0x63, 0xca, 0x5e, 0x83,
-       0x2b, 0xef, 0x35, 0x38, 0x46, 0xf0, 0x5d, 0xe4, 0xb3, 0xbe, 0x7e, 0x4f, 
0xca, 0xb2, 0xb5, 0xfa,
-       0x6b, 0x38, 0x59, 0x79, 0x77, 0x7e, 0xe0, 0x27, 0xde, 0x7a, 0xe7, 0xe4, 
0x34, 0x95, 0x69, 0x6a,
-       0x21, 0xba, 0xce, 0x36, 0x9c, 0x41, 0x2f, 0x8d, 0xd0, 0x72, 0xed, 0xc6, 
0xb1, 0xb4, 0xe8, 0x84,
-       0x2d, 0x3a, 0x96, 0x82, 0x11, 0xe1, 0x6c, 0xd5, 0x0b, 0xa8, 0x25, 0x54, 
0x9e, 0xa7, 0x5c, 0xd4,
-       0xed, 0xac, 0x17, 0xb8, 0x38, 0x59, 0x32, 0xf8, 0x4b, 0x05, 0x5a, 0x25, 
0x34, 0x6d, 0xe4, 0x4a,
-       0xde, 0xc8, 0x2a, 0xd4, 0xf8, 0x00, 0xd9, 0x66, 0xfc, 0x8d, 0x49, 0xaf, 
0x46, 0xde, 0x86, 0x0b,
-       0xad, 0xfb, 0xb2, 0x36, 0x14, 0xde, 0x46, 0x10, 0x50, 0x6e, 0xde, 0xda, 
0x8f, 0x34, 0xef, 0x19,
-       0x34, 0x71, 0x5c, 0x6e, 0xc2, 0x80, 0x0a, 0xbb, 0xfe, 0x11, 0xeb, 0x0a, 
0xf1, 0xe0, 0x1f, 0x15,
-       0x50, 0xde, 0x6f, 0xe2, 0x52, 0xe1, 0x55, 0xf6, 0x0a, 0x6f, 0x2f, 0xfb, 
0x07, 0x9f, 0xcc, 0x7e,
-       0xb5, 0x9c, 0x7d, 0xec, 0xa1, 0x7c, 0x24, 0x38, 0x1c, 0x2f, 0x39, 0x54, 
0x3b, 0x39, 0xca, 0xa1,
-       0xc1, 0x14, 0x93, 0x50, 0x06, 0x5c, 0xce, 0xd3, 0x06, 0x01, 0x1c, 0x69, 
0xac, 0xa0, 0x52, 0x3a,
-       0xe4, 0x50, 0x6d, 0x2e, 0xf3, 0x44, 0x64, 0x61, 0x3c, 0x2a, 0xc2, 0x38, 
0xf8, 0x7b, 0x05, 0x3a,
-       0x7b, 0x53, 0x06, 0xa3, 0x52, 0x8f, 0x93, 0x1d, 0x9a, 0x57, 0xe1, 0xd0, 
0x9e, 0xee, 0x0f, 0x21,
-       0x1c, 0x2e, 0x28, 0x13, 0x92, 0xf2, 0xde, 0x81, 0x07, 0xef, 0x1f, 0x88, 
0x6d, 0x72, 0xe7, 0x7b,
-       0xeb, 0x15, 0x8b, 0xe5, 0x30, 0xc4, 0x36, 0x61, 0x88, 0xe4, 0xf1, 0xc0, 
0x86, 0x3a, 0xeb, 0x53,
-       0x01, 0x0e, 0xcd, 0xf3, 0x57, 0xfa, 0xc8, 0x56, 0x7e, 0x42, 0xdf, 0x42, 
0x1f, 0x99, 0x62, 0xac,
-       0x54, 0xd4, 0x47, 0xd0, 0x93, 0xdf, 0xce, 0x5c, 0x98, 0x24, 0x37, 0xcc, 
0x99, 0x72, 0xa0, 0x36,
-       0xa1, 0xae, 0x09, 0xa1, 0xdd, 0x28, 0x55, 0xb5, 0x01, 0xb5, 0x89, 0x61, 
0xd9, 0x4a, 0x4d, 0x3d,
-       0x82, 0xea, 0x54, 0x9b, 0x2b, 0xf5, 0xc1, 0x14, 0xea, 0x17, 0x91, 0xac, 
0x91, 0xc3, 0xf0, 0xee,
-       0x2e, 0xf6, 0x12, 0xf6, 0xa5, 0x26, 0xd2, 0x15, 0x05, 0x62, 0x85, 0x69, 
0x4d, 0x87, 0x19, 0x7f,
-       0xe3, 0x10, 0xac, 0x45, 0xe1, 0xbb, 0x6c, 0x62, 0x63, 0x41, 0x85, 0xef, 
0x04, 0x23, 0x83, 0xaf,
-       0xa1, 0x8a, 0x0b, 0xbc, 0x20, 0xeb, 0x6f, 0xdd, 0xf5, 0xd6, 0x4b, 0xef, 
0x84, 0x76, 0x5a, 0x56,
-       0xaf, 0x09, 0x13, 0x52, 0x34, 0x18, 0x83, 0x42, 0x25, 0x76, 0x8b, 0x63, 
0x2f, 0xbd, 0xdb, 0x77,
-       0x79, 0xd4, 0x2b, 0xa5, 0xe2, 0xc5, 0x02, 0xb9, 0xdb, 0x06, 0x7c, 0x6f, 
0xc5, 0x68, 0x05, 0x85,
-       0xa5, 0x00, 0x06, 0xaf, 0xa0, 0x75, 0xed, 0x47, 0xde, 0xd4, 0x8b, 0x63, 
0xf7, 0xde, 0xfb, 0xa8,
-       0x82, 0x2f, 0xe1, 0xf8, 0x5d, 0xe4, 0x6e, 0x36, 0xde, 0xca, 0x79, 0x90, 
0x34, 0x76, 0xa6, 0x2d,
-       0xba, 0x29, 0x9c, 0x6e, 0x1e, 0xfc, 0x0d, 0x5b, 0xab, 0x64, 0x28, 0x4e, 
0x91, 0x3d, 0x2f, 0x5a,
-       0x43, 0xaa, 0xaa, 0x55, 0xd9, 0x09, 0xf5, 0x57, 0xf8, 0xde, 0x88, 0x22, 
0x1c, 0x9a, 0x92, 0x78,
-       0xf0, 0x21, 0x11, 0x58, 0x2e, 0x15, 0x66, 0x8f, 0x8f, 0xd2, 0x8e, 0x6a, 
0xf1, 0xf8, 0x28, 0x78,
-       0x43, 0x68, 0x53, 0xa1, 0xbb, 0x51, 0x4a, 0x92, 0x57, 0xdc, 0x9e, 0xda, 
0x96, 0x24, 0xf0, 0x62,
-       0xf0, 0x9f, 0x0a, 0x40, 0x21, 0xa3, 0xf4, 0x70, 0x53, 0x54, 0x4a, 0xfd, 
0xce, 0x08, 0xd5, 0xe0,
-       0x6d, 0x18, 0xae, 0x73, 0x6b, 0xe9, 0xec, 0x26, 0x21, 0x99, 0xc3, 0xed, 
0x38, 0x89, 0xfc, 0xe0,
-       0xbe, 0x64, 0x1c, 0x8e, 0x4d, 0x89, 0xe5, 0x94, 0x60, 0xfb, 0x70, 0xeb, 
0x95, 0x4d, 0x53, 0x45,
-       0x4b, 0x62, 0x39, 0xe5, 0x76, 0x97, 0x78, 0xb1, 0x64, 0xc4, 0xdc, 0x79, 
0x6d, 0xd1, 0x62, 0x8c,
-       0x19, 0x31, 0xdf, 0x36, 0xe1, 0x96, 0xe6, 0xb7, 0xd4, 0x42, 0xed, 0x57, 
0xc1, 0xdb, 0x86, 0x31,
-       0xa9, 0x85, 0x32, 0x89, 0x97, 0x56, 0x7a, 0x4d, 0xf1, 0xf7, 0xe0, 0x7f, 
0x07, 0xf0, 0x34, 0x1b,
-       0x4d, 0x26, 0x56, 0x0c, 0x3f, 0x9a, 0xb4, 0xe8, 0x7e, 0xcb, 0x37, 0xeb, 
0xfb, 0xd6, 0x57, 0x3e,
-       0xb4, 0xfe, 0x47, 0xfc, 0xc7, 0x81, 0xe1, 0x07, 0x49, 0xc9, 0xf9, 0x9e, 
0x68, 0x20, 0x90, 0x25,
-       0xe5, 0x24, 0x55, 0x5f, 0xca, 0x9f, 0x1c, 0x9c, 0x4d, 0xd1, 0x93, 0xa2, 
0x22, 0x87, 0x31, 0xbe,
-       0xa8, 0x14, 0x52, 0xb6, 0x47, 0xae, 0x23, 0xb9, 0x27, 0xba, 0x88, 0x97, 
0x99, 0xbf, 0x4f, 0xf3,
-       0x75, 0xc8, 0xf9, 0xfa, 0x72, 0xf8, 0x49, 0x17, 0x87, 0xd9, 0x47, 0xe9, 
0x3e, 0xf8, 0x01, 0xda,
-       0x65, 0x94, 0x26, 0x82, 0x65, 0x0b, 0x63, 0x76, 0x89, 0xd3, 0x01, 0xfb, 
0xfd, 0xdc, 0x34, 0x27,
-       0x38, 0x1b, 0xb0, 0xdf, 0x8d, 0x99, 0x8d, 0xd3, 0xe0, 0x04, 0x8e, 0x85, 
0x3e, 0xd7, 0x35, 0x5b,
-       0x1f, 0x3b, 0x29, 0xaf, 0x8a, 0x2f, 0xb3, 0x76, 0x0e, 0x12, 0xad, 0x46, 
0x3b, 0x67, 0x8b, 0xc9,
-       0x04, 0x07, 0xc4, 0xbf, 0xb0, 0xb6, 0xbe, 0xdb, 0x7a, 0xd1, 0x8e, 0x5f, 
0x4a, 0xf8, 0x2e, 0x29,
-       0xd7, 0x16, 0xc8, 0xf7, 0x53, 0x61, 0xce, 0x47, 0x1e, 0x79, 0x03, 0x38, 
0x08, 0xb3, 0xbb, 0x47,
-       0xfd, 0xd0, 0x37, 0x81, 0x52, 0x8c, 0x6d, 0xcd, 0x8d, 0xee, 0xb3, 0x5b, 
0xe8, 0xd9, 0xa7, 0x23,
-       0x20, 0x98, 0x47, 0xbf, 0x00, 0x64, 0x23, 0xdd, 0xc7, 0xe9, 0xeb, 0xe7, 
0x88, 0x3b, 0x08, 0x45,
-       0x4f, 0x80, 0x3e, 0x1d, 0x32, 0xe2, 0x50, 0x5e, 0x34, 0xb8, 0xb4, 0xd0, 
0x8e, 0x47, 0x40, 0x5f,
-       0x0e, 0xda, 0x22, 0x4b, 0xaa, 0x8e, 0x2b, 0x73, 0x73, 0xf6, 0x67, 0x1c, 
0xea, 0x7b, 0x8f, 0x40,
-       0x8e, 0xa0, 0x3e, 0xc9, 0xe7, 0xab, 0x31, 0xb3, 0x74, 0x61, 0x63, 0x0c, 
0xf1, 0x7b, 0x31, 0x1f,
-       0x63, 0x90, 0x30, 0x8c, 0xf8, 0x3d, 0x46, 0x0e, 0x7e, 0x57, 0x25, 0xce, 
0x9c, 0x1a, 0x0d, 0xdb,
-       0xa9, 0x2e, 0x2e, 0x75, 0xa5, 0xae, 0x76, 0xa0, 0x69, 0xda, 0x57, 0xba, 
0x70, 0xc6, 0xd3, 0x89,
-       0x72, 0x48, 0xac, 0x91, 0xa0, 0x10, 0x2b, 0x47, 0x14, 0xdd, 0xb1, 0x30, 
0xe7, 0x4a, 0x83, 0x87,
-       0xf3, 0xc4, 0xd6, 0x85, 0xd2, 0x2c, 0xf1, 0xc7, 0x13, 0x05, 0x88, 0x33, 
0xd2, 0x30, 0x03, 0xad,
-       0xb3, 0x7f, 0x57, 0x71, 0xa8, 0xe2, 0x6d, 0x8d, 0xf3, 0x7d, 0x2e, 0x8c, 
0xa9, 0x61, 0x1b, 0xaf,
-       0x75, 0x87, 0xf2, 0xaa, 0x6b, 0x33, 0x34, 0x51, 0x85, 0x6e, 0x09, 0xbe, 
0xc1, 0x03, 0x2a, 0xfb,
-       0xd8, 0xe8, 0x4a, 0x13, 0x32, 0xf3, 0x05, 0x66, 0x5d, 0x99, 0x68, 0x6f, 
0x55, 0xed, 0x41, 0xa7,
-       0x00, 0x65, 0xea, 0xf7, 0xf6, 0x4e, 0x4c, 0x2c, 0x90, 0xfa, 0xfe, 0xde, 
0x8b, 0x89, 0xa9, 0xd9,
-       0xe8, 0xd1, 0x29, 0x28, 0x05, 0x38, 0x36, 0x17, 0xe7, 0x13, 0xf2, 0xad, 
0x05, 0x47, 0x99, 0x6d,
-       0x0d, 0x2e, 0x40, 0xb2, 0x88, 0xbd, 0x23, 0x3b, 0xb4, 0x11, 0x39, 0x0b, 
0xe4, 0xb7, 0x34, 0xa1,
-       0x45, 0x1b, 0xf0, 0x60, 0xfd, 0x12, 0xf1, 0x36, 0xdf, 0x50, 0x74, 0x64, 
0x87, 0x18, 0xf2, 0xa0,
-       0x2e, 0x07, 0x5b, 0xaa, 0x3f, 0x56, 0x8f, 0xa1, 0x75, 0x6e, 0x5c, 0x3a, 
0xd9, 0x8e, 0xa7, 0x19,
-       0x30, 0xd6, 0x47, 0xc6, 0x54, 0x9b, 0x28, 0xcf, 0xc8, 0xa5, 0x57, 0xda, 
0x6b, 0xcd, 0xb1, 0xbe,
-       0x9b, 0x38, 0xb6, 0x31, 0xd5, 0x15, 0x05, 0xef, 0x36, 0x75, 0x0f, 0xb2, 
0x6c, 0x6d, 0x3a, 0x57,
-       0x7a, 0x7b, 0x54, 0x4e, 0xac, 0x4a, 0xde, 0x33, 0xb4, 0xb0, 0x8d, 0x14, 
0x3b, 0xe1, 0x23, 0xd0,
-       0x8b, 0xac, 0x5f, 0x4e, 0x4b, 0x3d, 0xf6, 0x88, 0xbe, 0x67, 0x8b, 0xe9, 
0x39, 0xda, 0xf2, 0xb8,
-       0x74, 0x33, 0x3f, 0xc9, 0x3b, 0xa8, 0x5f, 0x5c, 0xc0, 0xcf, 0xd3, 0x8d, 
0x0b, 0x24, 0x7c, 0xa6,
-       0xb6, 0xa1, 0x31, 0x5d, 0x4c, 0x6c, 0xc3, 0xd2, 0x6d, 0xe5, 0xf3, 0xb3, 
0x1f, 0xa0, 0x61, 0x79,
-       0x6f, 0x3d, 0x7c, 0x33, 0xee, 0x28, 0xb0, 0x8b, 0xd9, 0xb7, 0x33, 0xf3, 
0x7a, 0xe6, 0x58, 0xfa,
-       0x6b, 0x5d, 0x18, 0xf6, 0x8d, 0xcc, 0xf3, 0x85, 0x66, 0x6b, 0x93, 0x02, 
0xe3, 0x3c, 0xeb, 0x42,
-       0x98, 0xa2, 0xc0, 0x0e, 0x68, 0xf7, 0xb5, 0x26, 0x66, 0x68, 0x5d, 0x81, 
0x56, 0xcf, 0xfe, 0x59,
-       0x83, 0xde, 0x07, 0x5d, 0x45, 0xfb, 0x2f, 0x75, 0xdb, 0xd1, 0x6c, 0xf4, 
0xe6, 0x7c, 0x61, 0xeb,
-       0x16, 0x9e, 0xf3, 0x1c, 0x9e, 0x10, 0x76, 0x8e, 0x51, 0x72, 0x84, 0x79, 
0xed, 0x18, 0x63, 0x7d,
-       0x66, 0x1b, 0x17, 0x06, 0x7a, 0x58, 0xa1, 0x49, 0x41, 0xc2, 0x11, 0x19, 
0x62, 0x5e, 0x5a, 0x78,
-       0xdc, 0x17, 0xf0, 0x8c, 0x91, 0x89, 0x81, 0x34, 0xcc, 0xcb, 0x85, 0x49, 
0xcf, 0x8f, 0x39, 0xb6,
-       0x83, 0x81, 0xea, 0xaa, 0xd8, 0xaa, 0x8f, 0x58, 0x6e, 0x4e, 0x16, 0xd3, 
0x19, 0x8a, 0x8c, 0xd7,
-       0xc6, 0x04, 0x53, 0x67, 0x61, 0xa5, 0x61, 0x5c, 0x0b, 0x91, 0x85, 0x65, 
0xf6, 0x04, 0x4e, 0x18,
-       0x10, 0xa6, 0x65, 0x39, 0x42, 0xbf, 0xd0, 0x85, 0x3e, 0x1b, 0xe9, 0x58, 
0x6a, 0x58, 0xfa, 0x24,
-       0xd0, 0xbf, 0x9f, 0x63, 0xcd, 0xe0, 0x90, 0xfa, 0x56, 0xbf, 0xb1, 0xb0, 
0xd6, 0xfa, 0x70, 0x4a,
-       0xf0, 0xc5, 0x62, 0xc6, 0x8f, 0x9d, 0x5c, 0x53, 0x83, 0x32, 0x5b, 0x96, 
0x58, 0x58, 0x81, 0xa9,
-       0x0e, 0x63, 0x5a, 0xd6, 0x01, 0x59, 0x08, 0x8c, 0xd9, 0x58, 0xff, 0x9e, 
0xcd, 0xc7, 0x92, 0xc4,
-       0x10, 0x12, 0x46, 0xd5, 0xad, 0x89, 0x1b, 0xc9, 0x6c, 0x67, 0x9e, 0xa0, 
0x77, 0x23, 0x7d, 0xbc,
-       0x10, 0x7a, 0x7e, 0x5c, 0x27, 0x53, 0x92, 0x8b, 0x2c, 0xac, 0x5a, 0x2c, 
0x3a, 0xc6, 0x2c, 0x7d,
-       0x31, 0x36, 0x73, 0xee, 0x71, 0xe6, 0xb5, 0x35, 0xba, 0xd2, 0xa7, 0x9a, 
0x85, 0xd5, 0x99, 0xea,
-       0x4d, 0x01, 0xe7, 0xda, 0xb0, 0xaf, 0x1c, 0x4d, 0x60, 0x70, 0x7b, 0x99, 
0x21, 0xd6, 0x02, 0xe3,
-       0xe9, 0xd8, 0x1a, 0xb6, 0x80, 0x85, 0x35, 0x8a, 0xdd, 0x58, 0x42, 0x6f, 
0xe6, 0x08, 0x9e, 0x64,
-       0xb1, 0x60, 0x52, 0x39, 0xcc, 0xa7, 0xf8, 0x0b, 0x01, 0x72, 0x89, 0x85, 
0x15, 0x9b, 0x6e, 0x97,
-       0x4c, 0xb9, 0xfd, 0x71, 0x16, 0x30, 0x5a, 0xca, 0x28, 0x3c, 0xa1, 0x02, 
0x25, 0x68, 0x31, 0xb6,
-       0x2d, 0xac, 0xe2, 0x34, 0x37, 0x58, 0x50, 0x56, 0x39, 0xd4, 0x4f, 0xcf, 
0x06, 0xd0, 0xcc, 0x2f,
-       0x01, 0xba, 0x67, 0xb0, 0x99, 0xb0, 0x8a, 0xa8, 0xba, 0x75, 0x5b, 0xc3, 
0x0e, 0xd2, 0x94, 0xca,
-       0xf9, 0x00, 0x5e, 0x84, 0xd1, 0xfd, 0xd0, 0xdd, 0xb8, 0xf8, 0xb3, 0x6f, 
0x88, 0x2f, 0x97, 0x25,
-       0xfe, 0x44, 0x1a, 0xba, 0xf2, 0x37, 0x82, 0xfc, 0x77, 0xcf, 0xed, 0x21, 
0xff, 0xf9, 0xe6, 0xff,
-       0x01, 0x00, 0x00, 0xff, 0xff, 0x14, 0x77, 0xc8, 0xb4, 0x05, 0x12, 0x00, 
+       // 2156 bytes of a gzipped FileDescriptorProto
+       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x84, 0x58, 
0xcd, 0x72, 0xdb, 0xc8,
+       0x11, 0x0e, 0x45, 0x52, 0x22, 0x9b, 0x3f, 0x02, 0x21, 0xd9, 0xa6, 0xed, 
0xdd, 0x8d, 0xc3, 0x54,
+       0xb2, 0xbb, 0xaa, 0x14, 0x53, 0xf1, 0x26, 0xa7, 0x9c, 0x20, 0x12, 0x92, 
0xe0, 0x25, 0x09, 0xee,
+       0x00, 0xb4, 0x56, 0x97, 0x45, 0x41, 0x24, 0x24, 0xa3, 0x8a, 0x02, 0x18, 
0x00, 0xb4, 0x8b, 0x79,
+       0x8b, 0x3c, 0x41, 0x52, 0x79, 0x88, 0xbc, 0x47, 0x0e, 0xa9, 0x9c, 0x72, 
0x49, 0x2e, 0xb9, 0xe6,
+       0x0d, 0xd2, 0xdd, 0x83, 0x3f, 0xfa, 0xa7, 0xf6, 0x24, 0xcc, 0xd7, 0xdf, 
0xcc, 0xf4, 0x74, 0x7f,
+       0xdd, 0x33, 0x14, 0xb4, 0x97, 0xe1, 0xc3, 0x43, 0x18, 0x0c, 0x37, 0x51, 
0x98, 0x84, 0x83, 0xbf,
+       0x1e, 0xc0, 0xe9, 0x28, 0x0c, 0x02, 0x6f, 0x99, 0xf8, 0x61, 0x30, 0x8f, 
0xc2, 0x8d, 0x17, 0x25,
+       0xbe, 0x17, 0xab, 0x4f, 0xa1, 0xe1, 0xc7, 0xce, 0xca, 0x8f, 0x92, 0x5d, 
0xbf, 0xf2, 0xa2, 0xf2,
+       0x55, 0x43, 0x1c, 0xf9, 0xf1, 0x98, 0x86, 0xea, 0x4f, 0xa1, 0xe5, 0x6e, 
0x93, 0xd0, 0xa1, 0x85,
+       0xfc, 0xa4, 0x7f, 0xc0, 0x56, 0x20, 0x68, 0xc4, 0x88, 0xfa, 0x4b, 0x38, 
0x7e, 0xe3, 0xc6, 0x4e,
+       0x99, 0x74, 0xc4, 0xa4, 0x0e, 0xc2, 0x5a, 0xc1, 0x7b, 0x0e, 0xcd, 0xc8, 
0x73, 0x57, 0x4e, 0x18,
+       0xac, 0x77, 0xfd, 0x2a, 0x33, 0x1a, 0x04, 0x98, 0x38, 0x56, 0x07, 0x40, 
0x6c, 0xa7, 0x20, 0x34,
+       0x98, 0xd0, 0x42, 0x50, 0x64, 0x9c, 0x6f, 0xe0, 0x51, 0x12, 0xb9, 0x41, 
0xec, 0xb2, 0xf7, 0x8e,
+       0x1f, 0x87, 0x6b, 0x97, 0xbe, 0xfa, 0x35, 0xe4, 0x76, 0xc4, 0x69, 0xc9, 
0x68, 0x64, 0x36, 0xb5,
+       0x0f, 0x47, 0x4b, 0x37, 0x71, 0xd7, 0xe1, 0x7d, 0xbf, 0x8e, 0xb4, 0xa6, 
0xc8, 0x86, 0xea, 0x63,
+       0x38, 0x8c, 0x97, 0x6f, 0xbc, 0x07, 0xb7, 0x7f, 0xc8, 0x86, 0x74, 0x34, 
0xd8, 0xc0, 0xb1, 0x95,
+       0xb8, 0x89, 0xf7, 0xe0, 0x05, 0xc9, 0x95, 0x1b, 0xac, 0xd6, 0x9e, 0xfa, 
0x73, 0xe8, 0x2c, 0xf3,
+       0xb0, 0x39, 0xfe, 0x8a, 0x63, 0xd4, 0x14, 0xed, 0x02, 0x34, 0x56, 0x6a, 
0x17, 0x0e, 0xd0, 0x72,
+       0xc0, 0xbe, 0xe0, 0x97, 0xfa, 0x15, 0x34, 0x63, 0xff, 0x3e, 0x70, 0x93, 
0x6d, 0xe4, 0xf1, 0x79,
+       0x5b, 0x2f, 0x61, 0x68, 0x65, 0x88, 0x28, 0x8c, 0x83, 0xff, 0x56, 0xa0, 
0x99, 0x1b, 0xd4, 0xaf,
+       0xd1, 0xe3, 0x70, 0xbd, 0x7d, 0x08, 0x62, 0xdc, 0xa6, 0x8a, 0xb3, 0x8e, 
0x87, 0x23, 0x1e, 0x4f,
+       0xbd, 0xc4, 0x1d, 0xa3, 0xf3, 0x22, 0xb3, 0xab, 0x0a, 0x54, 0xe3, 0x3f, 
0xac, 0x79, 0xcf, 0xa6,
+       0xa0, 0x4f, 0xf5, 0x37, 0x00, 0x1b, 0x37, 0x72, 0x1f, 0xbc, 0xc4, 0x8b, 
0x62, 0xdc, 0x95, 0xe6,
+       0xf7, 0x86, 0xda, 0x5b, 0x0c, 0xc6, 0xd2, 0x9d, 0x67, 0x16, 0x51, 0x22, 
0xa9, 0xbf, 0x83, 0xee,
+       0x72, 0x1b, 0xc5, 0x61, 0xe4, 0xdc, 0x61, 0xf0, 0xc2, 0x68, 0xc7, 0xf1, 
0x6c, 0xbd, 0xec, 0x0e,
+       0x47, 0x0c, 0x5f, 0x48, 0x54, 0x74, 0x96, 0xe5, 0xa1, 0xfa, 0x5b, 0xe8, 
0xc4, 0x59, 0x98, 0xec,
+       0xdd, 0xc6, 0xe3, 0xf0, 0x76, 0x71, 0x96, 0x55, 0x46, 0xc5, 0x3e, 0x69, 
0xf0, 0xa7, 0x3a, 0x74,
+       0xf7, 0x4f, 0x43, 0x19, 0x0a, 0xa3, 0x95, 0x1f, 0xb8, 0x6b, 0x0e, 0x6b, 
0x47, 0x64, 0x43, 0xf5,
+       0x17, 0xd0, 0x65, 0x55, 0xf9, 0xc1, 0x32, 0xe2, 0x25, 0x52, 0xf5, 0x75, 
0x08, 0x35, 0x32, 0x90,
+       0x68, 0x4b, 0x37, 0xf6, 0x9c, 0xd8, 0x0b, 0x62, 0x3f, 0xf1, 0xdf, 0x7a, 
0xa9, 0xba, 0x3a, 0x84,
+       0x5a, 0x19, 0xa8, 0x7e, 0x01, 0x10, 0x7b, 0x6e, 0xb4, 0x7c, 0xe3, 0xde, 
0xae, 0x3d, 0x3e, 0x23,
+       0xea, 0xb8, 0x40, 0xd4, 0x67, 0xd0, 0xc0, 0x13, 0x46, 0x5e, 0xb0, 0xdc, 
0xf1, 0x59, 0x50, 0x9e,
+       0xd9, 0x98, 0x6c, 0xc1, 0x76, 0xbd, 0xe6, 0x99, 0x87, 0xec, 0x64, 0x3e, 
0x66, 0x1d, 0x61, 0xf2,
+       0xbc, 0x55, 0x2a, 0xfb, 0x74, 0xa4, 0xfe, 0x0c, 0xda, 0x2b, 0x3f, 0xde, 
0xac, 0xdd, 0x9d, 0x13,
+       0xfb, 0x7f, 0xf4, 0x58, 0xd1, 0x1d, 0xd1, 0x4a, 0x31, 0x0b, 0x21, 0xf5, 
0x14, 0xea, 0xb8, 0x86,
+       0xb7, 0xee, 0x37, 0x39, 0x83, 0x72, 0x40, 0x15, 0x27, 0x13, 0xec, 0x04, 
0x98, 0xa3, 0x3e, 0xb0,
+       0x0d, 0x24, 0x34, 0x43, 0x84, 0x08, 0x52, 0xab, 0x92, 0xd0, 0x92, 0x04, 
0x09, 0x31, 0xe1, 0x33,
+       0x68, 0x6e, 0x22, 0x6f, 0xe9, 0xc7, 0x54, 0x1d, 0x6d, 0xde, 0xb7, 0x00, 
0x68, 0xd7, 0x78, 0xe9,
+       0xe2, 0x49, 0x3a, 0x6c, 0x91, 0x03, 0xf5, 0x73, 0x80, 0x84, 0xce, 0x23, 
0xd7, 0xec, 0xf2, 0x9a,
+       0x4d, 0x46, 0x78, 0x49, 0x3c, 0x4d, 0x5a, 0x38, 0x92, 0x70, 0xcc, 0x84, 
0x56, 0x8a, 0x31, 0x65,
+       0xaf, 0xc0, 0x95, 0xf7, 0x0a, 0x1c, 0x23, 0xf8, 0x2e, 0xf2, 0x79, 0xbd, 
0x7e, 0x4f, 0xda, 0xb2,
+       0xb1, 0xfa, 0x6b, 0x38, 0x59, 0x79, 0x77, 0x7e, 0xe0, 0x27, 0xde, 0x7a, 
0xe7, 0xe4, 0x34, 0x95,
+       0x69, 0x6a, 0x61, 0xba, 0xce, 0x26, 0x9c, 0x41, 0x2f, 0x8d, 0xd0, 0x72, 
0xed, 0xc6, 0xb1, 0xf4,
+       0xe8, 0x84, 0x3d, 0x3a, 0x96, 0x86, 0x11, 0xe1, 0xec, 0xd5, 0x0b, 0xa8, 
0x25, 0x24, 0xcf, 0x53,
+       0x16, 0x75, 0x3b, 0xab, 0x05, 0x16, 0x27, 0x5b, 0x06, 0x7f, 0xa9, 0x40, 
0xab, 0x84, 0xa6, 0x85,
+       0x5c, 0xc9, 0x0b, 0x59, 0x85, 0x1a, 0x6f, 0x20, 0xcb, 0x8c, 0xbf, 0x31, 
0xe9, 0xd5, 0xc8, 0xdb,
+       0xb0, 0xd0, 0xba, 0x2f, 0x6b, 0x43, 0xe1, 0x6d, 0x04, 0x01, 0xe5, 0xe2, 
0xad, 0xfd, 0x48, 0xf1,
+       0x9e, 0x41, 0x13, 0xdb, 0xe5, 0x26, 0x0c, 0x48, 0xd8, 0xf5, 0x8f, 0x78, 
0x57, 0x98, 0x07, 0xff,
+       0xa8, 0x80, 0xf2, 0x7e, 0x11, 0x97, 0x84, 0x57, 0xd9, 0x13, 0xde, 0x5e, 
0xf6, 0x0f, 0x3e, 0x99,
+       0xfd, 0x6a, 0x39, 0xfb, 0x58, 0x43, 0x79, 0x4b, 0x70, 0x38, 0x5e, 0xb2, 
0xa9, 0x76, 0x72, 0x94,
+       0x43, 0x83, 0x29, 0x26, 0xa3, 0x0c, 0xb8, 0xec, 0xa7, 0x0d, 0x02, 0x38, 
0xd2, 0xa8, 0xa0, 0x52,
+       0x3a, 0x64, 0x53, 0x6d, 0x2e, 0xf3, 0x44, 0x64, 0x61, 0x3c, 0x2a, 0xc2, 
0x38, 0xf8, 0x7b, 0x05,
+       0x3a, 0x7b, 0x5d, 0x06, 0xa3, 0x52, 0x8f, 0x93, 0x1d, 0xba, 0x57, 0xe1, 
0xd0, 0x9e, 0xee, 0x37,
+       0x21, 0x6c, 0x2e, 0x68, 0x13, 0x92, 0xf2, 0xde, 0x86, 0x07, 0xef, 0x6f, 
0x88, 0x65, 0x72, 0xe7,
+       0x7b, 0xeb, 0x15, 0x9b, 0x65, 0x33, 0xc4, 0x32, 0x61, 0x88, 0xec, 0xf1, 
0xc0, 0x86, 0x3a, 0xaf,
+       0xa7, 0x02, 0x1c, 0x9a, 0xe7, 0xaf, 0xf4, 0x91, 0xad, 0xfc, 0x84, 0xbe, 
0x85, 0x3e, 0x32, 0xc5,
+       0x58, 0xa9, 0xa8, 0x8f, 0xa0, 0x27, 0xbf, 0x9d, 0xb9, 0x30, 0xc9, 0x6e, 
0x98, 0x33, 0xe5, 0x40,
+       0x6d, 0x42, 0x5d, 0x13, 0x42, 0xbb, 0x51, 0xaa, 0x6a, 0x03, 0x6a, 0x13, 
0xc3, 0xb2, 0x95, 0x9a,
+       0x7a, 0x04, 0xd5, 0xa9, 0x36, 0x57, 0xea, 0x83, 0x29, 0xd4, 0x2f, 0x22, 
0xa9, 0x91, 0xc3, 0xf0,
+       0xee, 0x2e, 0xf6, 0x12, 0x3e, 0x4b, 0x4d, 0xa4, 0x23, 0x0a, 0xc4, 0x0a, 
0xd3, 0x9a, 0x36, 0x33,
+       0xfe, 0xc6, 0x26, 0x58, 0x8b, 0xc2, 0x77, 0x59, 0xc7, 0x46, 0x41, 0x85, 
0xef, 0x04, 0x23, 0x83,
+       0xaf, 0xa1, 0x8a, 0x03, 0xbc, 0x20, 0xeb, 0x6f, 0xdd, 0xf5, 0xd6, 0x4b, 
0xef, 0x84, 0x76, 0x2a,
+       0xab, 0xd7, 0x84, 0x09, 0x69, 0x1a, 0x8c, 0x41, 0x21, 0x89, 0xdd, 0x62, 
0xdb, 0x4b, 0xef, 0xf6,
+       0x5d, 0x1e, 0xf5, 0x4a, 0x49, 0xbc, 0x28, 0x90, 0xbb, 0x6d, 0xc0, 0xf7, 
0x56, 0x8c, 0x5e, 0x50,
+       0x58, 0x0a, 0x60, 0xf0, 0x0a, 0x5a, 0xd7, 0x7e, 0xe4, 0x4d, 0xbd, 0x38, 
0x76, 0xef, 0xbd, 0x8f,
+       0x2e, 0xf0, 0x25, 0x1c, 0xbf, 0x8b, 0xdc, 0xcd, 0xc6, 0x5b, 0x39, 0x0f, 
0x92, 0xc6, 0x87, 0x69,
+       0x8b, 0x6e, 0x0a, 0xa7, 0x93, 0x07, 0x7f, 0xc3, 0xd2, 0x2a, 0x39, 0x8a, 
0x5d, 0x64, 0xef, 0x14,
+       0xad, 0x21, 0xa9, 0x6a, 0x55, 0x3e, 0x84, 0xfa, 0x2b, 0x7c, 0x6f, 0x44, 
0x11, 0x36, 0x4d, 0x49,
+       0x3c, 0xf8, 0x90, 0x08, 0x6c, 0x97, 0x0b, 0x66, 0x8f, 0x8f, 0xd2, 0x8c, 
0x6a, 0xf1, 0xf8, 0x28,
+       0x78, 0x43, 0x68, 0x93, 0xd0, 0xdd, 0x28, 0x25, 0xc9, 0x2b, 0x6e, 0x6f, 
0xd9, 0x96, 0x24, 0xf0,
+       0x60, 0xf0, 0x9f, 0x0a, 0x40, 0x61, 0xa3, 0xf4, 0x70, 0x51, 0x54, 0x4a, 
0xf5, 0xce, 0x08, 0x69,
+       0xf0, 0x36, 0x0c, 0xd7, 0xb9, 0xb7, 0xb4, 0x77, 0x93, 0x90, 0xec, 0xc0, 
0xed, 0x38, 0x89, 0xfc,
+       0xe0, 0xbe, 0xe4, 0x1c, 0xb6, 0x4d, 0x89, 0xe5, 0x94, 0x60, 0xfb, 0x70, 
0xeb, 0x95, 0x5d, 0x53,
+       0x45, 0x4b, 0x62, 0x92, 0x82, 0x4a, 0xbe, 0xdd, 0x25, 0x5e, 0x9c, 0x32, 
0xea, 0x1c, 0x6b, 0x60,
+       0x28, 0x5f, 0x63, 0x15, 0x6e, 0xa9, 0x7b, 0x4b, 0x06, 0x15, 0x5f, 0x05, 
0xef, 0x1a, 0xc6, 0x24,
+       0x85, 0xf2, 0x88, 0x57, 0x56, 0x7a, 0x49, 0xf1, 0xf7, 0xe0, 0x7f, 0x07, 
0xf0, 0x34, 0x6b, 0x4c,
+       0x26, 0xea, 0x85, 0x9f, 0x4c, 0x5a, 0x74, 0xbf, 0xe5, 0x7b, 0xf5, 0x7d, 
0xdf, 0x2b, 0x1f, 0xfa,
+       0xfe, 0x23, 0xa7, 0xc7, 0x76, 0xe1, 0x07, 0x49, 0xe9, 0xe8, 0x3d, 0xd1, 
0x40, 0x20, 0x4b, 0xc9,
+       0x49, 0xba, 0x7c, 0x29, 0x7b, 0xb2, 0x6d, 0x36, 0x45, 0x4f, 0x9a, 0x8a, 
0x0c, 0xc6, 0xf8, 0x9e,
+       0x52, 0x68, 0xb1, 0x3d, 0x72, 0x1d, 0xc9, 0x3d, 0xd1, 0x45, 0xbc, 0xcc, 
0xfc, 0x7d, 0x9a, 0xad,
+       0x43, 0xce, 0xd6, 0x97, 0xc3, 0x4f, 0x1e, 0x71, 0x98, 0x7d, 0x94, 0x6e, 
0x83, 0x1f, 0xa0, 0x5d,
+       0x46, 0xa9, 0x1f, 0x58, 0xb6, 0x30, 0x66, 0x97, 0xd8, 0x1b, 0xb0, 0xda, 
0xcf, 0x4d, 0x73, 0x82,
+       0x9d, 0x01, 0xab, 0xdd, 0x98, 0xd9, 0xd8, 0x0b, 0x4e, 0xe0, 0x58, 0xe8, 
0x73, 0x5d, 0xb3, 0xf5,
+       0xb1, 0x93, 0xf2, 0xaa, 0xf8, 0x2e, 0x6b, 0xe7, 0x20, 0xd1, 0x6a, 0x34, 
0x73, 0xb6, 0x98, 0x4c,
+       0xb0, 0x3d, 0xfc, 0x0b, 0x95, 0xf5, 0xdd, 0xd6, 0x8b, 0x76, 0xfc, 0x4e, 
0xc2, 0x57, 0x49, 0x59,
+       0x59, 0x20, 0x5f, 0x4f, 0x85, 0x3b, 0x1f, 0x79, 0xe2, 0x0d, 0xe0, 0x20, 
0xcc, 0x6e, 0x1e, 0xf5,
+       0xc3, 0xb3, 0x09, 0xb4, 0x62, 0x6c, 0x6b, 0x6e, 0x74, 0x9f, 0xdd, 0x41, 
0xcf, 0x3e, 0x1d, 0x01,
+       0xc1, 0x3c, 0x7a, 0xff, 0xcb, 0x32, 0xba, 0x8f, 0xd3, 0xb7, 0xcf, 0x11, 
0xd7, 0x0f, 0x9a, 0x9e,
+       0x00, 0x7d, 0x3a, 0xe4, 0xc4, 0xa1, 0xbc, 0x66, 0x70, 0x68, 0xa1, 0x1f, 
0x8f, 0x80, 0xbe, 0x1c,
+       0xf4, 0x45, 0x4a, 0xaa, 0x8e, 0x23, 0x73, 0x73, 0xf6, 0x67, 0x6c, 0xe9, 
0x7b, 0x4f, 0x40, 0x8e,
+       0xa0, 0x3e, 0xc9, 0xbb, 0xab, 0x31, 0xb3, 0x74, 0x61, 0x63, 0x0c, 0xf1, 
0x7b, 0x31, 0x1f, 0x63,
+       0x90, 0x30, 0x8c, 0xf8, 0x3d, 0x46, 0x0e, 0x7e, 0x57, 0x25, 0xce, 0x9c, 
0x1a, 0xb5, 0xda, 0xa9,
+       0x2e, 0x2e, 0x75, 0xa5, 0xae, 0x76, 0xa0, 0x69, 0xda, 0x57, 0xba, 0x70, 
0xc6, 0xd3, 0x89, 0x72,
+       0x48, 0xac, 0x91, 0xa0, 0x10, 0x2b, 0x47, 0x14, 0xdd, 0xb1, 0x30, 0xe7, 
0x4a, 0x83, 0x5b, 0xf3,
+       0xc4, 0xd6, 0x85, 0xd2, 0x2c, 0xf1, 0xc7, 0x13, 0x05, 0x88, 0x33, 0xd2, 
0x30, 0x03, 0xad, 0xb3,
+       0x7f, 0x57, 0xb1, 0xa5, 0xe2, 0x5d, 0x8d, 0xdd, 0x7d, 0x2e, 0x8c, 0xa9, 
0x61, 0x1b, 0xaf, 0x75,
+       0x87, 0xf2, 0xaa, 0x6b, 0x33, 0x74, 0x51, 0x85, 0x6e, 0x09, 0xbe, 0xc1, 
0x0d, 0x2a, 0xfb, 0xd8,
+       0xe8, 0x4a, 0x13, 0x32, 0xf3, 0x05, 0x66, 0x5d, 0x99, 0xe8, 0x6f, 0x55, 
0xed, 0x41, 0xa7, 0x00,
+       0x65, 0xea, 0xf7, 0xe6, 0x4e, 0x4c, 0x14, 0x48, 0x7d, 0x7f, 0xee, 0xc5, 
0xc4, 0xd4, 0x6c, 0x3c,
+       0xd1, 0x29, 0x28, 0x05, 0x38, 0x36, 0x17, 0xe7, 0x13, 0x3a, 0x5b, 0x0b, 
0x8e, 0x32, 0xdf, 0x1a,
+       0x2c, 0x40, 0xf2, 0x88, 0x4f, 0x47, 0x7e, 0x68, 0x23, 0x3a, 0x2c, 0xd0, 
0xb9, 0xa5, 0x0b, 0x2d,
+       0x9a, 0x80, 0x1b, 0xeb, 0x97, 0x88, 0xb7, 0xf9, 0x7e, 0xa2, 0x2d, 0x3b, 
0xc4, 0x90, 0x1b, 0x75,
+       0x39, 0xd8, 0x72, 0xf9, 0x63, 0xf5, 0x18, 0x5a, 0xe7, 0xc6, 0xa5, 0x93, 
0xcd, 0x78, 0x9a, 0x01,
+       0x63, 0x7d, 0x64, 0x4c, 0xb5, 0x89, 0xf2, 0x8c, 0x8e, 0xf4, 0x4a, 0x7b, 
0xad, 0x39, 0xd6, 0x77,
+       0x13, 0xc7, 0x36, 0xa6, 0xba, 0xa2, 0xe0, 0xcd, 0xa6, 0xee, 0x41, 0x96, 
0xad, 0x4d, 0xe7, 0x4a,
+       0x6f, 0x8f, 0xca, 0x89, 0x55, 0xe9, 0xf4, 0x0c, 0x2d, 0x6c, 0x23, 0xc5, 
0x4e, 0x78, 0x0b, 0x3c,
+       0x45, 0x56, 0x2f, 0xa7, 0xa5, 0x1a, 0x7b, 0x44, 0xdf, 0xb3, 0xc5, 0xf4, 
0x1c, 0x7d, 0x79, 0x5c,
+       0xba, 0x97, 0x9f, 0xe4, 0x15, 0xd4, 0x2f, 0xae, 0xdf, 0xe7, 0xe9, 0xc4, 
0x05, 0x12, 0x3e, 0x53,
+       0xdb, 0xd0, 0x98, 0x2e, 0x26, 0xb6, 0x61, 0xe9, 0xb6, 0xf2, 0xf9, 0xd9, 
0x0f, 0xd0, 0xb0, 0xbc,
+       0xb7, 0x1e, 0xbe, 0x18, 0x77, 0x14, 0xd8, 0xc5, 0xec, 0xdb, 0x99, 0x79, 
0x3d, 0x73, 0x2c, 0xfd,
+       0xb5, 0x2e, 0x0c, 0xfb, 0x46, 0xe6, 0xf9, 0x42, 0xb3, 0xb5, 0x49, 0x81, 
0x71, 0x9e, 0x75, 0x21,
+       0x4c, 0x51, 0x60, 0x07, 0x34, 0xfb, 0x5a, 0x13, 0x33, 0xf4, 0xae, 0x40, 
0xab, 0x67, 0xff, 0xac,
+       0x41, 0xef, 0x83, 0xaa, 0xa2, 0xf9, 0x97, 0xba, 0xed, 0x68, 0x36, 0x9e, 
0xe6, 0x7c, 0x61, 0xeb,
+       0x16, 0xee, 0xf3, 0x1c, 0x9e, 0x10, 0x76, 0x8e, 0x51, 0x72, 0x84, 0x79, 
0xed, 0x18, 0x63, 0x7d,
+       0x66, 0x1b, 0x17, 0x06, 0x9e, 0xb0, 0x42, 0x9d, 0x82, 0x8c, 0x23, 0x72, 
0xc4, 0xbc, 0xb4, 0x70,
+       0xbb, 0x2f, 0xe0, 0x19, 0x23, 0x13, 0x03, 0x69, 0x98, 0x97, 0x0b, 0x93, 
0x1e, 0x1f, 0x73, 0x2c,
+       0x07, 0x03, 0x97, 0xab, 0x62, 0xa9, 0x3e, 0x62, 0xbb, 0x39, 0x59, 0x4c, 
0x67, 0x68, 0x32, 0x5e,
+       0x1b, 0x13, 0x4c, 0x9d, 0x85, 0x4a, 0xc3, 0xb8, 0x16, 0x26, 0x0b, 0x65, 
0xf6, 0x04, 0x4e, 0x18,
+       0x10, 0xa6, 0x65, 0x39, 0x42, 0xbf, 0xd0, 0x85, 0x3e, 0x1b, 0xe9, 0x28, 
0x35, 0x94, 0x3e, 0x19,
+       0xf4, 0xef, 0xe7, 0xa8, 0x19, 0x6c, 0x52, 0xdf, 0xea, 0x37, 0x16, 0x6a, 
0xad, 0x0f, 0xa7, 0x04,
+       0x5f, 0x2c, 0x66, 0xfc, 0xd4, 0xc9, 0x57, 0x6a, 0x50, 0x66, 0xcb, 0x16, 
0x0b, 0x15, 0x98, 0xae,
+       0x61, 0x4c, 0xcb, 0x6b, 0x40, 0x16, 0x02, 0x63, 0x36, 0xd6, 0xbf, 0x67, 
0xf7, 0x51, 0x92, 0x18,
+       0x42, 0xc2, 0x48, 0xdd, 0x9a, 0xb8, 0x91, 0xcc, 0x76, 0x76, 0x12, 0x3c, 
0xdd, 0x48, 0x1f, 0x2f,
+       0x84, 0x9e, 0x6f, 0xd7, 0xc9, 0x16, 0xc9, 0x4d, 0x16, 0xaa, 0x16, 0x45, 
0xc7, 0x98, 0xa5, 0x2f,
+       0xc6, 0x66, 0xce, 0x3d, 0xce, 0x4e, 0x6d, 0x8d, 0xae, 0xf4, 0xa9, 0x66, 
0xa1, 0x3a, 0xd3, 0x75,
+       0x53, 0xc0, 0xb9, 0x36, 0xec, 0x2b, 0x47, 0x13, 0x18, 0xdc, 0x5e, 0xe6, 
0x88, 0xb5, 0xc0, 0x78,
+       0x3a, 0xb6, 0x86, 0x25, 0x60, 0xa1, 0x46, 0xb1, 0x1a, 0x4b, 0xe8, 0xcd, 
0x1c, 0xc1, 0x93, 0x2c,
+       0x16, 0x4c, 0x2a, 0x87, 0xf9, 0x14, 0x7f, 0x1f, 0x40, 0x6e, 0xb1, 0x50, 
0xb1, 0xe9, 0x74, 0xc9,
+       0x94, 0xd3, 0x1f, 0x67, 0x01, 0xa3, 0xa1, 0x8c, 0xc2, 0x13, 0x12, 0x28, 
0x41, 0x8b, 0xb1, 0x6d,
+       0xa1, 0x8a, 0xd3, 0xdc, 0xa0, 0xa0, 0xac, 0x72, 0xa8, 0x9f, 0x9e, 0x0d, 
0xa0, 0x99, 0x5f, 0x02,
+       0x74, 0xcf, 0x60, 0x31, 0xa1, 0x8a, 0x48, 0xdd, 0xba, 0xad, 0x61, 0x05, 
0x69, 0x4a, 0xe5, 0x7c,
+       0x00, 0x2f, 0xc2, 0xe8, 0x7e, 0xe8, 0x6e, 0x5c, 0xfc, 0xd1, 0x37, 0xc4, 
0x77, 0xcb, 0x12, 0x7f,
+       0x20, 0x0d, 0x5d, 0xf9, 0x0b, 0x41, 0xfe, 0xb3, 0xe7, 0xf6, 0x90, 0xff, 
0x7c, 0xf3, 0xff, 0x00,
+       0x00, 0x00, 0xff, 0xff, 0x30, 0x15, 0x1a, 0xdd, 0x03, 0x12, 0x00, 0x00,
diff --git a/message/requests.pb.go b/message/requests.pb.go
index c0ca693..8a1415b 100644
--- a/message/requests.pb.go
+++ b/message/requests.pb.go
@@ -98,10 +98,12 @@ func (*TypeInfoRequest) Descriptor() ([]byte, []int) { 
return fileDescriptor1, [
 // Request for Meta#prepareAndExecute(Meta.StatementHandle, String, long, 
 type PrepareAndExecuteRequest struct {
-       ConnectionId string 
-       Sql          string `protobuf:"bytes,2,opt,name=sql" 
-       MaxRowCount  uint64 
-       StatementId  uint32 
+       ConnectionId      string 
+       Sql               string `protobuf:"bytes,2,opt,name=sql" 
+       MaxRowCount       uint64 
+       StatementId       uint32 
+       MaxRowsTotal      int64  
+       FirstFrameMaxSize int32  
 func (m *PrepareAndExecuteRequest) Reset()                    { *m = 
PrepareAndExecuteRequest{} }
@@ -114,6 +116,7 @@ type PrepareRequest struct {
        ConnectionId string 
        Sql          string `protobuf:"bytes,2,opt,name=sql" 
        MaxRowCount  uint64 
+       MaxRowsTotal int64  
 func (m *PrepareRequest) Reset()                    { *m = PrepareRequest{} }
@@ -127,6 +130,7 @@ type FetchRequest struct {
        StatementId      uint32 
        Offset           uint64 `protobuf:"varint,3,opt,name=offset" 
        FetchMaxRowCount uint32 
+       FrameMaxSize     int32  
 func (m *FetchRequest) Reset()                    { *m = FetchRequest{} }
@@ -204,7 +208,7 @@ func (m *ConnectionSyncRequest) GetConnProps() 
*ConnectionProperties {
 type ExecuteRequest struct {
        StatementHandle    *StatementHandle 
`protobuf:"bytes,1,opt,name=statementHandle" json:"statementHandle,omitempty"`
        ParameterValues    []*TypedValue    
-       MaxRowCount        uint64           
+       FirstFrameMaxSize  uint64           
        HasParameterValues bool             
@@ -266,6 +270,53 @@ func (m *RollbackRequest) String() string            { 
return proto.CompactTextS
 func (*RollbackRequest) ProtoMessage()               {}
 func (*RollbackRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, 
[]int{18} }
+// Request to prepare and execute a collection of sql statements.
+type PrepareAndExecuteBatchRequest struct {
+       ConnectionId string   
+       StatementId  uint32   
+       SqlCommands  []string 
+func (m *PrepareAndExecuteBatchRequest) Reset()                    { *m = 
PrepareAndExecuteBatchRequest{} }
+func (m *PrepareAndExecuteBatchRequest) String() string            { return 
proto.CompactTextString(m) }
+func (*PrepareAndExecuteBatchRequest) ProtoMessage()               {}
+func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int) { return 
fileDescriptor1, []int{19} }
+// Each command is a list of TypedValues
+type UpdateBatch struct {
+       ParameterValues []*TypedValue 
+func (m *UpdateBatch) Reset()                    { *m = UpdateBatch{} }
+func (m *UpdateBatch) String() string            { return 
proto.CompactTextString(m) }
+func (*UpdateBatch) ProtoMessage()               {}
+func (*UpdateBatch) Descriptor() ([]byte, []int) { return fileDescriptor1, 
[]int{20} }
+func (m *UpdateBatch) GetParameterValues() []*TypedValue {
+       if m != nil {
+               return m.ParameterValues
+       }
+       return nil
+type ExecuteBatchRequest struct {
+       ConnectionId string         
+       StatementId  uint32         
+       Updates      []*UpdateBatch `protobuf:"bytes,3,rep,name=updates" 
+func (m *ExecuteBatchRequest) Reset()                    { *m = 
ExecuteBatchRequest{} }
+func (m *ExecuteBatchRequest) String() string            { return 
proto.CompactTextString(m) }
+func (*ExecuteBatchRequest) ProtoMessage()               {}
+func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) { return 
fileDescriptor1, []int{21} }
+func (m *ExecuteBatchRequest) GetUpdates() []*UpdateBatch {
+       if m != nil {
+               return m.Updates
+       }
+       return nil
 func init() {
        proto.RegisterType((*CatalogsRequest)(nil), "CatalogsRequest")
@@ -286,54 +337,66 @@ func init() {
        proto.RegisterType((*SyncResultsRequest)(nil), "SyncResultsRequest")
        proto.RegisterType((*CommitRequest)(nil), "CommitRequest")
        proto.RegisterType((*RollbackRequest)(nil), "RollbackRequest")
+       proto.RegisterType((*PrepareAndExecuteBatchRequest)(nil), 
+       proto.RegisterType((*UpdateBatch)(nil), "UpdateBatch")
+       proto.RegisterType((*ExecuteBatchRequest)(nil), "ExecuteBatchRequest")
 var fileDescriptor1 = []byte{
-       // 730 bytes of a gzipped FileDescriptorProto
-       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xc4, 0x56, 
0x4b, 0x6f, 0xd3, 0x40,
-       0x10, 0x96, 0x9b, 0xf4, 0x91, 0xc9, 0xa3, 0xa9, 0xfb, 0x20, 0x2a, 0x97, 
0xd4, 0x08, 0xa9, 0x07,
-       0xb0, 0x50, 0xa9, 0x4a, 0x55, 0x09, 0x24, 0x30, 0x45, 0x54, 0xe2, 0x11, 
0x9c, 0x8a, 0xab, 0xb5,
-       0xd9, 0x6c, 0x5a, 0xab, 0xf6, 0xae, 0xeb, 0x5d, 0xb7, 0xcd, 0x2f, 0x81, 
0x0b, 0xbf, 0x80, 0xbf,
-       0xc3, 0x89, 0x33, 0x3f, 0x84, 0xdd, 0xb5, 0xe3, 0x26, 0x4d, 0x0e, 0x75, 
0x55, 0xc4, 0x29, 0x99,
-       0x99, 0x6f, 0x5e, 0xdf, 0xee, 0xcc, 0x1a, 0x1a, 0x31, 0x39, 0x4f, 0x08, 
0x17, 0xdc, 0x8e, 0x62,
-       0x26, 0xd8, 0x66, 0x0d, 0xb3, 0x30, 0x64, 0x34, 0x95, 0xac, 0x3d, 0x58, 
0x76, 0x90, 0x40, 0x01,
-       0x3b, 0xe1, 0x6e, 0x8a, 0x33, 0x1f, 0x41, 0x1d, 0x33, 0x4a, 0x09, 0x16, 
0x3e, 0xa3, 0x9e, 0xdf,
-       0x6f, 0x19, 0x6d, 0x63, 0xbb, 0xe2, 0xd6, 0xae, 0x95, 0x47, 0x7d, 0xeb, 
0x15, 0x3c, 0x78, 0x2b,
-       0xfd, 0x7a, 0x88, 0x93, 0x4e, 0xcc, 0x22, 0x12, 0x8b, 0x61, 0x21, 0xff, 
0x0b, 0x68, 0x74, 0xf1,
-       0x29, 0x09, 0x51, 0x9e, 0xb6, 0x05, 0x8b, 0x38, 0xad, 0x24, 0x73, 0x18, 
0x89, 0xe6, 0x63, 0x68,
-       0x70, 0x8d, 0xf5, 0x22, 0x24, 0x04, 0x89, 0x69, 0x6b, 0x4e, 0x03, 0xea, 
0xa9, 0xb6, 0x93, 0x2a,
-       0xa7, 0xf3, 0x96, 0x66, 0xe4, 0xfd, 0x63, 0x40, 0xfd, 0x18, 0xf5, 0x02, 
0x72, 0x7f, 0x79, 0x9f,
-       0x80, 0x29, 0x54, 0x44, 0x8f, 0xa2, 0x90, 0xe4, 0xd0, 0x34, 0x79, 0x53, 
0x5b, 0x3e, 0x49, 0xc3,
-       0x08, 0xfd, 0x10, 0x2a, 0x62, 0x18, 0x11, 0x2f, 0xf0, 0xb9, 0x68, 0x95, 
0xdb, 0x25, 0x09, 0x5a,
-       0x52, 0x8a, 0x0f, 0x52, 0x36, 0x2d, 0xa8, 0x9f, 0x22, 0xee, 0x5d, 0x03, 
0x16, 0x64, 0x94, 0x25,
-       0xb7, 0x2a, 0x95, 0xc7, 0x23, 0xcc, 0x54, 0x9b, 0x8b, 0x33, 0xda, 0xdc, 
0x87, 0x15, 0xdd, 0xa5,
-       0xf2, 0x2a, 0x76, 0xb0, 0xbf, 0x0c, 0x68, 0x38, 0x2c, 0x48, 0x42, 0xfa, 
0xbf, 0x18, 0xb2, 0x61,
-       0x15, 0xeb, 0x02, 0x26, 0xe1, 0x65, 0x0d, 0x5f, 0x49, 0x4d, 0xe3, 0xf8, 
0xa9, 0xb6, 0xe6, 0x67,
-       0xb4, 0x25, 0xef, 0xb9, 0xe2, 0xe2, 0x88, 0x0e, 0x58, 0x21, 0x3a, 0xbe, 
0x1b, 0xd0, 0xea, 0xc4,
-       0x24, 0x42, 0x31, 0x79, 0x4d, 0xfb, 0x87, 0x57, 0x04, 0x27, 0x82, 0x14, 
0x89, 0x60, 0x36, 0xa1,
-       0xc4, 0xcf, 0x83, 0x8c, 0x18, 0xf5, 0x57, 0x9d, 0x72, 0x88, 0xae, 0xbc, 
0x98, 0x5d, 0x7a, 0x98,
-       0x25, 0x54, 0x68, 0x26, 0xca, 0x6e, 0x55, 0x2a, 0x5d, 0x76, 0xe9, 0x28, 
0x95, 0xb9, 0x05, 0x35,
-       0x2e, 0x90, 0x20, 0x21, 0xa1, 0x42, 0x45, 0x56, 0xdd, 0xd7, 0xdd, 0x6a, 
0xae, 0x93, 0xa5, 0x9d,
-       0x41, 0x23, 0xab, 0xec, 0xdf, 0xd7, 0x63, 0xfd, 0x30, 0xa0, 0xf6, 0x8e, 
0x08, 0x7c, 0x5a, 0x28,
-       0xd7, 0xcd, 0x2e, 0xe6, 0xa6, 0xba, 0x30, 0x37, 0x60, 0x81, 0x0d, 0x06, 
0x9c, 0x8c, 0xb2, 0x66,
-       0x92, 0xf9, 0x14, 0x56, 0x07, 0x2a, 0x9f, 0x37, 0x59, 0x5a, 0xca, 0x43, 
0x53, 0x9b, 0x3e, 0x8e,
-       0xd5, 0xf7, 0x12, 0x36, 0x9c, 0x98, 0xc8, 0xb0, 0xdd, 0x51, 0xec, 0x42, 
0xc7, 0xec, 0xc1, 0xba,
-       0x13, 0x30, 0x7e, 0x37, 0xef, 0x5b, 0xb4, 0x69, 0xfd, 0x34, 0x60, 0xfd, 
0x73, 0x44, 0xa8, 0x93,
-       0xfb, 0x15, 0xca, 0xb0, 0x0b, 0x65, 0x5f, 0x5e, 0x5d, 0x19, 0xb9, 0xb4, 
0x5d, 0xdd, 0x69, 0xdb,
-       0x33, 0x43, 0xd9, 0xea, 0x76, 0x1f, 0x52, 0x11, 0x0f, 0x5d, 0x8d, 0xde, 
0x7c, 0x01, 0x95, 0x5c,
-       0xa5, 0xce, 0xfd, 0x8c, 0x0c, 0xb3, 0xe8, 0xea, 0xaf, 0xb9, 0x06, 0xf3, 
0x17, 0x28, 0x48, 0x48,
-       0x76, 0x17, 0x52, 0xe1, 0x60, 0x6e, 0xdf, 0xd0, 0x6c, 0x2a, 0x3a, 0xee, 
0x56, 0xad, 0x15, 0x4b,
-       0x36, 0x73, 0xb9, 0x3b, 0xa4, 0xb8, 0x60, 0xaf, 0xa0, 0x64, 0x4f, 0x3e, 
0x50, 0x11, 0xd7, 0xb5,
-       0x55, 0x77, 0xd6, 0xed, 0xeb, 0x80, 0xd9, 0x7b, 0xe3, 0xcb, 0xc5, 0x56, 
0x51, 0x40, 0x25, 0x73,
-       0xeb, 0xb7, 0xdc, 0x5b, 0x37, 0xc6, 0xf3, 0x00, 0x96, 0xf3, 0x23, 0x78, 
0x8f, 0x68, 0x3f, 0x20,
-       0x3a, 0x5f, 0x75, 0xa7, 0x69, 0x77, 0x27, 0xf5, 0xee, 0x4d, 0xa0, 0xb9, 
0x07, 0x4d, 0x39, 0x59,
-       0x72, 0xcb, 0xc8, 0x15, 0xe3, 0x69, 0x62, 0x78, 0x46, 0x7e, 0xd5, 0x56, 
0x8b, 0xa4, 0xff, 0x55,
-       0xe9, 0xdc, 0xe5, 0x1c, 0xa4, 0x65, 0x7e, 0xab, 0xd9, 0x7e, 0x06, 0x6b, 
0x6a, 0xcb, 0x4f, 0xc5,
-       0x2f, 0xeb, 0x65, 0x6f, 0x4a, 0x5b, 0x67, 0x32, 0xaa, 0xf5, 0xcd, 0x00, 
0x33, 0xe5, 0x91, 0x27,
-       0x81, 0xe0, 0xf7, 0x3d, 0x83, 0x5b, 0x30, 0xaf, 0x45, 0x5d, 0xac, 0xea, 
0xf0, 0x4b, 0x42, 0xe2,
-       0xa1, 0xe6, 0xc8, 0x4d, 0x2d, 0x63, 0x63, 0x5a, 0x1e, 0x1f, 0x53, 0x6b, 
0x17, 0xea, 0x8e, 0xfc,
-       0x9e, 0xf0, 0x8b, 0x8d, 0x9b, 0xdc, 0xc6, 0x2e, 0x0b, 0x82, 0x1e, 0xc2, 
0x67, 0x45, 0xfc, 0xde,
-       0x58, 0xd0, 0x66, 0xf1, 0x89, 0x8d, 0x22, 0x24, 0xdf, 0x17, 0x1b, 0xa3, 
0x00, 0xfb, 0x82, 0xd8,
-       0xe8, 0x02, 0x09, 0x1f, 0xa3, 0xf4, 0x8b, 0xa6, 0xb7, 0xa0, 0x7f, 0x9e, 
0xff, 0x0d, 0x00, 0x00,
-       0xff, 0xff, 0x79, 0x42, 0x3a, 0x25, 0xf8, 0x08, 0x00, 0x00,
+       // 879 bytes of a gzipped FileDescriptorProto
+       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xc4, 0x56, 
0xdd, 0x4e, 0xdb, 0x48,
+       0x14, 0x96, 0x49, 0x02, 0xe4, 0x38, 0x09, 0xc1, 0xfc, 0x6c, 0xc4, 0x6a, 
0xa5, 0xe0, 0xfd, 0x11,
+       0x17, 0xbb, 0xde, 0x55, 0x16, 0xb1, 0x08, 0x69, 0x57, 0x5a, 0xbc, 0xa0, 
0x45, 0x2a, 0x6d, 0xea,
+       0xd0, 0xde, 0x5a, 0x13, 0x67, 0x02, 0x16, 0x8e, 0xc7, 0x78, 0xc6, 0x40, 
0x7a, 0xdf, 0x9b, 0xde,
+       0xf5, 0xaa, 0x0f, 0xd1, 0xc7, 0xe8, 0x2b, 0xf4, 0x11, 0x2a, 0xf5, 0xb2, 
0xaf, 0xd0, 0x99, 0xb1,
+       0x63, 0x92, 0x38, 0x55, 0x6b, 0x04, 0xed, 0x55, 0x72, 0xfe, 0xcf, 0xf7, 
0xf9, 0x9c, 0x99, 0x81,
+       0x5a, 0x88, 0x2f, 0x22, 0x4c, 0x19, 0x35, 0x82, 0x90, 0x30, 0xb2, 0x51, 
0x71, 0xc8, 0x60, 0x40,
+       0xfc, 0x58, 0xd2, 0x77, 0x60, 0xc9, 0x44, 0x0c, 0x79, 0xe4, 0x94, 0x5a, 
0xb1, 0x9f, 0xf6, 0x23,
+       0x54, 0x1d, 0xe2, 0xfb, 0xd8, 0x61, 0x2e, 0xf1, 0x6d, 0xb7, 0xd7, 0x50, 
0x9a, 0xca, 0x56, 0xd9,
+       0xaa, 0xdc, 0x28, 0x8f, 0x7a, 0xfa, 0x3f, 0xf0, 0xdd, 0x7f, 0x3c, 0xae, 
0x8b, 0x28, 0x6e, 0x87,
+       0x24, 0xc0, 0x21, 0x1b, 0xe6, 0x8a, 0xbf, 0x84, 0x5a, 0xc7, 0x39, 0xc3, 
0x03, 0x94, 0x96, 0x6d,
+       0xc0, 0x82, 0x13, 0x77, 0x92, 0x04, 0x8c, 0x44, 0xed, 0x67, 0xa8, 0x51, 
0xe9, 0x6b, 0x07, 0x88,
+       0x31, 0x1c, 0xfa, 0x8d, 0x39, 0xe9, 0x50, 0x8d, 0xb5, 0xed, 0x58, 0x99, 
0xad, 0x5b, 0x98, 0x51,
+       0xf7, 0x9d, 0x02, 0xd5, 0x13, 0xd4, 0xf5, 0xf0, 0xdd, 0xd5, 0xfd, 0x15, 
0x34, 0x26, 0x32, 0xda,
+       0x3e, 0x1a, 0xe0, 0xd4, 0x35, 0x2e, 0x5e, 0x97, 0x96, 0x87, 0xdc, 0x30, 
0xf2, 0xfe, 0x1e, 0xca,
+       0x6c, 0x18, 0x60, 0xdb, 0x73, 0x29, 0x6b, 0x14, 0x9b, 0x05, 0xee, 0xb4, 
0x28, 0x14, 0x0f, 0xb8,
+       0xac, 0xe9, 0x50, 0x3d, 0x43, 0xd4, 0xbe, 0x71, 0x98, 0xe7, 0x59, 0x16, 
0x2d, 0x95, 0x2b, 0x4f,
+       0x46, 0x3e, 0x19, 0x98, 0x0b, 0x33, 0x60, 0xee, 0xc2, 0xb2, 0x44, 0x29, 
0xa2, 0xf2, 0x7d, 0xd8,
+       0xb7, 0x0a, 0xd4, 0x4c, 0xe2, 0x45, 0x03, 0xff, 0x5b, 0x31, 0x64, 0xc0, 
0x8a, 0x23, 0x1b, 0x98,
+       0x74, 0x2f, 0x4a, 0xf7, 0xe5, 0xd8, 0x34, 0xee, 0x9f, 0x81, 0x55, 0x9a, 
0x01, 0x8b, 0xcf, 0xb9,
+       0xe0, 0xe2, 0xc8, 0xef, 0x93, 0x5c, 0x74, 0x7c, 0x50, 0xa0, 0xd1, 0x0e, 
0x71, 0x80, 0x42, 0xfc,
+       0xaf, 0xdf, 0x3b, 0xb8, 0xc6, 0x4e, 0xc4, 0x70, 0x9e, 0x0c, 0x5a, 0x1d, 
0x0a, 0xf4, 0xc2, 0x4b,
+       0x88, 0x11, 0x7f, 0xc5, 0x57, 0x1e, 0xa0, 0x6b, 0x3b, 0x24, 0x57, 0xb6, 
0x43, 0x22, 0x9f, 0x49,
+       0x26, 0x8a, 0x96, 0xca, 0x95, 0x16, 0xb9, 0x32, 0x85, 0x4a, 0xdb, 0x84, 
0x0a, 0x65, 0x88, 0xe1,
+       0x01, 0xf6, 0x99, 0xc8, 0x2c, 0xd0, 0x57, 0x2d, 0x35, 0xd5, 0xf1, 0xc4, 
0x3f, 0x41, 0x2d, 0x49,
+       0xc3, 0x27, 0x86, 0xf0, 0x0f, 0x22, 0x81, 0x17, 0xac, 0x4a, 0x9c, 0x87, 
0x9e, 0x08, 0x9d, 0xf6,
+       0x3b, 0xac, 0xf6, 0xdd, 0x90, 0x32, 0xbb, 0x1f, 0x0a, 0x36, 0x45, 0x04, 
0x75, 0x9f, 0x61, 0x39,
+       0x59, 0x25, 0x6b, 0x59, 0xda, 0x0e, 0x85, 0xe9, 0x18, 0x5d, 0x77, 0xb8, 
0x41, 0x7f, 0xc9, 0x07,
+       0x20, 0x41, 0xfc, 0x15, 0x70, 0x66, 0x41, 0x14, 0xb3, 0x20, 0xf4, 0x37, 
0x0a, 0x54, 0x0e, 0x31,
+       0x73, 0xce, 0x72, 0x75, 0x34, 0xcd, 0xe1, 0x5c, 0x96, 0xc3, 0x75, 0x98, 
0x27, 0xfd, 0x3e, 0xc5,
+       0xa3, 0xde, 0x12, 0x49, 0xfb, 0x0d, 0x56, 0xfa, 0xa2, 0x9e, 0x3d, 0x09, 
0x20, 0xfe, 0x0a, 0x75,
+       0x69, 0x3a, 0x9e, 0x44, 0x31, 0x45, 0x6f, 0x49, 0xd2, 0x5b, 0xe9, 0x8f, 
0x33, 0xfb, 0x37, 0xac,
+       0x9b, 0x21, 0xe6, 0xc5, 0x3b, 0xa3, 0x0e, 0x72, 0x8d, 0xa2, 0x0d, 0x6b, 
0xa6, 0x47, 0xe8, 0xed,
+       0xa2, 0xbf, 0x80, 0x0c, 0xfd, 0xb5, 0x02, 0x6b, 0x8f, 0x02, 0xec, 0x9b, 
0x69, 0x5c, 0xae, 0x0a,
+       0xdb, 0x50, 0x74, 0xf9, 0x7a, 0xf1, 0xcc, 0x85, 0x2d, 0xb5, 0xd5, 0x34, 
0x66, 0xa6, 0x32, 0xc4,
+       0x06, 0x1e, 0xf8, 0x2c, 0x1c, 0x5a, 0xd2, 0x7b, 0xe3, 0x2f, 0x28, 0xa7, 
0x2a, 0x31, 0x43, 0xe7,
+       0x78, 0x98, 0x64, 0x17, 0x7f, 0xb5, 0x55, 0x28, 0x5d, 0x22, 0x2f, 0xc2, 
0xc9, 0x5c, 0xc5, 0xc2,
+       0xde, 0xdc, 0xae, 0x22, 0xd9, 0x14, 0x74, 0xdc, 0xae, 0x5b, 0x3d, 0xe4, 
0x6c, 0xa6, 0x72, 0x67,
+       0xe8, 0x3b, 0x39, 0xb1, 0x82, 0x90, 0x6d, 0x7e, 0x89, 0x06, 0x54, 0xf6, 
0xa6, 0xb6, 0xd6, 0x8c,
+       0x9b, 0x84, 0xc9, 0x9d, 0xe8, 0xf2, 0xc3, 0xb7, 0x2c, 0x1c, 0x85, 0x4c, 
0xf5, 0xf7, 0x7c, 0xb5,
+       0xa6, 0x8e, 0x90, 0x3d, 0x58, 0x4a, 0x3f, 0xc1, 0xff, 0xc8, 0xef, 0x79, 
0x58, 0xd6, 0x53, 0x5b,
+       0x75, 0xa3, 0x33, 0xa9, 0xb7, 0xa6, 0x1d, 0xb5, 0x1d, 0xa8, 0xf3, 0x2d, 
0xe5, 0x03, 0xc6, 0x8f,
+       0x41, 0x5b, 0x12, 0x43, 0x13, 0xf2, 0x55, 0x43, 0x1c, 0x76, 0xbd, 0xa7, 
0x42, 0x67, 0x2d, 0xa5,
+       0x4e, 0x52, 0xa6, 0x9f, 0x3c, 0x12, 0xe2, 0x15, 0xc8, 0x1e, 0x09, 0xda, 
0x1f, 0xb0, 0x2a, 0xae,
+       0xa5, 0x4c, 0xb1, 0xa2, 0xbc, 0x9d, 0x34, 0x6e, 0x6b, 0x4f, 0x96, 0xd0, 
0x5f, 0x29, 0xa0, 0xc5,
+       0xa4, 0xd2, 0xc8, 0x63, 0xf4, 0xae, 0xd7, 0x76, 0x13, 0x4a, 0x52, 0x94, 
0x2d, 0x0b, 0xb8, 0x8f,
+       0x23, 0x1c, 0x0e, 0x25, 0x61, 0x56, 0x6c, 0x19, 0xdb, 0xec, 0xe2, 0xf8, 
0x66, 0xeb, 0xdb, 0x50,
+       0x35, 0xf9, 0x03, 0xc8, 0xcd, 0xb7, 0x7b, 0xfc, 0xfa, 0xb0, 0x88, 0xe7, 
0x75, 0x91, 0x73, 0x9e,
+       0x2b, 0xee, 0x85, 0x02, 0x3f, 0x64, 0xae, 0x8f, 0x7d, 0x74, 0x0f, 0x27, 
0x99, 0x70, 0xb9, 0xf0,
+       0x6c, 0xf1, 0xb8, 0xe3, 0xd3, 0x41, 0x39, 0x33, 0xe2, 0x69, 0xa1, 0x72, 
0x9d, 0x99, 0xa8, 0xf4,
+       0x03, 0x50, 0x9f, 0x04, 0x3d, 0x94, 0x34, 0x30, 0x73, 0x7c, 0x94, 0xcf, 
0x8f, 0x8f, 0xfe, 0x5c,
+       0x81, 0x95, 0xfb, 0x44, 0xf2, 0x0b, 0x2c, 0x44, 0xb2, 0xcd, 0x18, 0x84, 
0xda, 0xaa, 0x18, 0x63,
+       0x6d, 0x5b, 0x23, 0xe3, 0xbe, 0x0e, 0x4d, 0x12, 0x9e, 0x1a, 0x28, 0x40, 
0xfc, 0xb1, 0x61, 0x38,
+       0xc8, 0x73, 0x5c, 0x86, 0x0d, 0x74, 0x89, 0x98, 0xeb, 0xa0, 0xf8, 0x79, 
0xdb, 0x9d, 0x97, 0x3f,
+       0x7f, 0x7e, 0x0c, 0x00, 0x00, 0xff, 0xff, 0x4f, 0x49, 0xad, 0x3d, 0x05, 
0x0b, 0x00, 0x00,
diff --git a/message/responses.pb.go b/message/responses.pb.go
index 5a3f244..6bebac8 100644
--- a/message/responses.pb.go
+++ b/message/responses.pb.go
@@ -350,6 +350,27 @@ func (m *RollbackResponse) String() string            { 
return proto.CompactText
 func (*RollbackResponse) ProtoMessage()               {}
 func (*RollbackResponse) Descriptor() ([]byte, []int) { return 
fileDescriptor2, []int{15} }
+// Response to a batch update request
+type ExecuteBatchResponse struct {
+       ConnectionId     string       
+       StatementId      uint32       
+       UpdateCounts     []uint64     
+       MissingStatement bool         
+       Metadata         *RpcMetadata `protobuf:"bytes,5,opt,name=metadata" 
+func (m *ExecuteBatchResponse) Reset()                    { *m = 
ExecuteBatchResponse{} }
+func (m *ExecuteBatchResponse) String() string            { return 
proto.CompactTextString(m) }
+func (*ExecuteBatchResponse) ProtoMessage()               {}
+func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) { return 
fileDescriptor2, []int{16} }
+func (m *ExecuteBatchResponse) GetMetadata() *RpcMetadata {
+       if m != nil {
+               return m.Metadata
+       }
+       return nil
 func init() {
        proto.RegisterType((*ResultSetResponse)(nil), "ResultSetResponse")
        proto.RegisterType((*ExecuteResponse)(nil), "ExecuteResponse")
@@ -367,56 +388,59 @@ func init() {
        proto.RegisterType((*RpcMetadata)(nil), "RpcMetadata")
        proto.RegisterType((*CommitResponse)(nil), "CommitResponse")
        proto.RegisterType((*RollbackResponse)(nil), "RollbackResponse")
+       proto.RegisterType((*ExecuteBatchResponse)(nil), "ExecuteBatchResponse")
 var fileDescriptor2 = []byte{
-       // 755 bytes of a gzipped FileDescriptorProto
-       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xac, 0x55, 
0xcb, 0x6e, 0xdb, 0x38,
-       0x14, 0x85, 0xec, 0xd8, 0x89, 0xaf, 0x9f, 0xd1, 0x60, 0x66, 0x8c, 0x79, 
0x21, 0xe3, 0x60, 0x90,
-       0x00, 0x33, 0xd0, 0x22, 0x93, 0x1f, 0x68, 0x5c, 0x07, 0xed, 0x22, 0x68, 
0x40, 0x17, 0xdd, 0x0a,
-       0x8c, 0x74, 0xe3, 0x08, 0xd1, 0x2b, 0x24, 0x9d, 0xc6, 0x7f, 0x50, 0xa0, 
0x8b, 0xee, 0xba, 0xee,
-       0x0f, 0xf4, 0x1f, 0x7b, 0x29, 0xca, 0xb4, 0xd3, 0x38, 0x6e, 0xdd, 0x76, 
0x65, 0xeb, 0xdc, 0xc3,
-       0x7b, 0xae, 0x0e, 0xc9, 0x23, 0xe8, 0x0a, 0x94, 0x79, 0x96, 0x4a, 0x94, 
0x5e, 0x2e, 0x32, 0x95,
-       0xfd, 0xd6, 0x0a, 0xb2, 0x24, 0xc9, 0x52, 0xf3, 0x34, 0xf8, 0x50, 0x81, 
0x5d, 0x86, 0x72, 0x1a,
-       0xab, 0x31, 0x2a, 0x56, 0x52, 0xdd, 0x7d, 0x68, 0x07, 0x59, 0x9a, 0x62, 
0xa0, 0xa2, 0x2c, 0xf5,
-       0xa3, 0xb0, 0xef, 0xec, 0x39, 0x87, 0x0d, 0xd6, 0x5a, 0x80, 0xcf, 0x43, 
0xf7, 0x6f, 0x68, 0x49,
-       0xc5, 0x15, 0x26, 0x98, 0x2a, 0xcd, 0xa9, 0x10, 0xa7, 0xcd, 0x9a, 0x16, 
0x23, 0x0a, 0xf5, 0xc9,
-       0x5e, 0xa7, 0xbe, 0x85, 0xfa, 0x55, 0xe2, 0xec, 0xb0, 0x16, 0x81, 0xe3, 
0x39, 0xe6, 0x1e, 0x42,
-       0x43, 0x46, 0x93, 0x94, 0xab, 0xa9, 0xc0, 0xfe, 0x16, 0x11, 0x9a, 0x47, 
0xe0, 0x8d, 0xe7, 0x08,
-       0x5b, 0x14, 0xdd, 0x03, 0x68, 0x5e, 0x46, 0x42, 0x2a, 0xff, 0x52, 0xf0, 
0x04, 0xfb, 0xb5, 0x82,
-       0x5b, 0xf7, 0x4e, 0xf5, 0x13, 0x83, 0xa2, 0x54, 0xfc, 0xd7, 0xa3, 0x4d, 
0xf3, 0x90, 0x04, 0xfc,
-       0x20, 0x9b, 0x92, 0x6c, 0x9d, 0x98, 0x5b, 0xac, 0x69, 0xb0, 0xa1, 0x86, 
0x48, 0x75, 0x27, 0x41,
-       0xc5, 0x09, 0xe0, 0xfd, 0xed, 0xa2, 0x51, 0xcb, 0x63, 0x79, 0x70, 0x56, 
0x62, 0xcc, 0x56, 0x07,
-       0xef, 0x1d, 0xe8, 0x8e, 0xee, 0x30, 0x98, 0x2a, 0xb4, 0x06, 0xfd, 0x07, 
0xdb, 0xa2, 0x70, 0x4d,
-       0x92, 0x35, 0x55, 0x5a, 0xec, 0x7a, 0x0f, 0x5c, 0x64, 0x73, 0x8a, 0xfb, 
0x2f, 0xec, 0x26, 0x91,
-       0x94, 0x51, 0x3a, 0x59, 0xb2, 0xa2, 0x52, 0x58, 0xd1, 0x2b, 0x0b, 0xcb, 
0x76, 0x2c, 0x06, 0xab,
-       0xae, 0x1d, 0xec, 0x1a, 0xba, 0xe7, 0x02, 0x73, 0x2e, 0x16, 0x73, 0x79, 
0xe4, 0xa5, 0x55, 0x70,
-       0x8a, 0xd5, 0x3d, 0xcf, 0xf6, 0x7e, 0xc6, 0xd3, 0x30, 0xd6, 0x8e, 0xae, 
0x14, 0xab, 0xac, 0x15,
-       0xfb, 0xe8, 0x40, 0xfb, 0x14, 0x55, 0x70, 0x65, 0xb5, 0xfe, 0x80, 0x9a, 
0xd9, 0x07, 0xe7, 0xde,
-       0x3e, 0x18, 0x70, 0xb3, 0x77, 0x3e, 0x80, 0xee, 0x9c, 0x3c, 0xb7, 0xd5, 
0x9c, 0x94, 0x4e, 0x09,
-       0xb3, 0xd2, 0xc9, 0xe5, 0x79, 0xb7, 0xd6, 0xce, 0xfb, 0xd6, 0x81, 0x5f, 
0x87, 0x02, 0x49, 0xc1,
-       0xca, 0xfc, 0xf0, 0xe3, 0xfd, 0xf5, 0x5b, 0x75, 0x02, 0xbf, 0x0c, 0xe3, 
0x4c, 0xae, 0x98, 0x65,
-       0xb9, 0x87, 0xf3, 0xa5, 0x1e, 0x2f, 0x72, 0x4c, 0x87, 0x76, 0xc8, 0x6f, 
0xe8, 0x31, 0x24, 0x53,
-       0xf4, 0x1c, 0xdf, 0xd5, 0xe4, 0x8e, 0x5e, 0xc6, 0xae, 0x1f, 0xcf, 0xd2, 
0xc0, 0xf6, 0x38, 0x06,
-       0xd0, 0x1e, 0xfa, 0x94, 0x2d, 0xb9, 0x2c, 0xbb, 0xfc, 0xec, 0x2d, 0xc8, 
0xe7, 0x84, 0xa3, 0x50,
-       0x11, 0x4a, 0xd6, 0xd0, 0x44, 0xfd, 0x2c, 0x37, 0x38, 0x84, 0x7a, 0x53, 
0x9f, 0xd2, 0x9f, 0x0b,
-       0x2e, 0xb1, 0xec, 0x35, 0x1b, 0xc5, 0xe6, 0x0c, 0xed, 0x43, 0xf5, 0x1a, 
0x67, 0xa5, 0xe8, 0xae,
-       0xf7, 0x39, 0x8d, 0xe9, 0x2a, 0x6d, 0x6a, 0xed, 0x96, 0xc7, 0x53, 0x2c, 
0x75, 0x9a, 0xde, 0xcb,
-       0x59, 0x8e, 0xe1, 0x2b, 0x0d, 0x31, 0x53, 0xd9, 0x60, 0x53, 0x15, 0xf4, 
0x1f, 0xa8, 0x2c, 0x2e,
-       0x62, 0x6d, 0x6e, 0x82, 0x8e, 0x87, 0xbe, 0xf7, 0xc8, 0xd8, 0xcc, 0xd0, 
0x36, 0xf0, 0xe0, 0x4d,
-       0x05, 0xda, 0x23, 0x21, 0x32, 0x61, 0xb5, 0xfe, 0x02, 0xc0, 0xbb, 0x00, 
0x73, 0xed, 0xb0, 0x11,
-       0x6c, 0xb0, 0x25, 0xc4, 0xfd, 0x07, 0x3a, 0x57, 0x5c, 0xfa, 0x4b, 0x9c, 
0xed, 0xe2, 0x72, 0xb5,
-       0x09, 0x1d, 0x2d, 0x68, 0x74, 0x2b, 0x50, 0xf7, 0xf5, 0x13, 0x94, 0x92, 
0x4f, 0x8c, 0x47, 0x74,
-       0x2b, 0x0a, 0xf0, 0xcc, 0x60, 0xd4, 0x6b, 0x47, 0xe2, 0x2d, 0x8a, 0x48, 
0xcd, 0x0a, 0x77, 0x3a,
-       0x47, 0x0d, 0x6f, 0x5c, 0x02, 0xcc, 0x96, 0xdc, 0x3f, 0x69, 0xa4, 0xa2, 
0x57, 0x90, 0x85, 0x26,
-       0xd4, 0xdb, 0xac, 0x51, 0x20, 0x43, 0x02, 0xdc, 0xdf, 0x29, 0xa6, 0x6e, 
0x62, 0x13, 0x0c, 0x45,
-       0x8c, 0x37, 0x68, 0xed, 0x4d, 0x5c, 0xdc, 0x8e, 0x7b, 0x56, 0xd4, 0xd7, 
0x5a, 0xf1, 0xce, 0x81,
-       0x9f, 0xca, 0xf3, 0xa7, 0xd3, 0xc1, 0x1a, 0xb2, 0x32, 0x7b, 0x9c, 0x47, 
0xb2, 0x87, 0xee, 0x79,
-       0x92, 0x09, 0xb4, 0xc1, 0x63, 0x32, 0xaa, 0xa9, 0xb1, 0x55, 0xa9, 0xb3, 
0xfe, 0x48, 0x1c, 0x43,
-       0x73, 0xa9, 0xa0, 0x9d, 0x97, 0x28, 0xc8, 0x13, 0x9f, 0x87, 0x21, 0x09, 
0xc8, 0x32, 0x69, 0xda,
-       0x06, 0x7d, 0x62, 0xc0, 0x41, 0x0f, 0x3a, 0x43, 0xfa, 0x28, 0x47, 0x36, 
0x15, 0x06, 0x2e, 0xf4,
-       0x58, 0x16, 0xc7, 0x17, 0x3c, 0xb8, 0x9e, 0x63, 0x27, 0x03, 0xd8, 0xcb, 
0xc4, 0xc4, 0xe3, 0x39,
-       0x0f, 0xae, 0xd0, 0x0b, 0x78, 0x1c, 0x44, 0x0a, 0x3d, 0x7e, 0xcb, 0x55, 
0x14, 0x70, 0xf3, 0x39,
-       0xbf, 0xa8, 0x17, 0x3f, 0xff, 0x7f, 0x0a, 0x00, 0x00, 0xff, 0xff, 0xe3, 
0xd0, 0x5a, 0x8c, 0xf6,
-       0x07, 0x00, 0x00,
+       // 791 bytes of a gzipped FileDescriptorProto
+       0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xac, 0x56, 
0xcb, 0x6e, 0xd3, 0x4c,
+       0x14, 0x96, 0x73, 0x6b, 0x33, 0xb9, 0xd6, 0xff, 0x0f, 0x44, 0xdc, 0x54, 
0x52, 0xa1, 0x56, 0x02,
+       0x79, 0x51, 0xfa, 0x02, 0x34, 0xa4, 0x82, 0x45, 0x45, 0x35, 0x41, 0x6c, 
0xad, 0xa9, 0x7d, 0x9a,
+       0x5a, 0xf5, 0xad, 0x33, 0x93, 0xd2, 0xbc, 0x01, 0x12, 0x0b, 0x76, 0xac, 
0x79, 0x01, 0x5e, 0x88,
+       0xa7, 0xe1, 0x8c, 0xc7, 0x99, 0xb8, 0x34, 0x0d, 0x0d, 0x74, 0x15, 0xfb, 
0x3b, 0xdf, 0x9c, 0x73,
+       0xfc, 0xcd, 0xcc, 0x77, 0x42, 0x3a, 0x1c, 0x44, 0x9a, 0xc4, 0x02, 0x84, 
0x93, 0xf2, 0x44, 0x26,
+       0x0f, 0x9b, 0x5e, 0x12, 0x45, 0x49, 0xac, 0xdf, 0xfa, 0xdf, 0x4b, 0x64, 
0x83, 0x82, 0x98, 0x84,
+       0x72, 0x04, 0x92, 0xe6, 0x54, 0x7b, 0x8b, 0xb4, 0xbc, 0x24, 0x8e, 0xc1, 
0x93, 0x41, 0x12, 0xbb,
+       0x81, 0xdf, 0xb3, 0x36, 0xad, 0x9d, 0x3a, 0x6d, 0xce, 0xc1, 0x77, 0xbe, 
0xfd, 0x8c, 0x34, 0x85,
+       0x64, 0x12, 0x22, 0x88, 0xa5, 0xe2, 0x94, 0x90, 0xd3, 0xa2, 0x0d, 0x83, 
0x21, 0x05, 0xf3, 0x24,
+       0x9f, 0x62, 0xd7, 0x40, 0xbd, 0x32, 0x72, 0xd6, 0x69, 0x13, 0xc1, 0xd1, 
0x0c, 0xb3, 0x77, 0x48,
+       0x5d, 0x04, 0xe3, 0x98, 0xc9, 0x09, 0x87, 0x5e, 0x05, 0x09, 0x8d, 0x5d, 
0xe2, 0x8c, 0x66, 0x08,
+       0x9d, 0x07, 0xed, 0x6d, 0xd2, 0x38, 0x09, 0xb8, 0x90, 0xee, 0x09, 0x67, 
0x11, 0xf4, 0xaa, 0x19,
+       0xb7, 0xe6, 0x1c, 0xa8, 0x37, 0x4a, 0xb2, 0x50, 0xf6, 0xac, 0x5a, 0x9b, 
0xa4, 0x3e, 0x16, 0x70,
+       0xbd, 0x64, 0x82, 0x65, 0x6b, 0xc8, 0xac, 0xd0, 0x86, 0xc6, 0x06, 0x0a, 
0xc2, 0xaa, 0xeb, 0x11,
+       0x48, 0x86, 0x00, 0xeb, 0xad, 0x65, 0x89, 0x9a, 0x0e, 0x4d, 0xbd, 0xc3, 
0x1c, 0xa3, 0x26, 0xda,
+       0xff, 0x66, 0x91, 0xce, 0xf0, 0x12, 0xbc, 0x89, 0x04, 0x23, 0xd0, 0x4b, 
0xb2, 0xc6, 0x33, 0xd5,
+       0x04, 0x4a, 0x53, 0xc6, 0xc5, 0xb6, 0x73, 0x4d, 0x45, 0x3a, 0xa3, 0xd8, 
0x2f, 0xc8, 0x46, 0x14,
+       0x08, 0x11, 0xc4, 0xe3, 0x82, 0x14, 0xa5, 0x4c, 0x8a, 0x6e, 0x1e, 0x28, 
0xca, 0x31, 0x6f, 0xac,
+       0xbc, 0xb4, 0xb1, 0x33, 0xd2, 0x39, 0xe2, 0x90, 0x32, 0x3e, 0xef, 0xcb, 
0x41, 0x2d, 0x4d, 0x05,
+       0x2b, 0x5b, 0xdd, 0x75, 0x4c, 0xee, 0xb7, 0x2c, 0xf6, 0x43, 0xa5, 0xe8, 
0xc2, 0x62, 0xa5, 0xa5,
+       0xc5, 0x7e, 0x58, 0xa4, 0x75, 0x00, 0xd2, 0x3b, 0x35, 0xb5, 0x1e, 0x93, 
0xaa, 0xde, 0x07, 0xeb,
+       0xca, 0x3e, 0x68, 0x70, 0xb5, 0x6f, 0xde, 0x26, 0x9d, 0x19, 0x79, 0x26, 
0xab, 0x3e, 0x29, 0xed,
+       0x1c, 0xa6, 0xb9, 0x92, 0xc5, 0x7e, 0x2b, 0x4b, 0xfb, 0xfd, 0x62, 0x91, 
0x07, 0x03, 0x0e, 0x58,
+       0xc1, 0x94, 0xb9, 0xf3, 0xe3, 0x7d, 0xfb, 0xad, 0xda, 0x27, 0xf7, 0x07, 
0x61, 0x22, 0x16, 0xf4,
+       0x52, 0xcc, 0x61, 0xfd, 0x29, 0xc7, 0xfb, 0x14, 0xe2, 0x81, 0x69, 0xf2, 
0x2f, 0x72, 0x0c, 0x50,
+       0x14, 0xd5, 0xc7, 0x3f, 0x25, 0xb9, 0xc4, 0x8f, 0x31, 0xeb, 0x47, 0xd3, 
0xd8, 0x33, 0x39, 0xf6,
+       0x08, 0x51, 0x1a, 0xba, 0xe8, 0x2d, 0xa9, 0xc8, 0xb3, 0xdc, 0x73, 0xe6, 
0xe4, 0x23, 0xc4, 0x81,
+       0xcb, 0x00, 0x04, 0xad, 0x2b, 0xa2, 0x7a, 0x17, 0x2b, 0x1c, 0x42, 0xb5, 
0xa9, 0x6f, 0xf0, 0xe1,
+       0x98, 0x09, 0xc8, 0x73, 0x4d, 0x87, 0xa1, 0x3e, 0x43, 0x5b, 0xa4, 0x7c, 
0x06, 0xd3, 0xbc, 0xe8,
+       0x86, 0xf3, 0x3b, 0x8d, 0xaa, 0x28, 0x6e, 0x6a, 0xf5, 0x82, 0x85, 0x13, 
0xc8, 0xeb, 0x34, 0x9c,
+       0x0f, 0xd3, 0x14, 0xfc, 0x8f, 0x0a, 0xa2, 0x3a, 0xb2, 0xc2, 0xa6, 0x4a, 
0xd2, 0xbb, 0x56, 0x65,
+       0x7e, 0x11, 0xab, 0x33, 0x11, 0x94, 0x3d, 0xf4, 0x9c, 0x1b, 0xda, 0xa6, 
0x9a, 0xb6, 0x82, 0x06,
+       0x9f, 0x4b, 0xa4, 0x35, 0xe4, 0x3c, 0xe1, 0xa6, 0xd6, 0x53, 0x42, 0xe0, 
0xd2, 0x83, 0x54, 0x29,
+       0xac, 0x0b, 0xd6, 0x69, 0x01, 0xb1, 0x9f, 0x93, 0xf6, 0x29, 0x13, 0x6e, 
0x81, 0xb3, 0x96, 0x5d,
+       0xae, 0x16, 0xa2, 0xc3, 0x39, 0x0d, 0x6f, 0x05, 0xa8, 0xbc, 0x6e, 0x04, 
0x42, 0xb0, 0xb1, 0xd6,
+       0x08, 0x6f, 0x45, 0x06, 0x1e, 0x6a, 0x0c, 0x73, 0xad, 0x0b, 0xb8, 0x00, 
0x1e, 0xc8, 0x69, 0xa6,
+       0x4e, 0x7b, 0xb7, 0xee, 0x8c, 0x72, 0x80, 0x9a, 0x90, 0xfd, 0x04, 0x5b, 
0xca, 0x72, 0x79, 0x89,
+       0xaf, 0x4d, 0xbd, 0x45, 0xeb, 0x19, 0x32, 0x40, 0xc0, 0x7e, 0x84, 0x36, 
0x75, 0x1e, 0x6a, 0x63,
+       0xc8, 0x6c, 0xbc, 0x8e, 0x6b, 0xcf, 0xc3, 0xec, 0x76, 0x5c, 0x91, 0xa2, 
0xb6, 0x54, 0x8a, 0xaf,
+       0x16, 0xf9, 0x2f, 0x3f, 0x7f, 0xca, 0x1d, 0x8c, 0x20, 0x0b, 0xbd, 0xc7, 
0xba, 0xc1, 0x7b, 0xf0,
+       0x9e, 0x47, 0x09, 0x07, 0x63, 0x3c, 0xda, 0xa3, 0x1a, 0x0a, 0x5b, 0xe4, 
0x3a, 0xcb, 0x8f, 0xc4,
+       0x1e, 0x69, 0x14, 0x02, 0x4a, 0x79, 0x01, 0x1c, 0x35, 0x71, 0x99, 0xef, 
0x63, 0x01, 0x91, 0x3b,
+       0x4d, 0x4b, 0xa3, 0xaf, 0x35, 0xd8, 0xef, 0x92, 0xf6, 0x00, 0x87, 0x72, 
0x60, 0x5c, 0xa1, 0x6f,
+       0x93, 0x2e, 0x4d, 0xc2, 0xf0, 0x98, 0x79, 0x67, 0x06, 0xfb, 0x69, 0x91, 
0xff, 0xf3, 0x39, 0xb4,
+       0xcf, 0x8a, 0x46, 0x7c, 0x87, 0xd3, 0xba, 0x38, 0x35, 0x95, 0x07, 0x97, 
0x71, 0x6c, 0x36, 0x0b,
+       0x63, 0xf3, 0x86, 0x59, 0x56, 0xb9, 0xc5, 0x2c, 0xab, 0x2e, 0x13, 0x6e, 
0xbf, 0x4f, 0x36, 0x13,
+       0x3e, 0x76, 0x58, 0xca, 0xbc, 0x53, 0x70, 0x3c, 0x16, 0x7a, 0x81, 0x04, 
0x87, 0x5d, 0x30, 0x19,
+       0x78, 0x4c, 0xff, 0x57, 0x39, 0xae, 0x65, 0x3f, 0xaf, 0x7e, 0x05, 0x00, 
0x00, 0xff, 0xff, 0x70,
+       0x76, 0x9a, 0x2c, 0xd3, 0x08, 0x00, 0x00,
diff --git a/moby.yml b/moby.yml
index e502371..e4776b9 100644
--- a/moby.yml
+++ b/moby.yml
@@ -1,6 +1,6 @@
   - id: phoenix
-    image: boostport/hbase-phoenix-all-in-one:1.1.5-4.7.0
+    image: boostport/hbase-phoenix-all-in-one:1.2.2-4.8.0
       - "8765"
@@ -19,4 +19,4 @@ dev:
       name: Run tests
       cwd: $GOPATH/src/
-        command: go test -cover -v $(go list ./... | grep -v /vendor/)
\ No newline at end of file
+        command: go test -v $(go list ./... | grep -v /vendor/)
\ No newline at end of file
diff --git a/rows.go b/rows.go
index 2e87a04..82b67ff 100644
--- a/rows.go
+++ b/rows.go
@@ -54,10 +54,10 @@ func (r *rows) Next(dest []driver.Value) error {
                // Fetch more results from the server
                res, err :=, 
-                       ConnectionId:     r.conn.connectionId,
-                       StatementId:      r.statementID,
-                       Offset:           r.offset,
-                       FetchMaxRowCount: r.conn.config.fetchMaxRowCount,
+                       ConnectionId: r.conn.connectionId,
+                       StatementId:  r.statementID,
+                       Offset:       r.offset,
+                       FrameMaxSize: r.conn.config.frameMaxSize,
                if err != nil {
@@ -176,7 +176,7 @@ func typedValueToNative(rep message.Rep, v 
*message.TypedValue, config *Config)
                return v.NumberValue
        case message.Rep_BYTE_STRING:
-               return v.BytesValues
+               return v.BytesValue
        case message.Rep_DOUBLE, message.Rep_PRIMITIVE_DOUBLE:
                return v.DoubleValue
diff --git a/statement.go b/statement.go
index c8f181e..47d487f 100644
--- a/statement.go
+++ b/statement.go
@@ -2,7 +2,6 @@ package avatica
 import (
-       "encoding/base64"
@@ -54,7 +53,7 @@ func (s *stmt) Exec(args []driver.Value) (driver.Result, 
error) {
        res, err :=, 
                StatementHandle:    &s.handle,
                ParameterValues:    s.parametersToTypedValues(args),
-               MaxRowCount:        s.conn.config.maxRowCount,
+               FirstFrameMaxSize:  uint64(s.conn.config.frameMaxSize), //TODO: 
Due to CALCITE-1353, if frameMaxSize == -1, it overflows to 
18446744073709551615 due to the conversion to uint64, which is basically all 
                HasParameterValues: true,
@@ -81,7 +80,7 @@ func (s *stmt) Query(args []driver.Value) (driver.Rows, 
error) {
        res, err :=, 
                StatementHandle:    &s.handle,
                ParameterValues:    s.parametersToTypedValues(args),
-               MaxRowCount:        s.conn.config.maxRowCount,
+               FirstFrameMaxSize:  uint64(s.conn.config.frameMaxSize), //TODO: 
Due to CALCITE-1353, if frameMaxSize == -1, it overflows to 
18446744073709551615 due to the conversion to uint64, which is basically all 
                HasParameterValues: true,
@@ -118,10 +117,7 @@ func (s *stmt) parametersToTypedValues(vals 
[]driver.Value) []*message.TypedValu
                                typed.BoolValue = v
                        case []byte:
                                typed.Type = message.Rep_BYTE_STRING
-                               // This is a work around for CALCITE-1209
-                               str := base64.StdEncoding.EncodeToString(v)
-                               typed.StringValue = str
+                               typed.BytesValue = v
                        case string:
                                typed.Type = message.Rep_STRING
                                typed.StringValue = v
diff --git a/transaction.go b/transaction.go
index ac5a462..ca968ec 100644
--- a/transaction.go
+++ b/transaction.go
@@ -41,7 +41,7 @@ func (t *tx) enableAutoCommit() error {
                ConnProps: &message.ConnectionProperties{
                        AutoCommit:           true,
                        HasAutoCommit:        true,
-                       TransactionIsolation: 8,
+                       TransactionIsolation: 4,
diff --git a/vendor/vendor.json b/vendor/vendor.json
index b72c7c5..e9452bf 100644
--- a/vendor/vendor.json
+++ b/vendor/vendor.json
@@ -7,10 +7,10 @@
                        "revision": ""
-                       "checksumSHA1": "FczzogSoZcKU3h21tCUyHzMsnBY=",
+                       "checksumSHA1": "XnbEHQRzINRKXKmu9GcaqGkK4Lg=",
                        "path": "",
-                       "revision": "7cc19b78d562895b13596ddce7aafb59dd789318",
-                       "revisionTime": "2016-04-25T21:53:00Z"
+                       "revision": "f592bd283e9ef86337a432eb50e592278c3d534d",
+                       "revisionTime": "2016-08-17T17:41:13Z"
                        "checksumSHA1": "Uzyon2091lmwacNsl1hCytjhHtg=",
@@ -19,22 +19,22 @@
                        "revisionTime": "2016-04-07T17:41:26Z"
-                       "checksumSHA1": "cKNzpMpci3WUAzXpe+tVnBv2cjE=",
+                       "checksumSHA1": "zmC8/3V4ls53DJlNTKDZwPSC/dA=",
                        "path": "",
-                       "revision": "f9ab0dce87d815821e221626b772e3475a0d2749",
-                       "revisionTime": "2016-03-24T11:22:44Z"
+                       "revision": "0aa62d5ddceb50dbcb909d790b5345affd3669b6",
+                       "revisionTime": "2016-07-13T18:03:06Z"
                        "checksumSHA1": "9jjO5GjLa0XF/nfWihF02RoH4qc=",
                        "path": "",
-                       "revision": "58b2fb074ec0cc06e95f2409a11ff51dd11798e2",
-                       "revisionTime": "2016-05-14T19:45:11Z"
+                       "revision": "07b51741c1d6423d4a6abab1c49940ec09cb1aaf",
+                       "revisionTime": "2016-08-11T10:50:59Z"
-                       "checksumSHA1": "Do+l129/Bafh54VFaquooqtCcfk=",
+                       "checksumSHA1": "WHc3uByvGaMcnSoI21fhzYgbOgg=",
                        "path": "",
-                       "revision": "58b2fb074ec0cc06e95f2409a11ff51dd11798e2",
-                       "revisionTime": "2016-05-14T19:45:11Z"
+                       "revision": "07b51741c1d6423d4a6abab1c49940ec09cb1aaf",
+                       "revisionTime": "2016-08-11T10:50:59Z"
        "rootPath": ""
diff --git a/wercker.yml b/wercker.yml
index 134bc0f..1524699 100644
--- a/wercker.yml
+++ b/wercker.yml
@@ -5,7 +5,7 @@ box:
 no-response-timeout: 20
-  - boostport/hbase-phoenix-all-in-one:1.1.5-4.7.0
+  - boostport/hbase-phoenix-all-in-one:1.2.2-4.8.0

Reply via email to