neo4jconnection

README

Neo4j Connection

This connection allows you to configure properties necessary to establish a connection with a Neo4j Graph DB. A Neo4j Connection is necessary to work with the activities and trigger under neo4j contribution.

Installation

Flogo CLI

flogo install github.com/project-flogo/datastore-contrib/neo4j/connection

Configuration

Settings:

Name	Type	Description
name	string	A name for the connection - REQUIRED
description	string	A short description for the connection
connectionURI	string	Neo4j instance connection URI - REQUIRED
credType	string	Credential Type e.g None, BasicAuth
username	string	Username of the Neo4j instance
password	string	Password of the Neo4j instance

Example

A sample Neo4j connection

{
 "settings": {
 "name": "neo4jCon",
 "description": "",
 "connectionURI": "bolt://localhost:7687",
 "credType": "None",
 "username": "username",
 "password": "password"
}
}

Testing

Launch Neo4j docker container using below command

docker run  --publish=7474:7474 --publish=7687:7687  --volume=$HOME/neo4j/data:/data  neo4j

Open "http://localhost:7474/browser" and verify connectivity. You can optionally load sample data by running ":play movie-graph" command and follow the steps.

Documentation

Index

• func GetSharedConfiguration(conn interface{}) (connection.Manager, error)
• type Neo4jSharedConfigManager
  • func (k *Neo4jSharedConfigManager) GetConnection() interface{}
  • func (k *Neo4jSharedConfigManager) ReleaseConnection(connection interface{})
  • func (k *Neo4jSharedConfigManager) Start() error
  • func (k *Neo4jSharedConfigManager) Stop() error
  • func (k *Neo4jSharedConfigManager) Type() string
• type Settings

Functions

func GetSharedConfiguration

func GetSharedConfiguration(conn interface{}) (connection.Manager, error)

GetSharedConfiguration function to return Neo4j connection manager

Types

type Neo4jSharedConfigManager

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

Neo4jSharedConfigManager Structure

func (*Neo4jSharedConfigManager) GetConnection

func (k *Neo4jSharedConfigManager) GetConnection() interface{}

GetConnection ss

func (*Neo4jSharedConfigManager) ReleaseConnection

func (k *Neo4jSharedConfigManager) ReleaseConnection(connection interface{})

ReleaseConnection ss

func (*Neo4jSharedConfigManager) Start

func (k *Neo4jSharedConfigManager) Start() error

Start connection manager

func (*Neo4jSharedConfigManager) Stop

func (k *Neo4jSharedConfigManager) Stop() error

Stop connection manager

func (*Neo4jSharedConfigManager) Type

func (k *Neo4jSharedConfigManager) Type() string

Type of SharedConfigManager

type Settings

type Settings struct {
	Name          string `md:"name,required"`
	Description   string `md:"description"`
	ConnectionURI string `md:"connectionURI,required"`
	CredType      string `md:"credType,required"`
	UserName      string `md:"username"`
	Password      string `md:"password"`
}

Settings struct