ARROW-17359: [Go][FlightSQL] Create Example with SQLite in-mem and use to test FlightSQL server

ci/docker/conda-integration.dockerfile

@@ -38,7 +38,7 @@ RUN mamba install -q -y \
         nodejs=${node} \
         yarn \
         openjdk=${jdk} \
-        zlib=1.2.11 && \ 
+        zlib=1.2.11 && \
     mamba clean --all --force-pkgs-dirs
 
 # Install Rust with only the needed components

dev/release/01-prepare-test.rb

@@ -169,6 +169,13 @@ def test_version_pre_tag
           ],
         ],
       },
+      {
+        path: "go/arrow/doc.go",
+        hunks: [
+          ["-const PkgVersion = \"#{@snapshot_version}\"",
+           "+const PkgVersion = \"#{@release_version}\""],
+        ],
+      },
       {
         path: "go/parquet/writer_properties.go",
         hunks: [

dev/release/post-11-bump-versions-test.rb

@@ -185,6 +185,17 @@ def test_version_post_tag
     ]
 
     Dir.glob("go/**/{go.mod,*.go,*.go.*}") do |path|
+      if path == "go/arrow/doc.go"
+        expected_changes << {
+          path: path,
+          hunks: [
+          [
+            "-const PkgVersion = \"#{@snapshot_version}\"",
+            "+const PkgVersion = \"#{@next_snapshot_version}\"",
+          ],
+        ]}
+        next
+      end
       import_path = "github.com/apache/arrow/go/v#{@snapshot_major_version}"
       lines = File.readlines(path, chomp: true)
       target_lines = lines.grep(/#{Regexp.escape(import_path)}/)
@@ -205,10 +216,10 @@ def test_version_post_tag
         hunks << [
           "-\tDefaultCreatedBy          = \"parquet-go version #{@snapshot_version}\"",
           "+\tDefaultCreatedBy          = \"parquet-go version #{@next_snapshot_version}\"",
-        ]
+        ]      
       end
       expected_changes << {hunks: hunks, path: path}
-    end
+    end    
 
     Dir.glob("java/**/pom.xml") do |path|
       version = "<version>#{@snapshot_version}</version>"

dev/release/utils-prepare.sh

@@ -156,6 +156,9 @@ update_versions() {
   sed -i.bak -E -e \
     "s/\"parquet-go version .+\"/\"parquet-go version ${version}\"/" \
     parquet/writer_properties.go
+  sed -i.bak -E -e \
+    "s/const PkgVersion = \".*/const PkgVersion = \"${version}\"/" \
+    arrow/doc.go  
   find . -name "*.bak" -exec rm {} \;
   git add .
   popd

go/arrow/array/list_test.go

@@ -33,6 +33,8 @@ func TestListArray(t *testing.T) {
 	}{
 		{arrow.LIST, []int32{0, 3, 3, 3, 7}, arrow.ListOf(arrow.PrimitiveTypes.Int32)},
 		{arrow.LARGE_LIST, []int64{0, 3, 3, 3, 7}, arrow.LargeListOf(arrow.PrimitiveTypes.Int32)},
+		{arrow.LIST, []int32{0, 3, 3, 3, 7}, arrow.ListOfField(arrow.Field{Name: "item", Type: arrow.PrimitiveTypes.Int32, Nullable: true})},
+		{arrow.LARGE_LIST, []int64{0, 3, 3, 3, 7}, arrow.LargeListOfField(arrow.Field{Name: "item", Type: arrow.PrimitiveTypes.Int32, Nullable: true})},
 	}
 
 	for _, tt := range tests {

go/arrow/doc.go

@@ -31,6 +31,8 @@ array is valid (not null). If the array has no null entries, it is possible to o
 */
 package arrow
 
+const PkgVersion = "10.0.0-SNAPSHOT"
+
 //go:generate go run _tools/tmpl/main.go -i -data=numeric.tmpldata type_traits_numeric.gen.go.tmpl type_traits_numeric.gen_test.go.tmpl array/numeric.gen.go.tmpl array/numericbuilder.gen.go.tmpl array/bufferbuilder_numeric.gen.go.tmpl
 //go:generate go run _tools/tmpl/main.go -i -data=datatype_numeric.gen.go.tmpldata datatype_numeric.gen.go.tmpl tensor/numeric.gen.go.tmpl tensor/numeric.gen_test.go.tmpl
 //go:generate go run _tools/tmpl/main.go -i -data=scalar/numeric.gen.go.tmpldata scalar/numeric.gen.go.tmpl scalar/numeric.gen_test.go.tmpl

go/arrow/flight/flightsql/client.go

@@ -232,10 +232,6 @@ func (c *Client) GetSqlInfo(ctx context.Context, info []SqlInfo, opts ...grpc.Ca
 	return flightInfoForCommand(ctx, c, cmd, opts...)
 }
 
-// Prepare creates a PreparedStatement object for the specified query.
-// The resulting PreparedStatement object should be Closed when no longer
-// needed. It will maintain a reference to this Client for use to execute
-// and use the specified allocator for any allocations it needs to perform.
 // Prepare creates a PreparedStatement object for the specified query.
 // The resulting PreparedStatement object should be Closed when no longer
 // needed. It will maintain a reference to this Client for use to execute

go/arrow/flight/flightsql/example/sqlite_info.go

@@ -19,13 +19,16 @@
 
 package example
 
-import "github.com/apache/arrow/go/v10/arrow/flight/flightsql"
+import (
+	"github.com/apache/arrow/go/v10/arrow"
+	"github.com/apache/arrow/go/v10/arrow/flight/flightsql"
+)
 
 func SqlInfoResultMap() flightsql.SqlInfoResultMap {
 	return flightsql.SqlInfoResultMap{
 		uint32(flightsql.SqlInfoFlightSqlServerName):         "db_name",
 		uint32(flightsql.SqlInfoFlightSqlServerVersion):      "sqlite 3",
-		uint32(flightsql.SqlInfoFlightSqlServerArrowVersion): "10.0.0-SNAPSHOT",
+		uint32(flightsql.SqlInfoFlightSqlServerArrowVersion): arrow.PkgVersion,
 		uint32(flightsql.SqlInfoFlightSqlServerReadOnly):     false,
 		uint32(flightsql.SqlInfoDDLCatalog):                  false,
 		uint32(flightsql.SqlInfoDDLSchema):                   false,

go/arrow/flight/flightsql/schema_ref/reference_schemas.go

@@ -64,7 +64,7 @@ var (
 		{Name: "fk_key_name", Type: arrow.BinaryTypes.String, Nullable: true},
 		{Name: "pk_key_name", Type: arrow.BinaryTypes.String, Nullable: true},
 		{Name: "update_rule", Type: arrow.PrimitiveTypes.Uint8, Nullable: false},
-		{Name: "delete_rule", Type: arrow.PrimitiveTypes.Uint8, Nullable: true},
+		{Name: "delete_rule", Type: arrow.PrimitiveTypes.Uint8, Nullable: false},
 	}, nil)
 	ImportedKeys   = ImportedExportedKeysAndCrossReference
 	ExportedKeys   = ImportedExportedKeysAndCrossReference
@@ -88,7 +88,7 @@ var (
 		{Name: "column_size", Type: arrow.PrimitiveTypes.Int32, Nullable: true},
 		{Name: "literal_prefix", Type: arrow.BinaryTypes.String, Nullable: true},
 		{Name: "literal_suffix", Type: arrow.BinaryTypes.String, Nullable: true},
-		{Name: "create_params", Type: arrow.ListOfField(arrow.Field{Name: "item", Type: arrow.BinaryTypes.String, Nullable: false})},
+		{Name: "create_params", Type: arrow.ListOfField(arrow.Field{Name: "item", Type: arrow.BinaryTypes.String, Nullable: false}), Nullable: true},
 		{Name: "nullable", Type: arrow.PrimitiveTypes.Int32, Nullable: false},
 		{Name: "case_sensitive", Type: arrow.FixedWidthTypes.Boolean, Nullable: false},
 		{Name: "searchable", Type: arrow.PrimitiveTypes.Int32, Nullable: false},