Client Library Development

<h2 id="client-library-development" class="position-relative d-flex align-items-center group"> Client Library Development <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="client-library-development" aria-haspopup="dialog" aria-label="Share link: Client Library Development"> Share link </button> </h2><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>Geode provides official client libraries for multiple languages, all built on the QUIC+TLS protocol for secure, high-performance connectivity. This page covers client library architecture, development patterns, and integration guidelines. <h3 id="official-client-libraries" class="position-relative d-flex align-items-center group"> Official Client Libraries <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="official-client-libraries" aria-haspopup="dialog" aria-label="Share link: Official Client Libraries"> Share link </button> </h3><table> <thead> <tr> <th>Language</th> <th>Package</th> <th>Protocol</th> <th>Async Model</th> </tr> </thead> <tbody> <tr> <td>Go</td> <td><code>geodedb.com/geode</code></td> <td>QUIC/gRPC</td> <td>Goroutines</td> </tr> <tr> <td>Python</td> <td><code>geode-client</code></td> <td>QUIC/gRPC</td> <td>asyncio</td> </tr> <tr> <td>Rust</td> <td><code>geode-client</code></td> <td>QUIC/gRPC</td> <td>tokio</td> </tr> <tr> <td>Zig</td> <td><code>geode-client-zig</code></td> <td>QUIC/gRPC</td> <td>Native</td> </tr> <tr> <td>Node.js</td> <td><code>@geodedb/client</code></td> <td>QUIC/gRPC</td> <td>Promises</td> </tr> </tbody> </table> <h3 id="wire-protocol" class="position-relative d-flex align-items-center group"> Wire Protocol <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="wire-protocol" aria-haspopup="dialog" aria-label="Share link: Wire Protocol"> Share link </button> </h3>All Geode clients communicate using a Protobuf wire protocol over QUIC+TLS (default) or gRPC: <h4 id="message-types" class="position-relative d-flex align-items-center group"> Message Types <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="message-types" aria-haspopup="dialog" aria-label="Share link: Message Types"> Share link </button> </h4>Client → Server: <ul> <li><code>HelloRequest</code></li> <li><code>ExecuteRequest</code></li> <li><code>PullRequest</code></li> <li><code>BeginRequest</code> / <code>CommitRequest</code> / <code>RollbackRequest</code></li> <li><code>PingRequest</code></li> </ul> Server → Client: <ul> <li><code>ExecutionResponse</code> (payloads: <code>SchemaDefinition</code>, <code>DataPage</code>, <code>Error</code>, <code>ExplainPayload</code>, <code>ProfilePayload</code>)</li> </ul> <h4 id="connection-lifecycle" class="position-relative d-flex align-items-center group"> Connection Lifecycle <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="connection-lifecycle" aria-haspopup="dialog" aria-label="Share link: Connection Lifecycle"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">Client Server | | |------ HelloRequest ---------->| |<----- HelloResponse ----------| | | |------ ExecuteRequest -------->| |<----- ExecutionResponse ------| |------ PullRequest ----------->| |<----- ExecutionResponse ------| | | |------ PingRequest ----------->| |<----- PingResponse -----------| </code></pre></div> <h3 id="client-architecture" class="position-relative d-flex align-items-center group"> Client 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="client-architecture" aria-haspopup="dialog" aria-label="Share link: Client Architecture"> Share link </button> </h3> <h4 id="core-components" class="position-relative d-flex align-items-center group"> Core Components <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="core-components" aria-haspopup="dialog" aria-label="Share link: Core Components"> Share link </button> </h4>Every Geode client library implements these components: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">┌─────────────────────────────────────────────┐ │ Application Code │ ├─────────────────────────────────────────────┤ │ Query Builder │ │ (Fluent API for GQL) │ ├─────────────────────────────────────────────┤ │ Connection Pool │ │ (Connection lifecycle management) │ ├─────────────────────────────────────────────┤ │ Connection │ │ (Single QUIC stream wrapper) │ ├─────────────────────────────────────────────┤ │ Wire Protocol │ │ (JSON serialization/parsing) │ ├─────────────────────────────────────────────┤ │ QUIC + TLS │ │ (Transport encryption) │ └─────────────────────────────────────────────┘ </code></pre></div> <h4 id="connection-pool-design" class="position-relative d-flex align-items-center group"> Connection Pool 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="connection-pool-design" aria-haspopup="dialog" aria-label="Share link: Connection Pool Design"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">class ConnectionPool: """Connection pool architecture pattern""" def __init__(self, config): self.min_connections = config.min_connections # Warm pool self.max_connections = config.max_connections # Hard limit self.max_idle_time = config.max_idle_time # Reap idle self.health_check_interval = config.health_check self._available = Queue() # Ready connections self._in_use = Set() # Active connections self._lock = Lock() async def acquire(self, timeout=None): """Get connection from pool""" # Try available pool first # Create new if under max # Wait with timeout if at max pass async def release(self, conn): """Return connection to pool""" # Validate connection health # Return to available or close pass </code></pre></div> <h4 id="query-builder-pattern" class="position-relative d-flex align-items-center group"> Query Builder 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="query-builder-pattern" aria-haspopup="dialog" aria-label="Share link: Query Builder Pattern"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">class QueryBuilder: """Fluent query builder pattern""" def __init__(self): self._clauses = [] self._params = {} def match(self, pattern: str) -> 'QueryBuilder': self._clauses.append(f"MATCH {pattern}") return self def where(self, condition: str) -> 'QueryBuilder': self._clauses.append(f"WHERE {condition}") return self def with_param(self, name: str, value: Any) -> 'QueryBuilder': self._params[name] = value return self def return_(self, *expressions: str) -> 'QueryBuilder': self._clauses.append(f"RETURN {', '.join(expressions)}") return self def build(self) -> Tuple[str, Dict]: return '\n'.join(self._clauses), self._params # Usage query, params = (QueryBuilder() .match("(u:User {id: $id})") .with_param("id", user_id) .return_("u.name", "u.email") .build()) </code></pre></div> <h3 id="implementing-a-client" class="position-relative d-flex align-items-center group"> Implementing a Client <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="implementing-a-client" aria-haspopup="dialog" aria-label="Share link: Implementing a Client"> Share link </button> </h3> <h4 id="step-1-quic-connection" class="position-relative d-flex align-items-center group"> Step 1: QUIC Connection <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="step-1-quic-connection" aria-haspopup="dialog" aria-label="Share link: Step 1: QUIC Connection"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">// Rust example using Quinn use quinn::{ClientConfig, Endpoint}; pub struct GeodeConnection { endpoint: Endpoint, connection: quinn::Connection, } impl GeodeConnection { pub async fn connect(addr: &str, tls_config: ClientConfig) -> Result<Self> { let endpoint = Endpoint::client("0.0.0.0:0".parse()?)?; let connection = endpoint.connect_with(tls_config, addr, "geode")?.await?; Ok(Self { endpoint, connection }) } } </code></pre></div> <h4 id="step-2-wire-protocol" class="position-relative d-flex align-items-center group"> Step 2: Wire Protocol <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="step-2-wire-protocol" aria-haspopup="dialog" aria-label="Share link: Step 2: Wire Protocol"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use serde::{Deserialize, Serialize}; #[derive(Serialize)] #[serde(tag = "type")] enum ClientMessage { HELLO { version: u32, client: String }, RUN_GQL { query: String, params: HashMap<String, Value> }, PULL { n: i64 }, BEGIN { isolation: Option<String> }, COMMIT, ROLLBACK, PING, } #[derive(Deserialize)] #[serde(tag = "type")] enum ServerMessage { SUCCESS { stats: Option<QueryStats> }, SCHEMA { columns: Vec<String>, types: Vec<String> }, BINDINGS { data: Vec<HashMap<String, Value>> }, ERROR { code: String, message: String }, PONG, } </code></pre></div> <h4 id="step-3-connection-pool" class="position-relative d-flex align-items-center group"> Step 3: Connection Pool <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="step-3-connection-pool" aria-haspopup="dialog" aria-label="Share link: Step 3: Connection Pool"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">use tokio::sync::{Semaphore, Mutex}; pub struct ConnectionPool { config: PoolConfig, available: Mutex<Vec<GeodeConnection>>, semaphore: Semaphore, } impl ConnectionPool { pub async fn acquire(&self) -> Result<PooledConnection> { let permit = self.semaphore.acquire().await?; let conn = { let mut available = self.available.lock().await; available.pop() }; let conn = match conn { Some(c) => c, None => GeodeConnection::connect(&self.config.dsn).await?, }; Ok(PooledConnection { conn, permit, pool: self }) } } </code></pre></div> <h4 id="step-4-transaction-support" class="position-relative d-flex align-items-center group"> Step 4: Transaction Support <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="step-4-transaction-support" aria-haspopup="dialog" aria-label="Share link: Step 4: Transaction Support"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-rust" data-lang="rust">pub struct Transaction<'a> { conn: &'a mut GeodeConnection, active: bool, } impl<'a> Transaction<'a> { pub async fn begin(conn: &'a mut GeodeConnection) -> Result<Self> { conn.send(ClientMessage::BEGIN { isolation: None }).await?; conn.expect_success().await?; Ok(Self { conn, active: true }) } pub async fn commit(mut self) -> Result<()> { self.conn.send(ClientMessage::COMMIT).await?; self.conn.expect_success().await?; self.active = false; Ok(()) } pub async fn rollback(mut self) -> Result<()> { self.conn.send(ClientMessage::ROLLBACK).await?; self.conn.expect_success().await?; self.active = false; Ok(()) } } impl Drop for Transaction<'_> { fn drop(&mut self) { if self.active { // Automatic rollback on drop // (spawn rollback task) } } } </code></pre></div> <h3 id="error-handling" class="position-relative d-flex align-items-center group"> Error Handling <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="error-handling" aria-haspopup="dialog" aria-label="Share link: Error Handling"> Share link </button> </h3> <h4 id="gql-error-codes" class="position-relative d-flex align-items-center group"> GQL Error Codes <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="gql-error-codes" aria-haspopup="dialog" aria-label="Share link: GQL Error Codes"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">class GqlError(Exception): """Base GQL error with ISO status code""" def __init__(self, code: str, message: str): self.code = code self.message = message self.category = code[:2] # First two digits @property def is_retryable(self) -> bool: """Transient errors that may succeed on retry""" return self.category in ('08', '40', '57') # Error categories # 02xxx - No data # 08xxx - Connection exception (retryable) # 22xxx - Data exception # 23xxx - Constraint violation # 40xxx - Transaction rollback (retryable) # 42xxx - Syntax error # 57xxx - Resource limit (retryable) </code></pre></div> <h4 id="retry-logic" class="position-relative d-flex align-items-center group"> Retry Logic <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="retry-logic" aria-haspopup="dialog" aria-label="Share link: Retry Logic"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def execute_with_retry( pool: ConnectionPool, query: str, params: dict, max_retries: int = 3 ) -> Result: """Execute query with automatic retry for transient errors""" last_error = None for attempt in range(max_retries): try: async with pool.acquire() as conn: return await conn.execute(query, params) except GqlError as e: last_error = e if not e.is_retryable: raise # Exponential backoff await asyncio.sleep(0.1 * (2 ** attempt)) except ConnectionError as e: last_error = e await asyncio.sleep(0.1 * (2 ** attempt)) raise last_error </code></pre></div> <h3 id="testing-clients" class="position-relative d-flex align-items-center group"> Testing Clients <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-clients" aria-haspopup="dialog" aria-label="Share link: Testing Clients"> Share link </button> </h3> <h4 id="unit-tests" class="position-relative d-flex align-items-center group"> Unit Tests <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-tests" aria-haspopup="dialog" aria-label="Share link: Unit Tests"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">import pytest from unittest.mock import AsyncMock @pytest.fixture def mock_connection(): conn = AsyncMock() conn.execute.return_value = Result( columns=['name'], rows=[{'name': 'Alice'}] ) return conn async def test_query_builder(mock_connection): builder = QueryBuilder(mock_connection) result = await (builder .match("(u:User)") .where("u.active = true") .return_("u.name") .execute()) assert result.rows[0]['name'] == 'Alice' mock_connection.execute.assert_called_once() </code></pre></div> <h4 id="integration-tests" class="position-relative d-flex align-items-center group"> Integration Tests <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-tests" aria-haspopup="dialog" aria-label="Share link: Integration Tests"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">import pytest from testcontainers.geode import GeodeContainer @pytest.fixture(scope="module") async def geode(): """Start Geode container for integration tests""" with GeodeContainer() as container: yield container.get_connection_url() async def test_real_query(geode): pool = ConnectionPool(geode) async with pool.acquire() as conn: # Create test data await conn.execute( "CREATE (u:User {name: $name})", {"name": "Test User"} ) # Query it back result = await conn.execute( "MATCH (u:User {name: $name}) RETURN u.name", {"name": "Test User"} ) assert result.rows[0]['u.name'] == 'Test User' </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="connection-reuse" class="position-relative d-flex align-items-center group"> Connection Reuse <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="connection-reuse" aria-haspopup="dialog" aria-label="Share link: Connection Reuse"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># Configure pool for workload pool = ConnectionPool( dsn="quic://localhost:3141", min_connections=5, # Keep warm max_connections=50, # Scale limit max_idle_time=300, # 5 minutes connection_timeout=5, # Fast fail ) # Reuse connections async def handler(request): async with pool.acquire() as conn: # Connection returned to pool after use return await conn.execute(query, params) </code></pre></div> <h4 id="prepared-statements" class="position-relative d-flex align-items-center group"> Prepared Statements <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="prepared-statements" aria-haspopup="dialog" aria-label="Share link: Prepared Statements"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Go example - prepare once, execute many stmt, err := db.Prepare("MATCH (u:User {id: $1}) RETURN u") if err != nil { log.Fatal(err) } defer stmt.Close() // Execute prepared statement for _, id := range userIDs { rows, err := stmt.Query(id) // Process 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><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># Batch inserts for better throughput async def batch_insert(conn, users): await conn.execute(""" UNWIND $users AS user CREATE (u:User { id: user.id, name: user.name, email: user.email }) """, {"users": users}) # Insert 1000 users in single round-trip await batch_insert(conn, user_list) </code></pre></div> <h3 id="related-topics" class="position-relative d-flex align-items-center group"> Related Topics <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="related-topics" aria-haspopup="dialog" aria-label="Share link: Related Topics"> Share link </button> </h3><ul> <li><a href="/tags/client-libraries/" >Client Libraries Overview</a> </li> <li><a href="/tags/go-client/" >Go Client</a> </li> <li><a href="/tags/python-client/" >Python Client</a> </li> <li><a href="/tags/rust-client/" >Rust Client</a> </li> <li><a href="/tags/zig-client/" >Zig Client</a> </li> <li><a href="/tags/sql-driver/" >SQL Driver</a> </li> <li><a href="/tags/connections/" >Connection Pooling</a> </li> <li><a href="/docs/architecture/wire-protocol/" >Wire Protocol</a> </li> </ul> <h3 id="further-reading" class="position-relative d-flex align-items-center group"> Further Reading <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="further-reading" aria-haspopup="dialog" aria-label="Share link: Further Reading"> Share link </button> </h3><ul> <li><a href="/docs/client-libraries/" >Client Libraries Documentation</a> </li> <li><a href="/docs/protocol/" >Wire Protocol Specification</a> </li> <li><a href="/docs/configuration/" >Connection Configuration</a> </li> <li><a href="/guides/error-handling/" >Error Handling Guide</a> </li> <li><a href="/guides/query-performance/" >Performance Tuning</a> </li> </ul>

Popular

Related Articles