Application Development

Building applications with Geode enables developers to leverage graph database capabilities for modeling complex relationships, traversing networks efficiently, and discovering patterns in connected data. This guide explores application development patterns, architecture strategies, and best practices for graph-powered systems. <h3 id="application-architecture-patterns" class="position-relative d-flex align-items-center group"> Application Architecture Patterns <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="application-architecture-patterns" aria-haspopup="dialog" aria-label="Share link: Application Architecture Patterns"> Share link </button> </h3><div id="headingShareModal" class="heading-share-modal" role="dialog" aria-modal="true" aria-labelledby="headingShareTitle" hidden> <div class="hsm-dialog" role="document"> <div class="hsm-header"> <h2 id="headingShareTitle" class="h6 mb-0 fw-bold">Share this section</h2> <button type="button" class="hsm-close" aria-label="Close"> </button> </div> <div class="hsm-body"> <label for="headingShareInput" class="form-label small text-muted mb-1 text-uppercase fw-bold" style="font-size: 0.7rem; letter-spacing: 0.5px;">Permalink</label> <div class="input-group mb-4 hsm-url-group"> <input id="headingShareInput" type="text" class="form-control font-monospace" readonly aria-readonly="true" style="font-size: 0.85rem;" /> <button class="btn btn-primary hsm-copy" type="button" aria-label="Copy" title="Copy"> </button> </div> <div class="small fw-bold mb-2 text-muted text-uppercase" style="font-size: 0.7rem; letter-spacing: 0.5px;">Share via</div> <div class="hsm-share-grid"> <a id="share-twitter" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Twitter </a> <a id="share-linkedin" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> LinkedIn </a> <a id="share-facebook" class="btn btn-outline-secondary w-100" target="_blank" rel="noopener noreferrer"> Facebook </a> </div> </div> </div> </div> <style> .heading-share-modal { position: fixed; inset: 0; display: flex; justify-content: center; align-items: center; background: rgba(0, 0, 0, 0.6); z-index: 1050; padding: 1rem; backdrop-filter: blur(4px); -webkit-backdrop-filter: blur(4px); } .heading-share-modal[hidden] { display: none !important; } .hsm-dialog { max-width: 420px; width: 100%; background: var(--bs-body-bg, #fff); color: var(--bs-body-color, #212529); border: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); border-radius: 1rem; box-shadow: 0 25px 50px -12px rgba(0, 0, 0, 0.25); overflow: hidden; animation: hsm-fade-in 0.2s ease-out; } @keyframes hsm-fade-in { from { opacity: 0; transform: scale(0.95); } to { opacity: 1; transform: scale(1); } } [data-bs-theme="dark"] .hsm-dialog { background: #1e293b; border-color: rgba(255,255,255,0.1); color: #f8f9fa; } .hsm-header { display: flex; justify-content: space-between; align-items: center; padding: 1rem 1.5rem; border-bottom: 1px solid var(--bs-border-color, rgba(0,0,0,0.1)); background: rgba(0,0,0,0.02); } [data-bs-theme="dark"] .hsm-header { background: rgba(255,255,255,0.02); border-color: rgba(255,255,255,0.1); } .hsm-close { background: transparent; border: none; color: inherit; opacity: 0.5; padding: 0.25rem 0.5rem; border-radius: 0.25rem; font-size: 1.2rem; line-height: 1; transition: opacity 0.2s; } .hsm-close:hover { opacity: 1; } .hsm-body { padding: 1.5rem; } .hsm-url-group { display: flex !important; align-items: stretch; } .hsm-url-group .form-control { flex: 1; min-width: 0; margin: 0; background: var(--bs-secondary-bg, #f8f9fa); border-color: var(--bs-border-color, #dee2e6); border-top-right-radius: 0; border-bottom-right-radius: 0; height: 42px; } .hsm-url-group .btn { flex: 0 0 auto; margin: 0; margin-left: -1px; border-top-left-radius: 0; border-bottom-left-radius: 0; height: 42px; display: flex; align-items: center; justify-content: center; padding: 0 1.25rem; z-index: 2; } [data-bs-theme="dark"] .hsm-url-group .form-control { background: #0f172a; border-color: #334155; color: #e2e8f0; } .hsm-share-grid { display: flex; flex-direction: column; gap: 0.5rem; } .hsm-share-grid .btn { display: flex; align-items: center; justify-content: center; font-size: 0.9rem; padding: 0.6rem; border-color: var(--bs-border-color); width: 100%; } [data-bs-theme="dark"] .hsm-share-grid .btn { color: #e2e8f0; border-color: #475569; } [data-bs-theme="dark"] .hsm-share-grid .btn:hover { background: #334155; border-color: #cbd5e1; } </style> <script> (function(){ const modal = document.getElementById('headingShareModal'); if(!modal) return; const input = modal.querySelector('#headingShareInput'); const copyBtn = modal.querySelector('.hsm-copy'); const twitter = modal.querySelector('#share-twitter'); const linkedin = modal.querySelector('#share-linkedin'); const facebook = modal.querySelector('#share-facebook'); const closeBtn = modal.querySelector('.hsm-close'); let lastFocus=null; let trapBound=false; function buildUrl(id){ return window.location.origin + window.location.pathname + '#' + id; } function isOpen(){ return !modal.hasAttribute('hidden'); } function hydrate(id){ const url=buildUrl(id); input.value=url; const enc=encodeURIComponent(url); const text=encodeURIComponent(document.title); if(twitter) twitter.href=`https://twitter.com/intent/tweet?url=${enc}&text=${text}`; if(linkedin) linkedin.href=`https://www.linkedin.com/sharing/share-offsite/?url=${enc}`; if(facebook) facebook.href=`https://www.facebook.com/sharer/sharer.php?u=${enc}`; } function openModal(id){ lastFocus=document.activeElement; hydrate(id); if(!isOpen()){ modal.removeAttribute('hidden'); } requestAnimationFrame(()=>{ input.focus(); }); trapFocus(); } function closeModal(){ if(!isOpen()) return; modal.setAttribute('hidden',''); if(lastFocus && typeof lastFocus.focus==='function') lastFocus.focus(); } function copyCurrent(){ try{ navigator.clipboard.writeText(input.value).then(()=>feedback(true),()=>fallback()); } catch(e){ fallback(); } } function fallback(){ input.select(); try{ document.execCommand('copy'); feedback(true);}catch(e){ feedback(false);} } function feedback(ok){ if(!copyBtn) return; const icon=copyBtn.querySelector('i'); if(!icon) return; const prev=copyBtn.getAttribute('data-prev')||icon.className; if(!copyBtn.getAttribute('data-prev')) copyBtn.setAttribute('data-prev',prev); icon.className= ok ? 'fa-duotone fa-clipboard-check':'fa-duotone fa-circle-exclamation'; setTimeout(()=>{ icon.className=prev; },1800); } function handleShareClick(e){ e.preventDefault(); const btn=e.currentTarget; const id=btn.getAttribute('data-share-target'); if(id) openModal(id); } function bindShareButtons(){ document.querySelectorAll('.h-share').forEach(btn=>{ if(!btn.dataset.hShareBound){ btn.addEventListener('click', handleShareClick); btn.dataset.hShareBound='1'; } }); } bindShareButtons(); if(document.readyState==='loading'){ document.addEventListener('DOMContentLoaded', bindShareButtons); } else { requestAnimationFrame(bindShareButtons); } document.addEventListener('click', function(e){ const shareBtn=e.target.closest && e.target.closest('.h-share'); if(shareBtn && !shareBtn.dataset.hShareBound){ handleShareClick.call(shareBtn, e); } }, true); document.addEventListener('click', e=>{ if(e.target===modal) closeModal(); if(e.target.closest && e.target.closest('.hsm-close')){ e.preventDefault(); closeModal(); } if(copyBtn && (e.target===copyBtn || (e.target.closest && e.target.closest('.hsm-copy')))) { e.preventDefault(); copyCurrent(); } }); document.addEventListener('keydown', e=>{ if(e.key==='Escape' && isOpen()) closeModal(); }); function trapFocus(){ if(trapBound) return; trapBound=true; modal.addEventListener('keydown', f=>{ if(f.key==='Tab' && isOpen()){ const focusable=[...modal.querySelectorAll('a[href],button,input,textarea,select,[tabindex]:not([tabindex="-1"])')].filter(el=>!el.hasAttribute('disabled')); if(!focusable.length) return; const first=focusable[0]; const last=focusable[focusable.length-1]; if(f.shiftKey && document.activeElement===first){ f.preventDefault(); last.focus(); } else if(!f.shiftKey && document.activeElement===last){ f.preventDefault(); first.focus(); } } }); } if(closeBtn) closeBtn.addEventListener('click', e=>{ e.preventDefault(); closeModal(); }); })(); </script> <h4 id="layered-architecture" class="position-relative d-flex align-items-center group"> Layered Architecture <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="layered-architecture" aria-haspopup="dialog" aria-label="Share link: Layered Architecture"> Share link </button> </h4>Structure applications with clear separation of concerns. Architecture Layers: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">Presentation Layer (API, UI) ↓ Business Logic Layer (Services, Domain Logic) ↓ Data Access Layer (Repository Pattern) ↓ Geode Graph Database </code></pre></div>Example (Go): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Data Access Layer type UserRepository struct { db *sql.DB } func (r *UserRepository) FindByEmail(email string) (*User, error) { rows, err := r.db.Query(` MATCH (u:User {email: ?}) RETURN u.id, u.name, u.email, u.created_at `, email) if err != nil { return nil, err } defer rows.Close() var user User if rows.Next() { err = rows.Scan(&user.ID, &user.Name, &user.Email, &user.CreatedAt) return &user, err } return nil, ErrNotFound } // Business Logic Layer type UserService struct { repo *UserRepository } func (s *UserService) GetUserNetwork(email string) (*UserNetwork, error) { user, err := s.repo.FindByEmail(email) if err != nil { return nil, err } friends, err := s.repo.FindFriends(user.ID) if err != nil { return nil, err } return &UserNetwork{User: user, Friends: friends}, nil } // Presentation Layer (HTTP API) func (h *UserHandler) GetUserNetwork(w http.ResponseWriter, r *http.Request) { email := r.URL.Query().Get("email") network, err := h.userService.GetUserNetwork(email) if err != nil { http.Error(w, err.Error(), http.StatusNotFound) return } json.NewEncoder(w).Encode(network) } </code></pre></div> <h4 id="microservices-architecture" class="position-relative d-flex align-items-center group"> Microservices Architecture <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="microservices-architecture" aria-haspopup="dialog" aria-label="Share link: Microservices Architecture"> Share link </button> </h4>Use Geode as a specialized datastore within microservices. Service Boundaries: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">User Service → Geode (User profiles, relationships) Product Service → Geode (Product catalog, categories) Order Service → PostgreSQL (Transactional data) Recommendation Service → Geode (Collaborative filtering) </code></pre></div>Inter-Service Communication: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># Recommendation Service class RecommendationService: def __init__(self, geode_client, user_service_client): self.geode = geode_client self.user_service = user_service_client async def get_recommendations(self, user_id): # Fetch user preferences from User Service preferences = await self.user_service.get_preferences(user_id) # Query Geode for recommendations result, _ = await self.geode.query(""" MATCH (u:User {id: $user_id})-[:PURCHASED]->(p:Product) <-[:PURCHASED]-(similar:User) -[:PURCHASED]->(rec:Product) WHERE NOT (u)-[:PURCHASED]->(rec) AND rec.category IN $preferred_categories RETURN rec.id, rec.name, count(similar) as score ORDER BY score DESC LIMIT 10 """, { "user_id": user_id, "preferred_categories": preferences["categories"] }) return result.rows </code></pre></div> <h4 id="cqrs-pattern" class="position-relative d-flex align-items-center group"> CQRS Pattern <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="cqrs-pattern" aria-haspopup="dialog" aria-label="Share link: CQRS Pattern"> Share link </button> </h4>Separate read and write models for optimal performance. Command (Write) Model: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Client, Value}; use std::collections::HashMap; pub struct WriteModel { client: Client, } impl WriteModel { pub async fn create_user(&self, user: NewUser) -> Result<UserId> { let mut conn = self.client.connect().await?; let mut params = HashMap::new(); params.insert("id".to_string(), Value::int(user.id as i64)); params.insert("name".to_string(), Value::string(user.name)); params.insert("email".to_string(), Value::string(user.email)); let (page, _) = conn .query_with_params( r#" CREATE (u:User { id: $id, name: $name, email: $email, created_at: current_timestamp() }) RETURN u.id "#, &params, ) .await?; let id = page.rows[0].get("u.id").unwrap().as_int()? as UserId; Ok(id) } pub async fn add_friendship(&self, user_id: UserId, friend_id: UserId) -> Result<()> { let mut conn = self.client.connect().await?; conn.begin().await?; let mut params = HashMap::new(); params.insert("user_id".to_string(), Value::int(user_id as i64)); params.insert("friend_id".to_string(), Value::int(friend_id as i64)); let _ = conn .query_with_params( r#" MATCH (u:User {id: $user_id}), (f:User {id: $friend_id}) CREATE (u)-[:FRIENDS_WITH {since: current_timestamp()}]->(f) CREATE (f)-[:FRIENDS_WITH {since: current_timestamp()}]->(u) "#, &params, ) .await?; conn.commit().await?; Ok(()) } } </code></pre></div>Query (Read) Model: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Client, Value}; use std::collections::HashMap; pub struct ReadModel { client: Client, } impl ReadModel { pub async fn get_user_network(&self, user_id: UserId) -> Result<UserNetwork> { let mut conn = self.client.connect().await?; let mut params = HashMap::new(); params.insert("user_id".to_string(), Value::int(user_id as i64)); let (page, _) = conn .query_with_params( r#" MATCH (u:User {id: $user_id}) OPTIONAL MATCH (u)-[:FRIENDS_WITH]->(f:User) RETURN u, collect(f) as friends "#, &params, ) .await?; Ok(UserNetwork::from_rows(&page.rows)) } pub async fn get_friend_suggestions(&self, user_id: UserId, limit: usize) -> Result<Vec<User>> { let mut conn = self.client.connect().await?; let mut params = HashMap::new(); params.insert("user_id".to_string(), Value::int(user_id as i64)); params.insert("limit".to_string(), Value::int(limit as i64)); let (page, _) = conn .query_with_params( r#" MATCH (u:User {id: $user_id})-[:FRIENDS_WITH]->(f:User) -[:FRIENDS_WITH]->(fof:User) WHERE NOT (u)-[:FRIENDS_WITH]->(fof) AND u <> fof RETURN fof, count(f) as mutual_friends ORDER BY mutual_friends DESC LIMIT $limit "#, &params, ) .await?; Ok(page.rows.iter().map(User::from_row).collect()) } } </code></pre></div> <h3 id="api-design" class="position-relative d-flex align-items-center group"> API Design <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="api-design" aria-haspopup="dialog" aria-label="Share link: API Design"> Share link </button> </h3> <h4 id="restful-apis" class="position-relative d-flex align-items-center group"> RESTful APIs <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="restful-apis" aria-haspopup="dialog" aria-label="Share link: RESTful APIs"> Share link </button> </h4>Design REST APIs leveraging graph relationships. Resource Endpoints: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">GET /users/:id # Get user POST /users # Create user GET /users/:id/friends # Get user's friends POST /users/:id/friends/:friend_id # Add friendship DELETE /users/:id/friends/:friend_id # Remove friendship GET /users/:id/recommendations # Get recommendations </code></pre></div>Implementation (Python/FastAPI): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from fastapi import FastAPI, HTTPException from geode_client import Client app = FastAPI() geode = Client(host="localhost", port=3141) @app.get("/users/{user_id}") async def get_user(user_id: str): async with geode.connection() as conn: result, _ = await conn.query( "MATCH (u:User {id: $id}) RETURN u", {"id": user_id}, ) if not result.rows: raise HTTPException(status_code=404, detail="User not found") return result.rows[0]["u"].raw_value @app.get("/users/{user_id}/friends") async def get_friends(user_id: str): async with geode.connection() as conn: result, _ = await conn.query( """ MATCH (u:User {id: $id})-[:FRIENDS_WITH]->(f:User) RETURN f.id AS id, f.name AS name, f.email AS email """, {"id": user_id}, ) return [ { "id": row["id"].raw_value, "name": row["name"].raw_value, "email": row["email"].raw_value, } for row in result.rows ] @app.post("/users/{user_id}/friends/{friend_id}") async def add_friend(user_id: str, friend_id: str): async with geode.connection() as conn: await conn.begin() try: # Verify both users exist result, _ = await conn.query( """ MATCH (u:User {id: $user_id}) MATCH (f:User {id: $friend_id}) RETURN u, f """, {"user_id": user_id, "friend_id": friend_id}, ) if not result.rows: raise HTTPException(status_code=404, detail="User not found") # Create bidirectional friendship await conn.execute( """ MATCH (u:User {id: $user_id}), (f:User {id: $friend_id}) CREATE (u)-[:FRIENDS_WITH {since: current_timestamp()}]->(f) CREATE (f)-[:FRIENDS_WITH {since: current_timestamp()}]->(u) """, {"user_id": user_id, "friend_id": friend_id}, ) await conn.commit() except Exception: await conn.rollback() raise return {"status": "success"} </code></pre></div> <h4 id="graphql-apis" class="position-relative d-flex align-items-center group"> GraphQL APIs <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="graphql-apis" aria-haspopup="dialog" aria-label="Share link: GraphQL APIs"> Share link </button> </h4>GraphQL naturally maps to graph databases. Schema Definition: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-graphql" data-lang="graphql">type User { id: ID! name: String! email: String! friends: [User!]! friendCount: Int! recommendations: [Product!]! } type Product { id: ID! name: String! price: Float! category: String! } type Query { user(id: ID!): User users(limit: Int = 10): [User!]! product(id: ID!): Product products(category: String): [Product!]! } type Mutation { createUser(name: String!, email: String!): User! addFriend(userId: ID!, friendId: ID!): Boolean! purchaseProduct(userId: ID!, productId: ID!): Boolean! } </code></pre></div>Resolver Implementation: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">from ariadne import QueryType, MutationType, ObjectType query = QueryType() mutation = MutationType() user_type = ObjectType("User") @query.field("user") async def resolve_user(_, info, id): async with geode.connection() as conn: result, _ = await conn.query( "MATCH (u:User {id: $id}) RETURN u", {"id": id}, ) return result.rows[0]["u"].raw_value if result.rows else None @user_type.field("friends") async def resolve_friends(user, info): async with geode.connection() as conn: result, _ = await conn.query( """ MATCH (u:User {id: $id})-[:FRIENDS_WITH]->(f:User) RETURN f """, {"id": user["id"]}, ) return [row["f"].raw_value for row in result.rows] @user_type.field("friendCount") async def resolve_friend_count(user, info): async with geode.connection() as conn: result, _ = await conn.query( """ MATCH (u:User {id: $id})-[:FRIENDS_WITH]->(:User) RETURN count(*) as count """, {"id": user["id"]}, ) return result.rows[0]["count"].raw_value if result.rows else 0 @user_type.field("recommendations") async def resolve_recommendations(user, info): async with geode.connection() as conn: result, _ = await conn.query( """ MATCH (u:User {id: $id})-[:PURCHASED]->(p:Product) <-[:PURCHASED]-(similar:User) -[:PURCHASED]->(rec:Product) WHERE NOT (u)-[:PURCHASED]->(rec) RETURN DISTINCT rec, count(similar) as score ORDER BY score DESC LIMIT 10 """, {"id": user["id"]}, ) return [row["rec"].raw_value for row in result.rows] @mutation.field("addFriend") async def resolve_add_friend(_, info, userId, friendId): async with geode.connection() as conn: await conn.begin() try: await conn.execute( """ MATCH (u:User {id: $user_id}), (f:User {id: $friend_id}) CREATE (u)-[:FRIENDS_WITH]->(f) CREATE (f)-[:FRIENDS_WITH]->(u) """, {"user_id": userId, "friend_id": friendId}, ) await conn.commit() except Exception: await conn.rollback() raise return True </code></pre></div> <h3 id="data-modeling" class="position-relative d-flex align-items-center group"> Data Modeling <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="data-modeling" aria-haspopup="dialog" aria-label="Share link: Data Modeling"> Share link </button> </h3> <h4 id="domain-driven-design" class="position-relative d-flex align-items-center group"> Domain-Driven Design <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="domain-driven-design" aria-haspopup="dialog" aria-label="Share link: Domain-Driven Design"> Share link </button> </h4>Model graph schema aligned with business domains. Aggregate Boundaries: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-gql" data-lang="gql">-- User Aggregate (:User {id, name, email, created_at}) -[:HAS_PROFILE]-> (:Profile {bio, avatar_url}) -[:HAS_PREFERENCES]-> (:Preferences {theme, language}) -- Social Aggregate (:User)-[:FRIENDS_WITH {since}]->(:User) (:User)-[:FOLLOWS {since}]->(:User) (:User)-[:BLOCKED {reason}]->(:User) -- Content Aggregate (:User)-[:POSTED {timestamp}]->(:Post {content, likes}) (:User)-[:LIKED {timestamp}]->(:Post) (:User)-[:COMMENTED {text, timestamp}]->(:Post) </code></pre></div> <h4 id="schema-validation" class="position-relative d-flex align-items-center group"> Schema Validation <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="schema-validation" aria-haspopup="dialog" aria-label="Share link: Schema Validation"> Share link </button> </h4>Implement schema validation in application layer. Example (Rust with serde): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use geode_client::{Client, Value}; use serde::{Deserialize, Serialize}; use std::collections::HashMap; use validator::Validate; #[derive(Debug, Serialize, Deserialize, Validate)] pub struct NewUser { #[validate(length(min = 1, max = 100))] pub name: String, #[validate(email)] pub email: String, #[validate(length(min = 8))] pub password: String, } pub async fn create_user(client: &Client, user: NewUser) -> Result<UserId> { // Validate input user.validate()?; // Hash password let password_hash = hash_password(&user.password)?; // Create in Geode let mut conn = client.connect().await?; let mut params = HashMap::new(); params.insert("id".to_string(), Value::string(Uuid::new_v4().to_string())); params.insert("name".to_string(), Value::string(user.name)); params.insert("email".to_string(), Value::string(user.email)); params.insert("password_hash".to_string(), Value::string(password_hash)); let (page, _) = conn .query_with_params( r#" CREATE (u:User { id: $id, name: $name, email: $email, password_hash: $password_hash, created_at: current_timestamp() }) RETURN u.id "#, &params, ) .await?; Ok(page.rows[0].get("u.id").unwrap().as_string()?) } </code></pre></div> <h3 id="testing-strategies" class="position-relative d-flex align-items-center group"> Testing Strategies <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="testing-strategies" aria-haspopup="dialog" aria-label="Share link: Testing Strategies"> Share link </button> </h3> <h4 id="unit-testing-with-mocks" class="position-relative d-flex align-items-center group"> Unit Testing with Mocks <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="unit-testing-with-mocks" aria-haspopup="dialog" aria-label="Share link: Unit Testing with Mocks"> Share link </button> </h4>Mock Geode client for unit tests. Example (Go): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">type MockGeodeClient struct { QueryFunc func(query string, params ...interface{}) (*sql.Rows, error) } func (m *MockGeodeClient) Query(query string, params ...interface{}) (*sql.Rows, error) { return m.QueryFunc(query, params...) } func TestUserService_GetUserNetwork(t *testing.T) { mockClient := &MockGeodeClient{ QueryFunc: func(query string, params ...interface{}) (*sql.Rows, error) { // Return mock data return mockRows([]User{ {ID: "user1", Name: "Alice"}, {ID: "user2", Name: "Bob"}, }), nil }, } service := NewUserService(mockClient) network, err := service.GetUserNetwork("user1") assert.NoError(t, err) assert.Len(t, network.Friends, 2) } </code></pre></div> <h4 id="integration-testing" class="position-relative d-flex align-items-center group"> Integration Testing <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="integration-testing" aria-haspopup="dialog" aria-label="Share link: Integration Testing"> Share link </button> </h4>Test against real Geode instance. Example (Python with pytest): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">import pytest from geode_client import Client @pytest.fixture async def geode_client(): client = Client(host="localhost", port=3141) yield client # Cleanup async with client.connection() as conn: await conn.execute("MATCH (n) DETACH DELETE n") @pytest.mark.asyncio async def test_create_and_find_user(geode_client): # Create user async with geode_client.connection() as conn: await conn.execute(""" CREATE (:User {id: 'test1', name: 'Test User', email: '[email protected]'}) """) # Find user async with geode_client.connection() as conn: results, _ = await conn.query(""" MATCH (u:User {email: '[email protected]'}) RETURN u.id, u.name """) assert len(results.rows) == 1 assert results.rows[0]["u.name"].raw_value == "Test User" @pytest.mark.asyncio async def test_friend_recommendations(geode_client): # Setup test data async with geode_client.connection() as conn: await conn.execute(""" CREATE (alice:User {id: 'alice', name: 'Alice'}) CREATE (bob:User {id: 'bob', name: 'Bob'}) CREATE (carol:User {id: 'carol', name: 'Carol'}) CREATE (alice)-[:FRIENDS_WITH]->(bob) CREATE (bob)-[:FRIENDS_WITH]->(alice) CREATE (bob)-[:FRIENDS_WITH]->(carol) CREATE (carol)-[:FRIENDS_WITH]->(bob) """) # Test recommendations async with geode_client.connection() as conn: results, _ = await conn.query(""" MATCH (u:User {id: 'alice'})-[:FRIENDS_WITH]->(f) -[:FRIENDS_WITH]->(fof:User) WHERE NOT (u)-[:FRIENDS_WITH]->(fof) AND u <> fof RETURN fof.name """) assert len(results.rows) == 1 assert results.rows[0]["fof.name"].raw_value == "Carol" </code></pre></div> <h3 id="performance-optimization" class="position-relative d-flex align-items-center group"> Performance Optimization <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="performance-optimization" aria-haspopup="dialog" aria-label="Share link: Performance Optimization"> Share link </button> </h3> <h4 id="caching-strategies" class="position-relative d-flex align-items-center group"> Caching Strategies <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="caching-strategies" aria-haspopup="dialog" aria-label="Share link: Caching Strategies"> Share link </button> </h4>Implement caching for frequently accessed data. Example (Python with Redis): <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">import redis import json from functools import wraps redis_client = redis.Redis(host='localhost', port=6379, decode_responses=True) def cache_result(ttl=300): def decorator(func): @wraps(func) async def wrapper(*args, **kwargs): # Generate cache key cache_key = f"{func.__name__}:{args}:{kwargs}" # Check cache cached = redis_client.get(cache_key) if cached: return json.loads(cached) # Execute function result = await func(*args, **kwargs) # Store in cache redis_client.setex(cache_key, ttl, json.dumps(result)) return result return wrapper return decorator @cache_result(ttl=600) async def get_user_network(user_id): async with geode.connection() as conn: result, _ = await conn.query(""" MATCH (u:User {id: $id})-[:FRIENDS_WITH]->(f) RETURN f.id AS id, f.name AS name """, {"id": user_id}) return [ {"id": row["id"].raw_value, "name": row["name"].raw_value} for row in result.rows ] </code></pre></div> <h4 id="batch-operations" class="position-relative d-flex align-items-center group"> Batch Operations <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="batch-operations" aria-haspopup="dialog" aria-label="Share link: Batch Operations"> Share link </button> </h4>Batch related operations to reduce roundtrips. Example: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def create_users_batch(users): async with geode.connection() as conn: await conn.begin() try: for user in users: await conn.execute(""" CREATE (:User {id: $id, name: $name, email: $email}) """, user) await conn.commit() except Exception: await conn.rollback() raise </code></pre></div> <h3 id="deployment" class="position-relative d-flex align-items-center group"> Deployment <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="deployment" aria-haspopup="dialog" aria-label="Share link: Deployment"> Share link </button> </h3> <h4 id="docker-deployment" class="position-relative d-flex align-items-center group"> Docker Deployment <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="docker-deployment" aria-haspopup="dialog" aria-label="Share link: Docker Deployment"> Share link </button> </h4>docker-compose.yml: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-yaml" data-lang="yaml">version: '3.8' services: geode: image: geodedb/geode:0.2.18 ports: - "3141:3141" volumes: - geode-data:/data environment: - GEODE_LOG_LEVEL=info app: build: . ports: - "8000:8000" depends_on: - geode environment: - GEODE_URL=quic://geode:3141 volumes: geode-data: </code></pre></div> <h4 id="health-checks" class="position-relative d-flex align-items-center group"> Health Checks <button type="button" class="h-share btn btn-link p-0 text-decoration-none link-secondary opacity-50 hover-opacity-100 transition-all ms-1" data-share-target="health-checks" aria-haspopup="dialog" aria-label="Share link: Health Checks"> Share link </button> </h4>Implement health checks for monitoring. Example: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">@app.get("/health") async def health_check(): try: # Ping Geode async with geode.connection() as conn: await conn.query("RETURN 1 AS ok") return {"status": "healthy", "database": "connected"} except Exception as e: return {"status": "unhealthy", "error": str(e)}, 503 </code></pre></div>Building applications with Geode combines the flexibility of graph modeling with the simplicity of standards-based GQL queries. Following these patterns and best practices ensures scalable, maintainable, and performant graph-powered applications.

Popular

Related Articles

Use Case Guides

Use Cases