sqldriver

Documentation

Overview

Example

package main

import (
	"database/sql"

	account2 "github.com/aliyun/aliyun-odps-go-sdk/odps/account"
	"github.com/aliyun/aliyun-odps-go-sdk/odps/restclient"
	"github.com/aliyun/aliyun-odps-go-sdk/sqldriver"
	"log"
)

func main() {
	var account = account2.AliyunAccountFromEnv()
	var endpoint = restclient.LoadEndpointFromEnv()

	config := sqldriver.NewConfig()
	config.Endpoint = endpoint
	config.AccessId = account.AccessId()
	config.AccessKey = account.AccessKey()
	config.ProjectName = "project_1"

	dsn := config.FormatDsn()
	db, err := sql.Open("odps", dsn)
	if err != nil {
		log.Fatalf("%+v", err)
	}

	rows, err := db.Query("select ti, si, i, bi, b, f, d from data_type_demo;", nil)
	if err != nil {
		log.Fatalf("%+v", err)
	}

	var ti int8
	var si int16
	var i int32
	var bi int64
	var b []byte
	var f float32
	var d float64

	for rows.Next() {
		err = rows.Scan(&ti, &si, &i, &bi, &b, &f, &d)
		if err != nil {
			log.Fatalf("%+v", err)
		}

		println(ti, si, i, bi, b, f, d)
	}

}

Index

• Variables
• type Array
  • func (n Array) IsNull() bool
  • func (n *Array) Scan(value interface{}) error
  • func (n Array) String() string
• type Binary
  • func (n Binary) IsNull() bool
  • func (n *Binary) Scan(value interface{}) error
  • func (n Binary) String() string
• type Config
  • func ParseDSN(dsn string) (*Config, error)
• type Decimal
  • func (n Decimal) IsNull() bool
  • func (n *Decimal) Scan(value interface{}) error
  • func (n Decimal) String() string
• type Map
  • func (n Map) IsNull() bool
  • func (n *Map) Scan(value interface{}) error
  • func (n Map) String() string
• type NamedArgQuery
  • func NewNamedArgQuery(query string) NamedArgQuery
  • func (n *NamedArgQuery) SetArg(name string, value interface{})
• type NullAble
• type NullBool
  • func (n NullBool) IsNull() bool
  • func (n *NullBool) Scan(value interface{}) error
• type NullDate
  • func (n NullDate) IsNull() bool
  • func (n *NullDate) Scan(value interface{}) error
  • func (n NullDate) String() string
• type NullDateTime
  • func (n NullDateTime) IsNull() bool
  • func (n *NullDateTime) Scan(value interface{}) error
  • func (n NullDateTime) String() string
• type NullFloat32
  • func (n NullFloat32) IsNull() bool
  • func (n *NullFloat32) Scan(value interface{}) error
• type NullFloat64
  • func (n NullFloat64) IsNull() bool
  • func (n *NullFloat64) Scan(value interface{}) error
• type NullInt16
  • func (n NullInt16) IsNull() bool
  • func (n *NullInt16) Scan(value interface{}) error
• type NullInt32
  • func (n NullInt32) IsNull() bool
  • func (n *NullInt32) Scan(value interface{}) error
• type NullInt64
  • func (n NullInt64) IsNull() bool
  • func (n *NullInt64) Scan(value interface{}) error
• type NullInt8
  • func (n NullInt8) IsNull() bool
  • func (n *NullInt8) Scan(value interface{}) error
• type NullString
  • func (n NullString) IsNull() bool
  • func (n *NullString) Scan(value interface{}) error
• type NullTimeStamp
  • func (n NullTimeStamp) IsNull() bool
  • func (n *NullTimeStamp) Scan(value interface{}) error
  • func (n NullTimeStamp) String() string
• type OdpsDriver
  • func (d OdpsDriver) Open(name string) (driver.Conn, error)
• type PositionArgQuery
  • func NewPositionArgQuery(query string) PositionArgQuery
  • func (p *PositionArgQuery) SetArgs(args ...interface{})
• type Struct
  • func (n Struct) IsNull() bool
  • func (n *Struct) Scan(value interface{}) error
  • func (n Struct) String() string

Examples

• Package

Variables

var NewConfig = odps.NewConfig

var NewConfigFromIni = odps.NewConfigFromIni

Types

type Array

type Array data.Array

func (Array) IsNull

func (n Array) IsNull() bool

func (*Array) Scan

func (n *Array) Scan(value interface{}) error

func (Array) String

func (n Array) String() string

type Binary

type Binary sql.RawBytes

func (Binary) IsNull

func (n Binary) IsNull() bool

func (*Binary) Scan

func (n *Binary) Scan(value interface{}) error

func (Binary) String

