github.com/iodeal/go-sql-bigquery

BigQuery SQL Driver for Golang

This is an implementation of the BigQuery Client as a database/sql/driver for easy integration and usage.

Goals of project

This project is meant to be a basic database/sql driver implementation for Golang so that developers can easily use tools like Gorm, and *sql.DB functions, with Google’s BigQuery database.

Usage

Check out the example application in the examples directory, for a few examples.

Authentication

As this is using the Google Cloud Go SDK, you will need to have your credentials available via the GOOGLE_APPLICATION_CREDENTIALS environment variable point to your credential JSON file.

Alternatively, you can specify apiKey connection string parameter with API key value, or CredentialsFile parameter with Credentials File(json format) Local Path or credentials parameter with base-64 encoded service account or refresh token JSON credentials as the value.
Connection string examples:

"bigquery://projectid/location/dataset?CredentialsFile=/path/filename.json"
"bigquery://projectid/location/dataset?apiKey=AIzaSyB6XK8IO5AzKZXoioQOVNTFYzbDBjY5hy4"
"bigquery://projectid/location/dataset?credentials=eyJ0eXBlIjoiYXV0..."

Vanilla *sql.DB usage

Just like any other database/sql driver you’ll need to import it

package main

import (
    "database/sql"
    _ "github.com/iodeal/go-sql-bigquery"
    "log"
)

func main() {
    config := "bigquery://{project_id}/{location}/{dataset_id}?CredentialsFile={Local Credentials File Path}"
    db, err := sql.Open("bigquery", config)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close() 
    var rs string
	err = db.QueryRow("select 'query row' msg").Scan(&rs)
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println(rs)
	rows, err := db.Query("select 1 union all select 2 union all select 3")
	if err != nil {
		fmt.Println(err)
	}
	defer rows.Close()
	var cnt int
	for rows.Next() {
		err = rows.Scan(&cnt)
		fmt.Println(cnt)
	}
}

Contribution

Pull Requests are welcome!

Current Support

• [x] driver.Conn implemented
• [x] driver.Querier implemented
• [x] driver.Pinger implemented
• [x] Prepared Statements - supported via a quick hack
• [ ] Parametiterized Queries