Documentation
¶
Index ¶
- Constants
- type Client
- func (mysql *Client) CountAllEdges(predicate *graph.Predicate) int64
- func (mysql *Client) CountRows(q string, args ...interface{}) int64
- func (mysql *Client) CreateDatabase(name string) bool
- func (mysql *Client) DeleteVertex(uid int64) bool
- func (mysql *Client) Exec(q string, params ...interface{}) (bool, sql.Result)
- func (mysql *Client) InsertClass(name string) (bool, int64)
- func (mysql *Client) InsertInternalTable(class *graph.Class) bool
- func (mysql *Client) InsertProperty(vertex *graph.Vertex, key string, value interface{}) bool
- func (mysql *Client) InsertVertex(class *graph.Class, X string) (bool, int64)
- func (mysql *Client) QueryAllEdges(predicate *graph.Predicate) (bool, []*graph.Link)
- func (mysql *Client) QueryClassCount(class *graph.Class) int64
- func (mysql *Client) QueryClassList(class *graph.Class, limit, page int64) (bool, []*graph.Vertex)
- func (mysql *Client) QueryClassUID(name string) (bool, int64)
- func (mysql *Client) QueryEdge(predicate *graph.Predicate, q string, args ...interface{}) (bool, *graph.Link)
- func (mysql *Client) QueryEdges(predicate *graph.Predicate, q string, args ...interface{}) (bool, []*graph.Link)
- func (mysql *Client) QueryInClassCount(class *graph.Class, predicate *graph.Predicate, subject *graph.Vertex) int64
- func (mysql *Client) QueryInClassList(class *graph.Class, predicate *graph.Predicate, subject *graph.Vertex, ...) (bool, []*graph.Vertex)
- func (mysql *Client) QueryInCount(predicate *graph.Predicate, subject *graph.Vertex) int64
- func (mysql *Client) QueryInList(predicate *graph.Predicate, subject *graph.Vertex, limit int64) (bool, []*graph.Vertex)
- func (mysql *Client) QueryLink(q string, args ...interface{}) (bool, *graph.Link)
- func (mysql *Client) QueryLinks(q string, args ...interface{}) (bool, []*graph.Link)
- func (mysql *Client) QueryOutClassCount(class *graph.Class, predicate *graph.Predicate, subject *graph.Vertex) int64
- func (mysql *Client) QueryOutClassList(class *graph.Class, predicate *graph.Predicate, subject *graph.Vertex, ...) (bool, []*graph.Vertex)
- func (mysql *Client) QueryOutCount(predicate *graph.Predicate, subject *graph.Vertex) int64
- func (mysql *Client) QueryOutList(predicate *graph.Predicate, subject *graph.Vertex, limit int64) (bool, []*graph.Vertex)
- func (mysql *Client) QueryProperties(vertex *graph.Vertex, args ...string) (bool, map[string]interface{})
- func (mysql *Client) QueryProperty(q string) (bool, interface{})
- func (mysql *Client) QueryRows(q string, params ...interface{}) (bool, *sql.Rows)
- func (mysql *Client) QuerySession(q string, args ...interface{}) (bool, *graph.Session)
- func (mysql *Client) QueryState(in, out *graph.Vertex, predicate *graph.Predicate, state bool) bool
- func (mysql *Client) QueryTable(tableName string) bool
- func (mysql *Client) QueryUser(q string, args ...interface{}) (bool, *graph.User)
- func (mysql *Client) QueryVertex(uid int64) (bool, *graph.Vertex)
- func (mysql *Client) QueryVertexByX(x string, classes ...*graph.Class) (bool, *graph.Vertex)
- func (mysql *Client) QueryVertices(q string, args ...interface{}) (bool, []*graph.Vertex)
- func (mysql *Client) SearchClassProperties(class *graph.Class, propertyName, searchInput string) (bool, []*graph.PropertyExport)
- func (mysql *Client) SearchProperties(propertyName, searchInput string) (bool, []interface{})
- func (client *Client) SetDB(db *graph.Database)
- func (client *Client) Table(id string) string
- func (mysql *Client) Traverse(in int64, predicate *graph.Predicate, phase, export bool, limit int64) (bool, []*graph.Vertex)
- func (mysql *Client) TraverseCount(in int64, predicate *graph.Predicate, phase bool) int64
- func (mysql *Client) TraverseEdges(in int64, predicate *graph.Predicate, phase bool, limit int64) (bool, []*graph.Link)
- type Credentials
Constants ¶
View Source
const (
SERVICE_NAME = "MYSQL"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
Log logging.Logger
DB *graph.Database
Credentials graph.Credentials
sync.RWMutex
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(credentials *Credentials) *Client
func (*Client) CreateDatabase ¶
func (*Client) DeleteVertex ¶
func (*Client) InsertInternalTable ¶
func (*Client) InsertProperty ¶
func (*Client) InsertVertex ¶
func (*Client) QueryAllEdges ¶
func (*Client) QueryClassList ¶
func (*Client) QueryEdges ¶
func (*Client) QueryInClassCount ¶
func (*Client) QueryInClassList ¶
func (*Client) QueryInCount ¶
func (*Client) QueryInList ¶
func (*Client) QueryLinks ¶
func (*Client) QueryOutClassCount ¶
func (*Client) QueryOutClassList ¶
func (*Client) QueryOutCount ¶
func (*Client) QueryOutList ¶
func (*Client) QueryProperties ¶
func (*Client) QueryProperty ¶
func (*Client) QuerySession ¶
func (*Client) QueryState ¶
func (*Client) QueryTable ¶
func (*Client) QueryVertexByX ¶
func (*Client) QueryVertices ¶
func (*Client) SearchClassProperties ¶
func (*Client) SearchProperties ¶
func (*Client) TraverseCount ¶
type Credentials ¶
type Credentials struct {
ProjectId string
Connection string
Database string
Username string
Password string
}
func (*Credentials) DatabaseName ¶
func (credentials *Credentials) DatabaseName() string
func (*Credentials) ProjectID ¶
func (credentials *Credentials) ProjectID() string
func (*Credentials) ServiceName ¶
func (credentials *Credentials) ServiceName() string
Source Files
Click to show internal directories.
Click to hide internal directories.