executeCypherQuery

README

Neo4j Execute Cypher Query

This activity allows you to query Neo4j Graph DB using Cypher Query Language

Installation

Flogo CLI

flogo install github.com/project-flogo/datastore-contrib/neo4j/activity/executeCypherQuery

Configuration

Settings:

Name	Type	Description
connection	connection	Choose a Neo4j connection from the drop down - REQUIRED

Input:

Name	Type	Description
cypherQuery	string	The Cypher Query to execute

Output:

Name	Type	Description
output	any	Returns cypher query execution response

Example

{
  
}

Documentation

Index

• func New(ctx activity.InitContext) (activity.Activity, error)
• type Activity
  • func (a *Activity) Cleanup() error
  • func (a *Activity) Eval(context activity.Context) (done bool, err error)
  • func (a *Activity) Metadata() *activity.Metadata
• type Input
  • func (i *Input) FromMap(values map[string]interface{}) error
  • func (i *Input) ToMap() map[string]interface{}
• type NodeOutput
• type Output
  • func (o *Output) FromMap(values map[string]interface{}) error
  • func (o *Output) ToMap() map[string]interface{}
• type Settings

Functions

func New

func New(ctx activity.InitContext) (activity.Activity, error)

New functioncommon

Types

type Activity

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

Activity is a stub for your Activity implementation

func (*Activity) Cleanup

func (a *Activity) Cleanup() error

Cleanup method

func (*Activity) Eval

func (a *Activity) Eval(context activity.Context) (done bool, err error)

Eval implements activity.Activity.Eval

func (*Activity) Metadata

func (a *Activity) Metadata() *activity.Metadata

Metadata implements activity.Activity.Metadata

type Input

type Input struct {
	CypherQuery string                 `md:"cypherQuery,required"` // The cypher query
	QueryParams map[string]interface{} `md:"queryParams"`
}

Input structure

func (*Input) FromMap

func (i *Input) FromMap(values map[string]interface{}) error

FromMap method

func (*Input) ToMap

func (i *Input) ToMap() map[string]interface{}

ToMap method

type NodeOutput

type NodeOutput struct {
	Id     int64
	Labels []string
	Props  map[string]interface{}
}

type Output

type Output struct {
	Output interface{} `md:"response"` // The JSON Response of the query
}

Output structure

func (*Output) FromMap

func (o *Output) FromMap(values map[string]interface{}) error

FromMap Output

func (*Output) ToMap

func (o *Output) ToMap() map[string]interface{}

ToMap Output

type Settings

type Settings struct {
	Connection   string `md:"connection,required"` // The Neo4j connection
	DatabaseName string `md:"databaseName,required"`
	AccessMode   string `md:"accessMode,required"`
}

Settings structure