dbtype

Documentation

Index

• Constants
• func NewResult() *resultSet
• type ColVal
  • func NewColVal() *ColVal
  • func (c ColVal) GetNum() int64
  • func (c *ColVal) String() string
• type Link
  • func NewLinks(ID int64, startNodeId int64, endNodeId int64, typ string, ...) *Link
  • func (l Link) String() string
• type Node
  • func (n Node) String() string
• type Record
  • func (r Record) String() string
• type RecordSet
  • func NewRecordSet() *RecordSet
  • func (r *RecordSet) Err() error
  • func (r *RecordSet) GetLinkById(id int64) *Link
  • func (r *RecordSet) GetNodeById(id int64) *Node
  • func (r *RecordSet) Next() bool
  • func (r *RecordSet) Record() Record
• type ResultInfo
• type ResultSet

Constants

const (
	HeadIndexStatus      = iota
	HeadIndexCursor      // 1
	HeadIndexResults     // 2
	HeadIndexAddNodes    // 3
	HeadIndexAddLinks    // 4
	HeadIndexModifyNodes // 5
	HeadIndexModifyLinks // 6
	HeadIndexDeleteNodes // 7
	HeadIndexDeleteLinks // 8
	HeadIndexBodyLen     // 9
)

parse the MsgTypeParseObject into an array,HeadIndexxx response the index of array

Functions

func NewResult

func NewResult() *resultSet

Types

type ColVal

type ColVal struct {
	Val    interface{}
	Type   int
	AryLen int
}

func NewColVal

func NewColVal() *ColVal

func (ColVal) GetNum

func (c ColVal) GetNum() int64

func (*ColVal) String

func (c *ColVal) String() string

type Link

type Link struct {
	ID          int64
	StartNodeId int64
	EndNodeId   int64
	Type        string
	// contains filtered or unexported fields
}

func NewLinks

func NewLinks(ID int64, startNodeId int64, endNodeId int64, typ string, properties map[string]*ColVal) *Link

func (Link) String

func (l Link) String() string

type Node

type Node struct {
	ID         int64
	Labels     []string
	Properties map[string]*ColVal
}

func (Node) String

func (n Node) String() string

type Record

type Record []*ColVal

func (Record) String

func (r Record) String() string

type RecordSet

type RecordSet struct {
	Labels   []string
	Types    []string
	KeyNames []string
	Nodes    []*Node
	Links    []*Link
	Records  []Record
	// contains filtered or unexported fields
}

func NewRecordSet

func NewRecordSet() *RecordSet

func (*RecordSet) Err

func (r *RecordSet) Err() error

func (*RecordSet) GetLinkById

func (r *RecordSet) GetLinkById(id int64) *Link

func (*RecordSet) GetNodeById

func (r *RecordSet) GetNodeById(id int64) *Node

func (*RecordSet) Next

func (r *RecordSet) Next() bool

func (*RecordSet) Record

func (r *RecordSet) Record() Record

type ResultInfo

type ResultInfo struct {
	Status      int
	Cursor      int
	Results     int
	AddNodes    int
	AddLinks    int
	ModifyNodes int
	ModifyLinks int
	DeleteNodes int
	DeleteLinks int
	Msg         string
	// contains filtered or unexported fields
}

type ResultSet

type ResultSet interface {
	RecordSet() *RecordSet
	Next() bool
	Record() Record
	Err() error // 迭代过程中判断Error
}