Package app.ductape.sdk.graph.adapters

Class Neo4jBoltGraphAdapter

java.lang.Object

app.ductape.sdk.graph.adapters.BaseGraphAdapter

app.ductape.sdk.graph.adapters.Neo4jBoltGraphAdapter

public class Neo4jBoltGraphAdapter
extends BaseGraphAdapter

Production Neo4j connectivity via official Bolt driver (bolt://, neo4j://, neo4j+s://, …). Selected automatically by GraphAdapterFactory when connectionUrl/uri uses a Bolt-capable scheme.

Field Summary

Fields inherited from class app.ductape.sdk.graph.adapters.BaseGraphAdapter

connected, connectionOptions, connectionUrl, maxRetries, supportedFeatures

Constructor Summary

Constructors

Constructor	Description
Neo4jBoltGraphAdapter()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	beginTransaction(Map<String,Object> options)	TS parity: open a Bolt session + transaction, honoring an optional mode field ("read" or "write", default "write") to pick the driver AccessMode.
void	commitTransaction(Map<String,Object> transaction)	TS commit(): commits the underlying Bolt transaction and closes the session.
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 }.
Map<String,Object>	createNode(Map<String,Object> node)
Map<String,Object>	createRelationship(Map<String,Object> relationship)
void	disconnect()
Map<String,Object>	findNodeById(Object id)	TS findNodeById — wrapped as { node } when present.
List<Map<String,Object>>	findNodes(Map<String,Object> where)
Map<String,Object>	findRelationshipById(Object id)	TS findRelationshipById — wrapped as { relationship } when present.
List<Map<String,Object>>	findRelationships(Map<String,Object> where)
Map<String,Object>	getStatistics()
protected GraphTypes.GraphType	graphType()
static boolean	isBoltConnection(Map<String,Object> options)
Map<String,Object>	query(Map<String,Object> options)
void	rollbackTransaction(Map<String,Object> transaction)	TS rollback(): idempotent and silent — already-completed transactions are a no-op (TS catches and swallows the second-rollback error).
Map<String,Object>	testConnection(Map<String,Object> options)

Methods inherited from class app.ductape.sdk.graph.adapters.BaseGraphAdapter

addLabels, allPaths, attemptReconnect, createNodeConstraint, createNodeIndex, createRelationshipIndex, dropConstraint, dropIndex, ensureConnected, executeWithRetry, executeWithRetry, findConnectedComponents, fullTextSearch, getGraphType, getNeighborhood, getSupportedFeatures, isConnected, isConnectionError, listConstraints, listIndexes, listLabels, listRelationshipTypes, removeLabels, setLabels, shortestPath, supportsFeature, traverse, vectorSearch

Methods inherited from class java.lang.Object

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

Constructor Details

Neo4jBoltGraphAdapter

public Neo4jBoltGraphAdapter()

Method Details

isBoltConnection

public static boolean isBoltConnection(Map<String,Object> options)

graphType

protected GraphTypes.GraphType graphType()

Specified by:

graphType in class BaseGraphAdapter

connect

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

Specified by:

connect in class BaseGraphAdapter

testConnection

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

Specified by:

testConnection in class BaseGraphAdapter

disconnect

public void disconnect()

Specified by:

disconnect in class BaseGraphAdapter

query

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

Overrides:

query in class BaseGraphAdapter

createNode

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

Specified by:

createNode in class BaseGraphAdapter

findNodes

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

Specified by:

findNodes in class BaseGraphAdapter

createRelationship

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

Specified by:

createRelationship in class BaseGraphAdapter

findRelationships

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

Specified by:

findRelationships in class BaseGraphAdapter

beginTransaction

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

TS parity: open a Bolt session + transaction, honoring an optional mode field ("read" or "write", default "write") to pick the driver AccessMode. The returned map carries id, status, and mode so GraphTransactionManager can report status nuances.

Overrides:

beginTransaction in class BaseGraphAdapter

commitTransaction

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

TS commit(): commits the underlying Bolt transaction and closes the session. If commit throws (e.g. constraint violation flushed at commit), we still close the session and remove tracking so callers can retry — TS swallows rollback errors after a failed commit, so GraphTransactionManager does the rollback dance one level up.

Overrides:

commitTransaction in class BaseGraphAdapter

rollbackTransaction

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

TS rollback(): idempotent and silent — already-completed transactions are a no-op (TS catches and swallows the second-rollback error). The session is always closed.

Overrides:

rollbackTransaction in class BaseGraphAdapter

getStatistics

public Map<String,Object> getStatistics()

Overrides:

getStatistics in class BaseGraphAdapter

countNodes

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

Description copied from class: BaseGraphAdapter

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

Overrides:

countNodes in class BaseGraphAdapter

findNodeById

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

Description copied from class: BaseGraphAdapter

TS findNodeById — wrapped as { node } when present.

Overrides:

findNodeById in class BaseGraphAdapter

findRelationshipById

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

Description copied from class: BaseGraphAdapter

TS findRelationshipById — wrapped as { relationship } when present.

Overrides:

findRelationshipById in class BaseGraphAdapter

countRelationships

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

Description copied from class: BaseGraphAdapter

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

Overrides:

countRelationships in class BaseGraphAdapter