neo4j :: SequentialNodeCollection
A Neo4j node collection using a sequential identification scheme.neo4j $ SequentialNodeCollection
A Neo4j node collection using a sequential identification scheme.Serializable::inspect to show more useful information
			curl :: native_curl
Binding of C libCurl which allow us to interact with network.serialization :: serialization_core
Abstract services to serialize Nit objects to different formatsdeserialize_json and JsonDeserializer
			serialize_to_json and JsonSerializer
			core :: union_find
union–find algorithm using an efficient disjoint-set data structure
# Provides a sequential identification scheme for Neo4j nodes.
module neo4j::graph::sequential_id
import graph
private import pipeline
# A Neo4j node collection using a sequential identification scheme.
#
# The local IDs are sequential numbers (integers) starting at `1`.
#
# Note: When loading nodes, the local IDs should forms a mostly contiguous
# range starting at `1`. Else, this collection will consume a lot of memory.
# Futhermore, the local IDs **must** be positive.
#
# ~~~nit
# var nodes = new SequentialNodeCollection("id")
# var a = nodes.create_node
# var b = new NeoNode
# var c = new NeoNode
#
# nodes.register b
# c["id"] = 4
# nodes.add c
# assert a["id"] == 1
# assert b["id"] == 2
# assert c["id"] == 4
# assert nodes.to_a == [a, b, c]
# assert nodes.length == 3
#
# nodes.compact
# assert a["id"] == 1
# assert b["id"] == 2
# assert c["id"] == 3
# assert nodes.to_a == [a, b, c]
# assert nodes.length == 3
# ~~~
class SequentialNodeCollection
	super NeoNodeCollection
	redef type ID_TYPE: Int
	private var nodes = new Array[nullable NeoNode]
	redef var length = 0
	redef fun iterator do return new NullSkipper[NeoNode](self.nodes.iterator)
	redef fun [](id) do return nodes[id].as(NeoNode)
	redef fun get_or_null(id) do
		if id < 0 or id > nodes.length then return null
		return nodes[id]
	end
	redef fun has_id(id) do
		return id >= 0 and id < nodes.length and nodes[id] isa NeoNode
	end
	redef fun enlarge(cap) do nodes.enlarge(cap)
	redef fun register(node) do
		nodes.add node
		id_of(node) = nodes.length
		length += 1
	end
	redef fun add(node) do
		var id = node[id_property]
		assert id isa Int else
			sys.stderr.write "The local ID must be an `Int`.\n"
		end
		assert id >= 0 else
			sys.stderr.write "The local ID must be greater or equal to 0. Got {id}.\n"
		end
		# Pad with nulls.
		nodes.enlarge(id)
		var delta = id - nodes.length
		while delta > 0 do
			nodes.add null
			delta -= 1
		end
		nodes[id] = node
		length += 1
	end
	redef fun remove_at(id) do
		nodes[id] = null
		length -= 1
	end
	redef fun clear do
		nodes.clear
		length = 0
	end
	redef fun compact do
		var i = iterator
		nodes = new Array[nullable NeoNode]
		for n in i do
			nodes.add n
			id_of(n) = nodes.length
		end
	end
end
lib/neo4j/graph/sequential_id.nit:11,1--116,3