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 Config
  • func ParseDSN(dsn string) (*Config, error)
• type NamedArgQuery
  • func NewNamedArgQuery(query string) NamedArgQuery
  • func (n *NamedArgQuery) SetArg(name string, value interface{})
• type OdpsDriver
  • func (d OdpsDriver) Open(name string) (driver.Conn, error)
• type PositionArgQuery
  • func NewPositionArgQuery(query string) PositionArgQuery
  • func (p *PositionArgQuery) SetArgs(args ...interface{})

Examples

• Package

Variables

var NewConfig = odps.NewConfig

var NewConfigFromIni = odps.NewConfigFromIni

Types

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=""&stsToken=""&tcpConnectionTimeout=30&httpTimeout=60 其中project参数为必填项

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 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{})