Package app.ductape.sdk.graph.adapters

Class BaseGraphAdapter

java.lang.Object

app.ductape.sdk.graph.adapters.BaseGraphAdapter

Direct Known Subclasses:

ArangoDBAdapter, CosmosGremlinAdapter, MemgraphAdapter, Neo4jAdapter, Neo4jBoltGraphAdapter, NeptuneAdapter, SpannerGraphAdapter

public abstract class BaseGraphAdapter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	connected
protected Map<String,Object>	connectionOptions
protected String	connectionUrl
protected int	maxRetries
protected final Set<GraphTypes.GraphFeature>	supportedFeatures

Constructor Summary

Constructors

Constructor	Description
BaseGraphAdapter()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	addLabels(Map<String,Object> options)
Map<String,Object>	allPaths(Map<String,Object> options)
protected void	attemptReconnect()
Map<String,Object>	beginTransaction(Map<String,Object> options)
void	commitTransaction(Map<String,Object> transaction)
abstract Map<String,Object>	connect(Map<String,Object> options)
Map<String,Object>	countNodes(Map<String,Object> options)	TS countNodes(labels?, where?, ...) aggregated result { count }.
Map<String,Object>	countRelationships(Map<String,Object> options)	TS countRelationships(types?, where?, ...) aggregated result { count }.
abstract Map<String,Object>	createNode(Map<String,Object> node)
Map<String,Object>	createNodeConstraint(Map<String,Object> options)	TS schema — node constraint DDL.
Map<String,Object>	createNodeIndex(Map<String,Object> options)	TS schema — node index DDL.
abstract Map<String,Object>	createRelationship(Map<String,Object> relationship)
Map<String,Object>	createRelationshipIndex(Map<String,Object> options)	TS schema — relationship index DDL.
abstract void	disconnect()
Map<String,Object>	dropConstraint(String constraintName)	TS schema — drop constraint by canonical name (adapter-specific semantics).
Map<String,Object>	dropIndex(String indexName)	TS schema — drop index by canonical name (adapter-specific semantics).
protected void	ensureConnected()
protected <T> T	executeWithRetry(Callable<T> operation)
protected <T> T	executeWithRetry(Callable<T> operation, int retries)
Map<String,Object>	findConnectedComponents(Map<String,Object> options)
Map<String,Object>	findNodeById(Object id)	TS findNodeById — wrapped as { node } when present.
abstract List<Map<String,Object>>	findNodes(Map<String,Object> where)
Map<String,Object>	findRelationshipById(Object id)	TS findRelationshipById — wrapped as { relationship } when present.
abstract List<Map<String,Object>>	findRelationships(Map<String,Object> where)
Map<String,Object>	fullTextSearch(Map<String,Object> options)
GraphTypes.GraphType	getGraphType()
Map<String,Object>	getNeighborhood(Map<String,Object> options)
Map<String,Object>	getStatistics()
Set<GraphTypes.GraphFeature>	getSupportedFeatures()
protected abstract GraphTypes.GraphType	graphType()
boolean	isConnected()
protected boolean	isConnectionError(Throwable error)
Map<String,Object>	listConstraints()
Map<String,Object>	listIndexes()
Map<String,Object>	listLabels()
Map<String,Object>	listRelationshipTypes()
Map<String,Object>	query(Map<String,Object> options)
Map<String,Object>	removeLabels(Map<String,Object> options)
void	rollbackTransaction(Map<String,Object> transaction)
Map<String,Object>	setLabels(Map<String,Object> options)
Map<String,Object>	shortestPath(Map<String,Object> options)
boolean	supportsFeature(GraphTypes.GraphFeature feature)
abstract Map<String,Object>	testConnection(Map<String,Object> options)
Map<String,Object>	traverse(Map<String,Object> options)
Map<String,Object>	vectorSearch(Map<String,Object> options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

connected

protected boolean connected

connectionUrl

protected String connectionUrl

connectionOptions

protected Map<String,Object> connectionOptions

maxRetries

protected int maxRetries

supportedFeatures

protected final Set<GraphTypes.GraphFeature> supportedFeatures

Constructor Details

BaseGraphAdapter

public BaseGraphAdapter()

Method Details

graphType

protected abstract GraphTypes.GraphType graphType()

isConnected

public boolean isConnected()

getGraphType

public GraphTypes.GraphType getGraphType()

supportsFeature

public boolean supportsFeature(GraphTypes.GraphFeature feature)

getSupportedFeatures

public Set<GraphTypes.GraphFeature> getSupportedFeatures()

executeWithRetry

protected <T> T executeWithRetry(Callable<T> operation)

executeWithRetry

protected <T> T executeWithRetry(Callable<T> operation,
 int retries)

isConnectionError

protected boolean isConnectionError(Throwable error)

attemptReconnect

protected void attemptReconnect()

ensureConnected

protected void ensureConnected()

connect

public abstract Map<String,Object> connect(Map<String,Object> options)

testConnection

public abstract Map<String,Object> testConnection(Map<String,Object> options)

disconnect

public abstract void disconnect()

createNode

public abstract Map<String,Object> createNode(Map<String,Object> node)

findNodes

public abstract List<Map<String,Object>> findNodes(Map<String,Object> where)

createRelationship

public abstract Map<String,Object> createRelationship(Map<String,Object> relationship)

findRelationships

public abstract List<Map<String,Object>> findRelationships(Map<String,Object> where)

beginTransaction

public Map<String,Object> beginTransaction(Map<String,Object> options)

commitTransaction

public void commitTransaction(Map<String,Object> transaction)

rollbackTransaction

public void rollbackTransaction(Map<String,Object> transaction)

query

public Map<String,Object> query(Map<String,Object> options)

traverse

public Map<String,Object> traverse(Map<String,Object> options)

getStatistics

public Map<String,Object> getStatistics()

listLabels

public Map<String,Object> listLabels()

listRelationshipTypes

public Map<String,Object> listRelationshipTypes()

listIndexes

public Map<String,Object> listIndexes()

listConstraints

public Map<String,Object> listConstraints()

shortestPath

public Map<String,Object> shortestPath(Map<String,Object> options)

allPaths

public Map<String,Object> allPaths(Map<String,Object> options)

getNeighborhood

public Map<String,Object> getNeighborhood(Map<String,Object> options)

findConnectedComponents

public Map<String,Object> findConnectedComponents(Map<String,Object> options)

fullTextSearch

public Map<String,Object> fullTextSearch(Map<String,Object> options)

vectorSearch

public Map<String,Object> vectorSearch(Map<String,Object> options)

findNodeById

public Map<String,Object> findNodeById(Object id)

TS findNodeById — wrapped as { node } when present.

findRelationshipById

public Map<String,Object> findRelationshipById(Object id)

TS findRelationshipById — wrapped as { relationship } when present.

addLabels

public Map<String,Object> addLabels(Map<String,Object> options)

removeLabels

public Map<String,Object> removeLabels(Map<String,Object> options)

setLabels

public Map<String,Object> setLabels(Map<String,Object> options)

countNodes

public Map<String,Object> countNodes(Map<String,Object> options)

TS countNodes(labels?, where?, ...) aggregated result { count }.

countRelationships

public Map<String,Object> countRelationships(Map<String,Object> options)

TS countRelationships(types?, where?, ...) aggregated result { count }.

createNodeIndex

public Map<String,Object> createNodeIndex(Map<String,Object> options)

TS schema — node index DDL.

createNodeConstraint

public Map<String,Object> createNodeConstraint(Map<String,Object> options)

TS schema — node constraint DDL.

createRelationshipIndex

public Map<String,Object> createRelationshipIndex(Map<String,Object> options)

TS schema — relationship index DDL.

dropIndex

public Map<String,Object> dropIndex(String indexName)

TS schema — drop index by canonical name (adapter-specific semantics).

dropConstraint

public Map<String,Object> dropConstraint(String constraintName)

TS schema — drop constraint by canonical name (adapter-specific semantics).