Response Processing

The GQLDB Python driver provides the Response and Row classes for working with query results. This guide covers how to extract and convert data from query responses.

Response Class

The gql() method returns a Response object containing query results:

Python
from gqldb import GqldbClient, GqldbConfig

config = GqldbConfig(hosts=["localhost:9000"])

with GqldbClient(config) as client:
    client.login("admin", "password")
    client.use_graph("myGraph")

    response = client.gql("MATCH (n:User) RETURN n.name, n.age")

    print(f"Columns: {response.columns}")        # ["n.name", "n.age"]
    print(f"Row count: {response.row_count}")    # Number of rows
    print(f"Has more: {response.has_more}")      # Pagination indicator
    print(f"Warnings: {response.warnings}")      # Any query warnings
    print(f"Rows affected: {response.rows_affected}")  # For write operations

Response Attributes and Methods

Row Class

Each row contains values that can be accessed by index:

Python
response = client.gql("MATCH (n:User) RETURN n.name, n.age, n.active")

for row in response:
    # Access by index
    name = row.get(0)      # First column
    age = row.get(1)       # Second column
    active = row.get(2)    # Third column

    # Typed accessors
    name_str = row.get_string(0)    # Returns str
    age_int = row.get_int(1)        # Returns int
    active_bool = row.get_bool(2)   # Returns bool

    print(f"{name_str}, age {age_int}, active: {active_bool}")

Row Methods

Iterating Results

Using for loop

Python
response = client.gql("MATCH (n) RETURN n")

# Response implements __iter__
for row in response:
    print(row.get(0))

Using for_each

Python
def process_row(row, index):
    print(f"Row {index}: {row.get(0)}")

response.for_each(process_row)

Using map

Python
names = response.map(lambda row: row.get_string(0))
print(f"Names: {names}")

Quick Access Methods

First and Last Row

Python
first = response.first()  # First row or None
last = response.last()    # Last row or None

if first:
    print(f"First result: {first.get(0)}")

Check if Empty

Python
if response.is_empty():
    print("No results found")

Single Value

For queries that return a single row with a single column:

Python
count_response = client.gql("MATCH (n) RETURN count(n)")
count = count_response.single_value()  # Returns the single value

# Typed single value accessors
count_int = count_response.single_int()      # As int
count_str = count_response.single_string()   # As string

Converting to Dictionaries

to_dicts()

Convert rows to a list of dictionaries:

Python
response = client.gql("MATCH (u:User) RETURN u.name AS name, u.age AS age")
users = response.to_dicts()

# Result: [{"name": "Alice", "age": 30}, {"name": "Bob", "age": 25}]
for user in users:
    print(f"{user['name']} is {user['age']} years old")

to_json()

Convert to JSON string:

Python
json_str = response.to_json()
print(json_str)

Get Value by Column Name

Python
response = client.gql("MATCH (u:User) RETURN u.name AS name, u.age AS age")

for row in response:
    name = response.get_by_name(row, "name")
    age = response.get_by_name(row, "age")
    print(f"{name}: {age}")

Accessing Result Columns

Query results are organized by columns (aliases). To extract typed data such as nodes, edges, paths, tables, or attributes, you must first select a column using alias() (by name) or get() (by index). These return an AliasResult object with type-specific extraction methods.

alias()

Select a column by its alias name:

Python
response = client.gql("MATCH (u:User)-[e:Follows]->(f:User) RETURN u, e, f")

# Access by alias name
users = response.alias("u").as_nodes()
edges = response.alias("e").as_edges()
friends = response.alias("f").as_nodes()

get()

Select a column by its positional index:

Python
response = client.gql("MATCH (u:User) RETURN u, u.name")

# Access by index
nodes, schemas = response.get(0).as_nodes()
names = response.get(1).as_attr()

AliasResult Class

The AliasResult object returned by alias() and get() provides the following methods:

Extracting Graph Elements

as_nodes()

Extract nodes from a specific column of the response using alias() or get():

Python
from gqldb import Node

response = client.gql("MATCH (u:User) RETURN u")
nodes, schemas = response.alias("u").as_nodes()

# Access nodes
for node in nodes:
    print(f"ID: {node.id}")
    print(f"Labels: {node.labels}")
    print(f"Properties: {node.properties}")

# Access inferred schemas
for label, schema in schemas.items():
    print(f"Schema for {label}: {schema}")

Node Class

Python
@dataclass
class Node:
    id: str
    labels: List[str]
    properties: Dict[str, Any]

as_edges()

Extract edges from a specific column of the response using alias() or get():

Python
from gqldb import Edge

response = client.gql("MATCH ()-[e:Follows]->() RETURN e")
edges, schemas = response.alias("e").as_edges()

