SNOW-988972 adding an example demonstrating how to insert data into V…

…ARIANT and OBJECT datatype columns with bind variables

cmd/insertvariantobject/Makefile

@@ -0,0 +1,16 @@
+include ../../gosnowflake.mak
+CMD_TARGET=insertvariantobject
+
+## Install
+install: cinstall
+
+## Run
+run: crun
+
+## Lint
+lint: clint
+
+## Format source codes
+fmt: cfmt
+
+.PHONY: install run lint fmt

cmd/insertvariantobject/insertvariantobject.go

@@ -0,0 +1,91 @@
+package main
+
+import (
+	"database/sql"
+	"flag"
+	"fmt"
+	"log"
+	"encoding/json"
+
+	sf "github.com/snowflakedb/gosnowflake"
+)
+
+func main() {
+	if !flag.Parsed() {
+		flag.Parse()
+	}
+
+	cfg, err := sf.GetConfigFromEnv([]*sf.ConfigParam{
+		{Name: "Account", EnvName: "SNOWFLAKE_TEST_ACCOUNT", FailOnMissing: true},
+		{Name: "User", EnvName: "SNOWFLAKE_TEST_USER", FailOnMissing: true},
+		{Name: "Password", EnvName: "SNOWFLAKE_TEST_PASSWORD", FailOnMissing: true},
+		{Name: "Warehouse", EnvName: "SNOWFLAKE_TEST_WAREHOUSE", FailOnMissing: true},
+		{Name: "Database", EnvName: "SNOWFLAKE_TEST_DATABASE", FailOnMissing: true},
+		{Name: "Schema", EnvName: "SNOWFLAKE_TEST_SCHEMA", FailOnMissing: true},
+		{Name: "Host", EnvName: "SNOWFLAKE_TEST_HOST", FailOnMissing: false},
+		{Name: "Port", EnvName: "SNOWFLAKE_TEST_PORT", FailOnMissing: false},
+		{Name: "Protocol", EnvName: "SNOWFLAKE_TEST_PROTOCOL", FailOnMissing: false},
+	})
+	if err != nil {
+		log.Fatalf("failed to create Config, err: %v", err)
+	}
+	dsn, err := sf.DSN(cfg)
+	if err != nil {
+		log.Fatalf("failed to create DSN from Config: %v, err: %v", cfg, err)
+	}
+
+	db, err := sql.Open("snowflake", dsn)
+	if err != nil {
+		log.Fatalf("failed to connect. %v, err: %v", dsn, err)
+	}
+	defer db.Close()
+
+	param := map[string]string{"key": "value"}
+	jsonStr, _ := json.Marshal(param)
+
+	createTableQuery := "CREATE OR REPLACE TABLE insertvariantobject (c1 VARIANT, c2 OBJECT);"
+
+	// https://docs.snowflake.com/en/sql-reference/functions/parse_json
+	// can do with TO_VARIANT(PARSE_JSON(..)) as well, but PARSE_JSON already produces VARIANT
+	insertQuery := "INSERT INTO insertvariantobject (c1, c2) SELECT PARSE_JSON(?), TO_OBJECT(PARSE_JSON(?));"
+	// https://docs.snowflake.com/en/sql-reference/data-types-semistructured#object
+	insertOnlyObject := "INSERT INTO insertvariantobject (c2) SELECT OBJECT_CONSTRUCT('name', 'Jones'::VARIANT,'age',  42::VARIANT);"
+
+	selectQuery := "SELECT c1, c2 FROM insertvariantobject;"
+
+	fmt.Printf("Running CREATE OR REPLACE TABLE\n")
+	db.Exec(createTableQuery)
+
+	fmt.Printf("Inserting VARIANT and OBJECT data into table\n")
+	_, err = db.Exec(insertQuery,
+		string(jsonStr),
+		string(jsonStr),
+	)
+	if err != nil {
+		log.Fatalf("failed to run the query. %v, err: %v", insertQuery, err)
+	}
+	_, err = db.Exec(insertOnlyObject)
+        if err != nil {
+                log.Fatalf("failed to run the query. %v, err: %v", insertOnlyObject, err)
+        }
+
+	fmt.Printf("Querying the table into which we just inserted the data\n")
+	rows, err := db.Query(selectQuery)
+        if err != nil {
+                log.Fatalf("failed to run the query. %v, err: %v", selectQuery, err)
+        }
+        defer rows.Close()
+	var c1, c2 any
+	for rows.Next() {
+		err := rows.Scan(&c1, &c2)
+		if err != nil {
+			log.Fatalf("failed to get result. err: %v", err)
+		}
+		fmt.Printf("%v, %v\n", c1, c2)
+	}
+	if rows.Err() != nil {
+		fmt.Printf("ERROR: %v\n", rows.Err())
+		return
+	}
+
+}