sql

package
v0.0.0-...-05f225d Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const QuadStoreType = "sql"

Variables

This section is empty.

Functions

func RegisterFlavor 

func RegisterFlavor(f Flavor)

Types

type AllIterator 

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

func NewAllIterator 

func NewAllIterator(qs *QuadStore, table string) *AllIterator

func (*AllIterator) Clone 

func (it *AllIterator) Clone() graph.Iterator

func (*AllIterator) Close 

func (it *AllIterator) Close() error

func (*AllIterator) Contains 

func (it *AllIterator) Contains(v graph.Value) bool

func (*AllIterator) Describe 

func (it *AllIterator) Describe() graph.Description

func (*AllIterator) Err 

func (it *AllIterator) Err() error

func (*AllIterator) Next 

func (it *AllIterator) Next() bool

func (*AllIterator) NextPath 

func (it *AllIterator) NextPath() bool

func (*AllIterator) Optimize 

func (it *AllIterator) Optimize() (graph.Iterator, bool)

func (*AllIterator) Reset 

func (it *AllIterator) Reset()

func (*AllIterator) Result 

func (it *AllIterator) Result() graph.Value

func (*AllIterator) Size 

func (it *AllIterator) Size() (int64, bool)

func (*AllIterator) Sorted 

func (it *AllIterator) Sorted() bool

func (*AllIterator) Stats 

func (it *AllIterator) Stats() graph.IteratorStats

func (*AllIterator) SubIterators 

func (it *AllIterator) SubIterators() []graph.Iterator

func (*AllIterator) TagResults 

func (it *AllIterator) TagResults(dst map[string]graph.Value)

func (*AllIterator) Tagger 

func (it *AllIterator) Tagger() *graph.Tagger

func (*AllIterator) Type 

func (it *AllIterator) Type() graph.Type

func (*AllIterator) UID 

func (it *AllIterator) UID() uint64

type AmbiguousCommitError 

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

AmbiguousCommitError represents an error that left a transaction in an ambiguous state: unclear if it committed or not.

type Flavor 

type Flavor struct {
	Name                string
	Driver              string
	NodesTable          string
	QuadsTable          string
	FieldQuote          rune
	Placeholder         func(int) string
	Indexes             func(graph.Options) []string
	Error               func(error) error
	Estimated           func(table string) string
	RunTx               func(tx *sql.Tx, in []graph.Delta, opts graph.IgnoreOpts) error
	NoSchemaChangesInTx bool
}

type NodeHash 

type NodeHash [quad.HashSize]byte

func (NodeHash) IsNode 

func (NodeHash) IsNode() bool

func (NodeHash) Key 

func (h NodeHash) Key() interface{}

func (*NodeHash) Scan 

func (h *NodeHash) Scan(src interface{}) error

func (NodeHash) String 

func (h NodeHash) String() string

func (NodeHash) Valid 

func (h NodeHash) Valid() bool

type NullTime 

type NullTime struct {
	Time  time.Time
	Valid bool // Valid is true if Time is not NULL
}

NullTime represents a time.Time that may be null. NullTime implements the sql.Scanner interface so it can be used as a scan destination, similar to sql.NullString.

func (*NullTime) Scan 

func (nt *NullTime) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTime) Value 

func (nt NullTime) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type QuadHashes 

type QuadHashes [4]NodeHash

func (QuadHashes) Get 

func (q QuadHashes) Get(d quad.Direction) NodeHash

func (QuadHashes) IsNode 

func (QuadHashes) IsNode() bool

func (QuadHashes) Key 

func (q QuadHashes) Key() interface{}

type QuadStore 

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

func (*QuadStore) ApplyDeltas 

func (qs *QuadStore) ApplyDeltas(in []graph.Delta, opts graph.IgnoreOpts) error

func (*QuadStore) Close 

func (qs *QuadStore) Close() error

func (*QuadStore) FixedIterator 

func (qs *QuadStore) FixedIterator() graph.FixedIterator

func (*QuadStore) Horizon 

func (qs *QuadStore) Horizon() graph.PrimaryKey

func (*QuadStore) NameOf 

func (qs *QuadStore) NameOf(v graph.Value) quad.Value

func (*QuadStore) NodesAllIterator 

func (qs *QuadStore) NodesAllIterator() graph.Iterator

func (*QuadStore) OptimizeIterator 

func (qs *QuadStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)

func (*QuadStore) Quad 

func (qs *QuadStore) Quad(val graph.Value) quad.Quad