for edge in edges:
    print(f"ID: {edge.id}")
    print(f"Label: {edge.label}")
    print(f"From: {edge.from_node_id}")
    print(f"To: {edge.to_node_id}")
    print(f"Properties: {edge.properties}")

Edge Class

Python
@dataclass
class Edge:
    id: str
    label: str
    from_node_id: str
    to_node_id: str
    properties: Dict[str, Any]

as_paths()

Extract paths from a specific column of the response using alias() or get():

Python
from gqldb import Path

response = client.gql("MATCH p = (a)-[*1..3]->(b) RETURN p LIMIT 10")
paths = response.alias("p").as_paths()

for path in paths:
    print(f"Path nodes: {len(path.nodes)}")
    print(f"Path edges: {len(path.edges)}")

    # Print path
    for i, node in enumerate(path.nodes):
        print(f"  Node: {node.id}")
        if i < len(path.edges):
            print(f"    -[{path.edges[i].label}]->")

Path Class

Python
@dataclass
class Path:
    nodes: List[Node]
    edges: List[Edge]

Table Format

as_table()

Get a specific column of the response as a generic table using alias() or get():

Python
response = client.gql("MATCH (u:User) RETURN u.name, u.age")
table = response.get(0).as_table()

print(f"Headers: {[h.name for h in table.headers]}")
print(f"Rows: {table.rows}")

Table and Header Classes

Python
@dataclass
class Table:
    name: str
    headers: List[Header]
    rows: List[List[Any]]

@dataclass
class Header:
    name: str
    type: PropertyType

Attribute Extraction

as_attr()

Extract values from a specific column using alias() or get():

Python
response = client.gql("MATCH (u:User) RETURN u.age AS age")
age_attr = response.alias("age").as_attr()

print(f"Column name: {age_attr.name}")
print(f"Type: {age_attr.type}")
print(f"Values: {age_attr.values}")

# Calculate statistics
ages = [v for v in age_attr.values if isinstance(v, (int, float))]
if ages:
    avg_age = sum(ages) / len(ages)
    print(f"Average age: {avg_age}")

Attr Class

Python
@dataclass
class Attr:
    name: str
    type: PropertyType
    values: List[Any]

Complete Example

Python
from gqldb import GqldbClient, GqldbConfig
from gqldb.errors import GqldbError

def main():
    config = GqldbConfig(
        hosts=["localhost:9000"],
        default_graph="socialNetwork"
    )

    with GqldbClient(config) as client:
        client.login("admin", "password")

        # Setup test data
        client.create_graph("socialNetwork")
        client.use_graph("socialNetwork")
        client.gql("""
            INSERT (a:User {_id: 'u1', name: 'Alice', age: 30}),
                   (b:User {_id: 'u2', name: 'Bob', age: 25}),
                   (c:User {_id: 'u3', name: 'Charlie', age: 35}),
                   (a)-[:Follows {since: '2023-01'}]->(b),
                   (b)-[:Follows {since: '2023-03'}]->(c),
                   (c)-[:Follows {since: '2023-06'}]->(a)
        """)

        # Query nodes
        print("=== Query Nodes ===")
        node_response = client.gql("MATCH (u:User) RETURN u LIMIT 5")
        nodes, schemas = node_response.alias("u").as_nodes()
        for node in nodes:
            print(f"User {node.id}: {node.properties.get('name')}")

        # Query with multiple columns
        print("\n=== Query Columns ===")
        col_response = client.gql(
            "MATCH (u:User) RETURN u.name AS name, u.age AS age ORDER BY u.age DESC LIMIT 3"
        )
        users = col_response.to_dicts()
        print(f"Top 3 oldest users: {users}")

        # Query paths
        print("\n=== Query Paths ===")
        path_response = client.gql(
            "MATCH p = (a:User)-[:Follows*1..2]->(b:User) RETURN p LIMIT 3"
        )
        paths = path_response.alias("p").as_paths()
        for path in paths:
            route = " -> ".join(n.properties.get("name", n.id) for n in path.nodes)
            print(f"Path: {route}")

        # Aggregate query
        print("\n=== Aggregate Query ===")
        count_response = client.gql("MATCH (n) RETURN count(n)")
        print(f"Total nodes: {count_response.single_int()}")

        # Extract attribute values
        print("\n=== Attribute Extraction ===")
        age_response = client.gql("MATCH (u:User) RETURN u.age AS age")
        ages = age_response.alias("age").as_attr()
        numeric_ages = [v for v in ages.values if isinstance(v, (int, float))]

        if numeric_ages:
            print(f"Ages: {numeric_ages}")
            print(f"Min age: {min(numeric_ages)}")
            print(f"Max age: {max(numeric_ages)}")

        # Cleanup
        client.drop_graph("socialNetwork")

if __name__ == "__main__":
    main()