gql_2.go

import (
	...
	"database/sql"
	"database/sql/driver"
	"github.com/marcboeker/go-duckdb"
 ...
)

// the driver struct wrapping the duckdb connection
type DuckDBDriver struct {
 db *sql.DB
}

// init function that creates the connection
func NewDuckDBDriver(cred aws.AWSCred) *DuckDBDriver {
 db, err := initializeDB(cred)
 if err != nil {
  panic(err)
 }
 err = db.Ping()
 if err != nil {
  panic(err)
 }
 log.Print("connected to duckdb in memory db")
 return &DuckDBDriver{
  db: db,
 }
}

// opening a duckdb connection and executing init statements
func initializeDB(awsCred aws.AWSCred) (*sql.DB, error) {
 bootQueries := getBootQueries(awsCred)
 connector, err := duckdb.NewConnector("", func(execer driver.ExecerContext) error {
  for _, qry := range bootQueries {
   _, err := execer.ExecContext(context.Background(),
    qry, make([]driver.NamedValue, 0))
   if err != nil {
    return err
   }
  }
  return nil
 })
 if err != nil {
  return nil, err
 }
 db := sql.OpenDB(connector)
 return db, nil
}