func (*QuadStore) QuadDirection 

func (qs *QuadStore) QuadDirection(in graph.Value, d quad.Direction) graph.Value

func (*QuadStore) QuadIterator 

func (qs *QuadStore) QuadIterator(d quad.Direction, val graph.Value) graph.Iterator

func (*QuadStore) QuadsAllIterator 

func (qs *QuadStore) QuadsAllIterator() graph.Iterator

func (*QuadStore) Size 

func (qs *QuadStore) Size() int64

func (*QuadStore) Type 

func (qs *QuadStore) Type() string

func (*QuadStore) ValueOf 

func (qs *QuadStore) ValueOf(s quad.Value) graph.Value

type SQLIterator 

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

func NewSQLIterator 

func NewSQLIterator(qs *QuadStore, sql sqlIterator) *SQLIterator

func NewSQLLinkIterator 

func NewSQLLinkIterator(qs *QuadStore, d quad.Direction, v quad.Value) *SQLIterator

func (*SQLIterator) Clone 

func (it *SQLIterator) Clone() graph.Iterator

func (*SQLIterator) Close 

func (it *SQLIterator) Close() error

func (*SQLIterator) Contains 

func (it *SQLIterator) Contains(v graph.Value) bool

func (*SQLIterator) Describe 

func (it *SQLIterator) Describe() graph.Description

func (*SQLIterator) Err 

func (it *SQLIterator) Err() error

func (*SQLIterator) Next 

func (it *SQLIterator) Next() bool

func (*SQLIterator) NextPath 

func (it *SQLIterator) NextPath() bool

func (*SQLIterator) Optimize 

func (it *SQLIterator) Optimize() (graph.Iterator, bool)

func (*SQLIterator) Reset 

func (it *SQLIterator) Reset()

func (*SQLIterator) Result 

func (it *SQLIterator) Result() graph.Value

func (*SQLIterator) Size 

func (it *SQLIterator) Size() (int64, bool)

func (*SQLIterator) Sorted 

func (it *SQLIterator) Sorted() bool

func (*SQLIterator) Stats 

func (it *SQLIterator) Stats() graph.IteratorStats

func (*SQLIterator) SubIterators 

func (it *SQLIterator) SubIterators() []graph.Iterator

func (*SQLIterator) TagResults 

func (it *SQLIterator) TagResults(dst map[string]graph.Value)

func (*SQLIterator) Tagger 

func (it *SQLIterator) Tagger() *graph.Tagger

func (*SQLIterator) Type 

func (it *SQLIterator) Type() graph.Type

func (*SQLIterator) UID 

func (it *SQLIterator) UID() uint64

type SQLLinkIterator 

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

func (*SQLLinkIterator) Describe 

func (l *SQLLinkIterator) Describe() string

func (*SQLLinkIterator) Result 

func (l *SQLLinkIterator) Result() graph.Value

func (*SQLLinkIterator) Size 

func (l *SQLLinkIterator) Size(qs *QuadStore) (int64, bool)

func (*SQLLinkIterator) Tagger 

func (l *SQLLinkIterator) Tagger() *graph.Tagger

func (*SQLLinkIterator) Type 

func (l *SQLLinkIterator) Type() sqlQueryType

type SQLNodeIntersection 

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

func (*SQLNodeIntersection) Describe 

func (n *SQLNodeIntersection) Describe() string

func (*SQLNodeIntersection) Result 

func (n *SQLNodeIntersection) Result() graph.Value

func (*SQLNodeIntersection) Size 

func (n *SQLNodeIntersection) Size(qs *QuadStore) (int64, bool)

func (*SQLNodeIntersection) Tagger 

func (n *SQLNodeIntersection) Tagger() *graph.Tagger

func (*SQLNodeIntersection) Type 

func (n *SQLNodeIntersection) Type() sqlQueryType

type SQLNodeIterator 

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

func (*SQLNodeIterator) Describe 

func (n *SQLNodeIterator) Describe() string

func (*SQLNodeIterator) Result 

func (n *SQLNodeIterator) Result() graph.Value

func (*SQLNodeIterator) Size 

func (n *SQLNodeIterator) Size(qs *QuadStore) (int64, bool)

func (*SQLNodeIterator) Tagger 

func (n *SQLNodeIterator) Tagger() *graph.Tagger

func (*SQLNodeIterator) Type 

func (n *SQLNodeIterator) Type() sqlQueryType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.