func (n Binary) String() string

type Config

type Config = odps.Config

Config is a configuration parsed from a DSN string. If a new Config is created instead of being parsed from a DSN string, the NewConfig function should be used, which sets default values.

func ParseDSN

func ParseDSN(dsn string) (*Config, error)

ParseDSN dsn格式如下 http://AccessId:AccessKey@host:port/path?project=<project_name>&stsToken=<sts_token>&tcpConnectionTimeout=30&httpTimeout=60&tunnelQuotaName=<quota_name> 其中project参数为必填项

type Decimal

type Decimal data.Decimal

func (Decimal) IsNull

func (n Decimal) IsNull() bool

func (*Decimal) Scan

func (n *Decimal) Scan(value interface{}) error

func (Decimal) String

func (n Decimal) String() string

type Map

type Map data.Map

func (Map) IsNull

func (n Map) IsNull() bool

func (*Map) Scan

func (n *Map) Scan(value interface{}) error

func (Map) String

func (n Map) String() string

type NamedArgQuery

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

func NewNamedArgQuery

func NewNamedArgQuery(query string) NamedArgQuery

func (*NamedArgQuery) SetArg

func (n *NamedArgQuery) SetArg(name string, value interface{})

type NullAble

type NullAble interface {
	IsNull() bool
}

type NullBool

type NullBool sql.NullBool

func (NullBool) IsNull

func (n NullBool) IsNull() bool

func (*NullBool) Scan

func (n *NullBool) Scan(value interface{}) error

type NullDate

type NullDate sql.NullTime

func (NullDate) IsNull

func (n NullDate) IsNull() bool

func (*NullDate) Scan

func (n *NullDate) Scan(value interface{}) error

func (NullDate) String

func (n NullDate) String() string

type NullDateTime

type NullDateTime sql.NullTime

func (NullDateTime) IsNull

func (n NullDateTime) IsNull() bool

func (*NullDateTime) Scan

func (n *NullDateTime) Scan(value interface{}) error

func (NullDateTime) String

func (n NullDateTime) String() string

type NullFloat32

type NullFloat32 struct {
	Float32 float32
	Valid   bool
}

func (NullFloat32) IsNull

func (n NullFloat32) IsNull() bool

func (*NullFloat32) Scan

func (n *NullFloat32) Scan(value interface{}) error

type NullFloat64

type NullFloat64 sql.NullFloat64

func (NullFloat64) IsNull

func (n NullFloat64) IsNull() bool

func (*NullFloat64) Scan

func (n *NullFloat64) Scan(value interface{}) error

type NullInt16

type NullInt16 struct {
	Int16 int16
	Valid bool //Valid is true if Int16 is not NULL
}

func (NullInt16) IsNull

func (n NullInt16) IsNull() bool

func (*NullInt16) Scan

func (n *NullInt16) Scan(value interface{}) error

type NullInt32

type NullInt32 sql.NullInt32

func (NullInt32) IsNull

func (n NullInt32) IsNull() bool

func (*NullInt32) Scan

func (n *NullInt32) Scan(value interface{}) error

type NullInt64

type NullInt64 sql.NullInt64

func (NullInt64) IsNull

func (n NullInt64) IsNull() bool

func (*NullInt64) Scan

func (n *NullInt64) Scan(value interface{}) error

type NullInt8

type NullInt8 struct {
	Int8  int8
	Valid bool //Valid is true if Int16 is not NULL
}

func (NullInt8) IsNull

func (n NullInt8) IsNull() bool

func (*NullInt8) Scan

func (n *NullInt8) Scan(value interface{}) error

type NullString

type NullString sql.NullString

func (NullString) IsNull

func (n NullString) IsNull() bool

func (*NullString) Scan

func (n *NullString) Scan(value interface{}) error

type NullTimeStamp

type NullTimeStamp sql.NullTime

func (NullTimeStamp) IsNull

func (n NullTimeStamp) IsNull() bool

func (*NullTimeStamp) Scan

func (n *NullTimeStamp) Scan(value interface{}) error

func (NullTimeStamp) String

func (n NullTimeStamp) String() string

type OdpsDriver

type OdpsDriver struct{}

func (OdpsDriver) Open

func (d OdpsDriver) Open(name string) (driver.Conn, error)

type PositionArgQuery

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

func NewPositionArgQuery

func NewPositionArgQuery(query string) PositionArgQuery

func (*PositionArgQuery) SetArgs

func (p *PositionArgQuery) SetArgs(args ...interface{})

type Struct

type Struct data.Struct

func (Struct) IsNull

func (n Struct) IsNull() bool

func (*Struct) Scan

func (n *Struct) Scan(value interface{}) error

func (Struct) String

func (n Struct) String() string