gql_1.go

type DAO struct {
 driver DataDriver
}

// the data we want to load
QUsersTable := "CREATE TABLE users AS SELECT name, last_name, cast(age as integer)" 
              + "FROM read_parquet('%s') "

// the parquet files location
parquetTablePath := "s3://bucket/prefix/data/"

// loading the data to users table in the init
func NewStore(driver DataDriver) *DAO {
 initQuery := fmt.Sprintf(QUsersTable, parquetTablePath)  
 err := driver.Execute(initQuery)
 if err != nil {
  panic(err)
 }
 return &DAO{driver: driver}
}