bigquery

package module
v0.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2019 License: MIT Imports: 12 Imported by: 1

README

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.

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.

Vanilla *sql.DB usage

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

package main

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

func main() {
    db, err := sql.Open("bigquery", 
        "bigquery://projectid/dataset")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close() 
    // Do Something with the DB

}

Gorm Usage

For gorm

package main

import (
    "github.com/jinzhu/gorm"
    _ "github.com/solcates/go-sql-bigquery/dialects/bigquery"
    "log"
)

func main() {
    db, err := gorm.Open("bigquery", 
        "bigquery://projectid/dataset")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close() 
    // Do Something with the DB

}

Contribution

Pull Requests are welcome!

Current Support

  • driver.Conn implemented
  • driver.Querier implemented
  • driver.Pinger implemented
  • gorm Dialect - have only tested basic use cases
  • Prepared Statements - supported via a quick hack
  • Parametiterized Queries

Documentation

Index

Constants

View Source
const (
	ConnectionStringEnvKey = "BIGQUERY_CONNECTION_STRING"
)

Variables

This section is empty.

Functions

func NewStmt

func NewStmt(query string, c *Conn) *stmt

Types

type Config

type Config struct {
	ProjectID string
	Location  string
	DataSet   string
}

func ConfigFromConnString added in v0.1.1

func ConfigFromConnString(in string) (*Config, error)

ConfigFromConnString will return the Config structures

type Conn added in v0.1.8

type Conn struct {
	// contains filtered or unexported fields
}

func NewConn added in v0.1.8

func NewConn(ctx context.Context, cfg *Config) (c *Conn, err error)

NewConn returns a connection for this Config

func (*Conn) Begin added in v0.1.8

func (c *Conn) Begin() (driver.Tx, error)

Begin is stubbed out and not used

func (*Conn) Close added in v0.1.8

func (c *Conn) Close() (err error)

Close closes the connection

func (*Conn) Exec added in v0.1.8

func (c *Conn) Exec(query string, args []driver.Value) (res driver.Result, err error)

func (*Conn) Ping added in v0.1.8

func (c *Conn) Ping(ctx context.Context) (err error)

Ping the BigQuery service and make sure it's reachable

func (*Conn) Prepare added in v0.1.8

func (c *Conn) Prepare(query string) (stmt driver.Stmt, err error)

Prepare is stubbed out and not used

func (*Conn) Query added in v0.1.8

func (c *Conn) Query(query string, args []driver.Value) (rows driver.Rows, err error)

type Connector

type Connector struct {
	Info   map[string]string
	Client *bigquery.Client
	// contains filtered or unexported fields
}

func NewConnector

func NewConnector(connectionString string) *Connector

func (*Connector) Connect

func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

func (*Connector) Driver

func (c *Connector) Driver() driver.Driver

type Dataset added in v0.1.8

type Dataset interface {
	// Create creates a dataset in the BigQuery service. An error will be returned if the
	// dataset already exists. Pass in a DatasetMetadata value to configure the dataset.
	Create(ctx context.Context, md *bigquery.DatasetMetadata) (err error)
	// Delete deletes the dataset.  Delete will fail if the dataset is not empty.
	Delete(ctx context.Context) (err error)
	// DeleteWithContents deletes the dataset, as well as contained resources.
	DeleteWithContents(ctx context.Context) (err error)
	// Metadata fetches the metadata for the dataset.
	Metadata(ctx context.Context) (md *bigquery.DatasetMetadata, err error)
	// Update modifies specific Dataset metadata fields.
	// To perform a read-modify-write that protects against intervening reads,
	// set the etag argument to the DatasetMetadata.ETag field from the read.
	// Pass the empty string for etag for a "blind write" that will always succeed.
	Update(ctx context.Context, dm bigquery.DatasetMetadataToUpdate, etag string) (md *bigquery.DatasetMetadata, err error)
	// Table creates a handle to a BigQuery table in the dataset.
	// To determine if a table exists, call Table.Metadata.
	// If the table does not already exist, use Table.Create to create it.
	Table(tableID string) *bigquery.Table
	// Tables returns an iterator over the tables in the Dataset.
	Tables(ctx context.Context) *bigquery.TableIterator
	// Model creates a handle to a BigQuery model in the dataset.
	// To determine if a model exists, call Model.Metadata.
	// If the model does not already exist, you can create it via execution
	// of a CREATE MODEL query.
	Model(modelID string) *bigquery.Model
	// Models returns an iterator over the models in the Dataset.
	Models(ctx context.Context) *bigquery.ModelIterator
	// Routine creates a handle to a BigQuery routine in the dataset.
	// To determine if a routine exists, call Routine.Metadata.
	Routine(routineID string) *bigquery.Routine
	// Routines returns an iterator over the routines in the Dataset.
	Routines(ctx context.Context) *bigquery.RoutineIterator
}

type Driver

type Driver struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*Driver) Open

func (d *Driver) Open(connectionString string) (c driver.Conn, err error)

Directories

Path Synopsis
dialects
examples
orm

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL