Tag: Go Client Library

The Geode Go client library (<code>geode-client-go</code>) provides a production-ready, idiomatic Go interface for connecting to Geode graph databases. Built on Go’s standard <code>database/sql</code> interface, it integrates seamlessly with existing Go applications and tooling while leveraging QUIC+TLS 1.3 for secure, high-performance communication. The Go client is designed for developers who want familiar Go patterns combined with full access to Geode’s GQL capabilities. Whether you are building microservices, data pipelines, or analytical applications, the Go client provides the reliability and performance characteristics expected in production environments. <h3 id="key-features" class="position-relative d-flex align-items-center group"> Key Features <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="key-features" aria-haspopup="dialog" aria-label="Share link: Key Features"> 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>database/sql Driver: The Go client implements Go’s standard <code>database/sql</code> driver interface, allowing you to use familiar patterns and integrate with existing database tooling, ORMs, and middleware. QUIC + TLS 1.3: All connections use QUIC transport with mandatory TLS 1.3 encryption, providing low-latency connections with strong security guarantees. Connection Pooling: Built-in connection pooling through <code>database/sql</code> handles connection lifecycle, reuse, and health checking automatically. Prepared Statements: Pre-compile frequently used queries to reduce parsing overhead and improve performance. Transaction Support: Full ACID transaction support with explicit BEGIN, COMMIT, and ROLLBACK control. Rich Error Types: Detailed error information with ISO/IEC 39075 GQL status codes for precise error handling. Context Cancellation: Full support for Go’s context package, enabling timeouts and cancellation. <h3 id="installation" class="position-relative d-flex align-items-center group"> Installation <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="installation" aria-haspopup="dialog" aria-label="Share link: Installation"> Share link </button> </h3>Install the Go client using the standard Go module system: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">go get geodedb.com/geode </code></pre></div>The client requires Go 1.24.0 or later. <h4 id="verifying-installation" class="position-relative d-flex align-items-center group"> Verifying Installation <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="verifying-installation" aria-haspopup="dialog" aria-label="Share link: Verifying Installation"> Share link </button> </h4>After installation, verify the module: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">go list -m geodedb.com/geode # Should output: geodedb.com/geode v0.x.x </code></pre></div> <h3 id="quick-start" class="position-relative d-flex align-items-center group"> Quick Start <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="quick-start" aria-haspopup="dialog" aria-label="Share link: Quick Start"> Share link </button> </h3> <h4 id="basic-connection" class="position-relative d-flex align-items-center group"> Basic 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="basic-connection" aria-haspopup="dialog" aria-label="Share link: Basic Connection"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">package main import ( "context" "database/sql" "log" "time" _ "geodedb.com/geode" ) func main() { // Connect to Geode server db, err := sql.Open("geode", "localhost:3141?ca=/path/to/ca.crt") if err != nil { log.Fatal(err) } defer db.Close() // Configure connection pool db.SetMaxOpenConns(10) db.SetMaxIdleConns(5) db.SetConnMaxLifetime(time.Hour) db.SetConnMaxIdleTime(10 * time.Minute) ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() // Verify connection if err := db.PingContext(ctx); err != nil { log.Fatal("Failed to connect:", err) } log.Println("Connected to Geode!") } </code></pre></div> <h4 id="executing-queries" class="position-relative d-flex align-items-center group"> Executing Queries <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="executing-queries" aria-haspopup="dialog" aria-label="Share link: Executing Queries"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func queryPeople(ctx context.Context, db *sql.DB) error { // Execute a query rows, err := db.QueryContext(ctx, ` MATCH (p:Person) RETURN p.name AS name, p.age AS age ORDER BY p.name LIMIT 10 `) if err != nil { return err } defer rows.Close() // Iterate through results for rows.Next() { var name string var age int if err := rows.Scan(&name, &age); err != nil { return err } log.Printf("Person: %s, Age: %d", name, age) } return rows.Err() } </code></pre></div> <h4 id="parameterized-queries" class="position-relative d-flex align-items-center group"> Parameterized Queries <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="parameterized-queries" aria-haspopup="dialog" aria-label="Share link: Parameterized Queries"> Share link </button> </h4>Use parameterized queries to prevent injection attacks and improve performance: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func findPerson(ctx context.Context, db *sql.DB, name string) error { // Use ? for positional parameters rows, err := db.QueryContext(ctx, ` MATCH (p:Person {name: ?}) RETURN p.name, p.age, p.email `, name) if err != nil { return err } defer rows.Close() for rows.Next() { var name, email string var age int if err := rows.Scan(&name, &age, &email); err != nil { return err } log.Printf("Found: %s (%d) - %s", name, age, email) } return rows.Err() } // Named parameters func findPersonNamed(ctx context.Context, db *sql.DB, name string, minAge int) error { rows, err := db.QueryContext(ctx, ` MATCH (p:Person {name: $name}) WHERE p.age >= $minAge RETURN p.name, p.age `, sql.Named("name", name), sql.Named("minAge", minAge)) if err != nil { return err } defer rows.Close() // Process results... return rows.Err() } </code></pre></div> <h3 id="dsn-data-source-name-format" class="position-relative d-flex align-items-center group"> DSN (Data Source Name) Format <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="dsn-data-source-name-format" aria-haspopup="dialog" aria-label="Share link: DSN (Data Source Name) Format"> Share link </button> </h3>The connection string supports multiple formats: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-fallback" data-lang="fallback">quic://host:port?options host:port?options host:port host </code></pre></div> <h4 id="dsn-options" class="position-relative d-flex align-items-center group"> DSN Options <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="dsn-options" aria-haspopup="dialog" aria-label="Share link: DSN Options"> Share link </button> </h4><table> <thead> <tr> <th>Option</th> <th>Description</th> <th>Default</th> </tr> </thead> <tbody> <tr> <td><code>page_size</code></td> <td>Results page size</td> <td>1000</td> </tr> <tr> <td><code>hello_name</code></td> <td>Client name for HELLO</td> <td>geode-go</td> </tr> <tr> <td><code>hello_ver</code></td> <td>Client version for HELLO</td> <td>0.1</td> </tr> <tr> <td><code>conformance</code></td> <td>GQL conformance level</td> <td>min</td> </tr> <tr> <td><code>ca</code></td> <td>Path to CA certificate</td> <td></td> </tr> <tr> <td><code>cert</code></td> <td>Path to client certificate (mTLS)</td> <td></td> </tr> <tr> <td><code>key</code></td> <td>Path to client key (mTLS)</td> <td></td> </tr> <tr> <td><code>insecure_tls_skip_verify</code></td> <td>Skip TLS verification (testing only)</td> <td>false</td> </tr> </tbody> </table> <h4 id="environment-variables" class="position-relative d-flex align-items-center group"> Environment Variables <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="environment-variables" aria-haspopup="dialog" aria-label="Share link: Environment Variables"> Share link </button> </h4><table> <thead> <tr> <th>Variable</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>GEODE_HOST</code></td> <td>Default host</td> </tr> <tr> <td><code>GEODE_PORT</code></td> <td>Default port</td> </tr> <tr> <td><code>GEODE_TLS_CA</code></td> <td>Default CA certificate path</td> </tr> </tbody> </table> <h4 id="connection-examples" class="position-relative d-flex align-items-center group"> Connection Examples <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-examples" aria-haspopup="dialog" aria-label="Share link: Connection Examples"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Simple connection (TLS with system CA) db, _ := sql.Open("geode", "geode.example.com:3141") // With custom CA certificate db, _ := sql.Open("geode", "geode.example.com:3141?ca=/etc/geode/ca.crt") // With mutual TLS (mTLS) db, _ := sql.Open("geode", "geode.example.com:3141?ca=/etc/geode/ca.crt&cert=/etc/geode/client.crt&key=/etc/geode/client.key") // Development mode (skip TLS verification) db, _ := sql.Open("geode", "localhost:3141?insecure_tls_skip_verify=true") // Using URL format db, _ := sql.Open("geode", "quic://user:pass@localhost:3141?page_size=500") </code></pre></div> <h3 id="transaction-management" class="position-relative d-flex align-items-center group"> Transaction Management <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="transaction-management" aria-haspopup="dialog" aria-label="Share link: Transaction Management"> Share link </button> </h3>The Go client supports full ACID transactions: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func transferFunds(ctx context.Context, db *sql.DB, from, to string, amount float64) error { // Start transaction tx, err := db.BeginTx(ctx, nil) if err != nil { return err } // Debit from source account _, err = tx.ExecContext(ctx, ` MATCH (a:Account {id: ?}) WHERE a.balance >= ? SET a.balance = a.balance - ? `, from, amount, amount) if err != nil { tx.Rollback() return err } // Credit to destination account _, err = tx.ExecContext(ctx, ` MATCH (a:Account {id: ?}) SET a.balance = a.balance + ? `, to, amount) if err != nil { tx.Rollback() return err } // Commit transaction return tx.Commit() } </code></pre></div> <h4 id="transaction-options" class="position-relative d-flex align-items-center group"> Transaction Options <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="transaction-options" aria-haspopup="dialog" aria-label="Share link: Transaction Options"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Read-only transaction tx, err := db.BeginTx(ctx, &sql.TxOptions{ ReadOnly: true, }) // With isolation level (if supported) tx, err := db.BeginTx(ctx, &sql.TxOptions{ Isolation: sql.LevelSerializable, }) </code></pre></div> <h3 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> </h3>Use prepared statements for frequently executed queries: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func batchLookup(ctx context.Context, db *sql.DB, ids []string) error { // Prepare statement once stmt, err := db.PrepareContext(ctx, ` MATCH (p:Person {id: ?}) RETURN p.name, p.age `) if err != nil { return err } defer stmt.Close() // Execute multiple times for _, id := range ids { rows, err := stmt.QueryContext(ctx, id) if err != nil { return err } for rows.Next() { var name string var age int if err := rows.Scan(&name, &age); err != nil { rows.Close() return err } log.Printf("ID %s: %s (%d)", id, name, age) } rows.Close() } return nil } </code></pre></div> <h3 id="connection-pooling" class="position-relative d-flex align-items-center group"> Connection Pooling <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-pooling" aria-haspopup="dialog" aria-label="Share link: Connection Pooling"> Share link </button> </h3>The <code>database/sql</code> package provides built-in connection pooling: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func configurePool(db *sql.DB) { // Maximum number of open connections db.SetMaxOpenConns(25) // Maximum number of idle connections db.SetMaxIdleConns(10) // Maximum lifetime of a connection db.SetConnMaxLifetime(5 * time.Minute) // Maximum idle time before closing db.SetConnMaxIdleTime(1 * time.Minute) } </code></pre></div> <h4 id="pool-monitoring" class="position-relative d-flex align-items-center group"> Pool Monitoring <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="pool-monitoring" aria-haspopup="dialog" aria-label="Share link: Pool Monitoring"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func monitorPool(db *sql.DB) { ticker := time.NewTicker(30 * time.Second) defer ticker.Stop() for range ticker.C { stats := db.Stats() log.Printf("Pool Stats: Open=%d, InUse=%d, Idle=%d, WaitCount=%d, WaitDuration=%v", stats.OpenConnections, stats.InUse, stats.Idle, stats.WaitCount, stats.WaitDuration, ) } } </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>The Go client provides rich error types: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">import "geodedb.com/geode" func handleError(err error) { if err == nil { return } var derr *geode.DriverError if errors.As(err, &derr) { log.Printf("Geode Error - Code: %s, Message: %s", derr.Code, derr.Message) // Check if error is retryable if derr.IsRetryable() { log.Println("Error is retryable") } // Handle specific error codes switch derr.Code { case "42000": // Syntax error log.Println("Query syntax error") case "28000": // Authentication failure log.Println("Authentication failed") case "40001": // Serialization failure log.Println("Transaction conflict - retry") } } else { log.Printf("Generic error: %v", err) } } </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-go" data-lang="go">func executeWithRetry(ctx context.Context, db *sql.DB, query string, args ...interface{}) error { maxRetries := 3 baseDelay := 100 * time.Millisecond for attempt := 0; attempt < maxRetries; attempt++ { _, err := db.ExecContext(ctx, query, args...) if err == nil { return nil } var derr *geode.DriverError if errors.As(err, &derr) && derr.IsRetryable() { delay := baseDelay * time.Duration(1<<attempt) log.Printf("Retrying in %v (attempt %d/%d)", delay, attempt+1, maxRetries) time.Sleep(delay) continue } return err } return fmt.Errorf("max retries exceeded") } </code></pre></div> <h3 id="graph-operations" class="position-relative d-flex align-items-center group"> Graph 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="graph-operations" aria-haspopup="dialog" aria-label="Share link: Graph Operations"> Share link </button> </h3> <h4 id="creating-nodes-and-relationships" class="position-relative d-flex align-items-center group"> Creating Nodes and Relationships <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="creating-nodes-and-relationships" aria-haspopup="dialog" aria-label="Share link: Creating Nodes and Relationships"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func createSocialGraph(ctx context.Context, db *sql.DB) error { // Create nodes _, err := db.ExecContext(ctx, ` CREATE (alice:Person {name: 'Alice', age: 30}) CREATE (bob:Person {name: 'Bob', age: 25}) CREATE (alice)-[:FRIENDS_WITH {since: 2020}]->(bob) `) return err } // Create with parameters func createPerson(ctx context.Context, db *sql.DB, name string, age int) error { _, err := db.ExecContext(ctx, ` CREATE (p:Person {name: ?, age: ?, created_at: datetime()}) `, name, age) return err } </code></pre></div> <h4 id="traversing-relationships" class="position-relative d-flex align-items-center group"> Traversing Relationships <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="traversing-relationships" aria-haspopup="dialog" aria-label="Share link: Traversing Relationships"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func findFriendsOfFriends(ctx context.Context, db *sql.DB, personName string) error { rows, err := db.QueryContext(ctx, ` MATCH (p:Person {name: ?})-[:FRIENDS_WITH*2..3]-(fof:Person) WHERE fof.name <> ? RETURN DISTINCT fof.name AS name, fof.age AS age ORDER BY fof.name `, personName, personName) if err != nil { return err } defer rows.Close() for rows.Next() { var name string var age int if err := rows.Scan(&name, &age); err != nil { return err } log.Printf("Friend of friend: %s (%d)", name, age) } return rows.Err() } </code></pre></div> <h4 id="aggregations" class="position-relative d-flex align-items-center group"> Aggregations <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="aggregations" aria-haspopup="dialog" aria-label="Share link: Aggregations"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">func getStatistics(ctx context.Context, db *sql.DB) error { row := db.QueryRowContext(ctx, ` MATCH (p:Person) RETURN count(p) AS total, avg(p.age) AS avg_age, min(p.age) AS min_age, max(p.age) AS max_age `) var total int var avgAge, minAge, maxAge float64 if err := row.Scan(&total, &avgAge, &minAge, &maxAge); err != nil { return err } log.Printf("Total: %d, Avg Age: %.1f, Range: %.0f-%.0f", total, avgAge, minAge, maxAge) return nil } </code></pre></div> <h3 id="quic-performance-tuning" class="position-relative d-flex align-items-center group"> QUIC Performance Tuning <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="quic-performance-tuning" aria-haspopup="dialog" aria-label="Share link: QUIC Performance Tuning"> Share link </button> </h3>The Go client uses <a href="https://github.com/quic-go/quic-go" aria-label="quic-go – opens in new window" target="_blank" rel="noopener noreferrer" >quic-go ↗ </a> for QUIC transport. For optimal throughput on high-bandwidth connections, configure the following system-level optimizations. <h4 id="udp-buffer-sizes" class="position-relative d-flex align-items-center group"> UDP Buffer Sizes <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="udp-buffer-sizes" aria-haspopup="dialog" aria-label="Share link: UDP Buffer Sizes"> Share link </button> </h4>Increase the maximum UDP buffer size to ~7MB for high-throughput transfers: Linux: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">sudo sysctl -w net.core.rmem_max=7340032 sudo sysctl -w net.core.wmem_max=7340032 # Persist across reboots echo "net.core.rmem_max=7340032" | sudo tee -a /etc/sysctl.d/99-geode-quic.conf echo "net.core.wmem_max=7340032" | sudo tee -a /etc/sysctl.d/99-geode-quic.conf </code></pre></div>BSD/macOS: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">sudo sysctl -w kern.ipc.maxsockbuf=8441037 </code></pre></div> <h4 id="generic-segmentation-offload-gso" class="position-relative d-flex align-items-center group"> Generic Segmentation Offload (GSO) <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="generic-segmentation-offload-gso" aria-haspopup="dialog" aria-label="Share link: Generic Segmentation Offload (GSO)"> Share link </button> </h4>GSO batches UDP packets to reduce syscall overhead. It is automatically enabled on Linux 4.18+. <ul> <li>No configuration required - enabled automatically</li> <li>To disable (not recommended): Set <code>QUIC_GO_DISABLE_GSO=true</code> environment variable</li> </ul> <h4 id="path-mtu-discovery-dplpmtud" class="position-relative d-flex align-items-center group"> Path MTU Discovery (DPLPMTUD) <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="path-mtu-discovery-dplpmtud" aria-haspopup="dialog" aria-label="Share link: Path MTU Discovery (DPLPMTUD)"> Share link </button> </h4>DPLPMTUD probes for optimal MTU size, reducing per-packet overhead. It is enabled by default. <h3 id="testing" class="position-relative d-flex align-items-center group"> 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="testing" aria-haspopup="dialog" aria-label="Share link: Testing"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"># Unit tests (no server required) go test -v -short ./... # Integration tests with manual server GEODE_TEST_DSN="localhost:3141?insecure_tls_skip_verify=true" go test -v ./... # Docker-based integration tests (recommended) go test -v -tags=integration ./... # Docker integration tests with custom image GEODE_IMAGE="myregistry/geode:tag" go test -v -tags=integration ./... # Unit benchmarks go test -bench=. -benchmem ./... # Fuzzing go test -fuzz=FuzzParseDSN -fuzztime=30s </code></pre></div> <h3 id="utility-functions" class="position-relative d-flex align-items-center group"> Utility Functions <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="utility-functions" aria-haspopup="dialog" aria-label="Share link: Utility Functions"> Share link </button> </h3> <h4 id="unicode-conversion" class="position-relative d-flex align-items-center group"> Unicode Conversion <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="unicode-conversion" aria-haspopup="dialog" aria-label="Share link: Unicode Conversion"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">import "geodedb.com/geode" // UTF-8 to UTF-16 utf16 := geode.Utf8ToUtf16("Hello World") // UTF-16 to UTF-8 utf8 := geode.Utf16ToUtf8(utf16) // WTF-8 lossy decode (replaces invalid sequences with U+FFFD) safe := geode.Wtf8Lossy([]byte{0x61, 0x80, 0x62}) </code></pre></div> <h3 id="best-practices" class="position-relative d-flex align-items-center group"> Best Practices <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="best-practices" aria-haspopup="dialog" aria-label="Share link: Best Practices"> Share link </button> </h3> <h4 id="connection-management" class="position-relative d-flex align-items-center group"> Connection Management <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-management" aria-haspopup="dialog" aria-label="Share link: Connection Management"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Good: Use a single *sql.DB for the entire application var db *sql.DB func init() { var err error db, err = sql.Open("geode", os.Getenv("GEODE_DSN")) if err != nil { log.Fatal(err) } configurePool(db) } // Good: Use context with timeout func query(ctx context.Context) error { ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() rows, err := db.QueryContext(ctx, "MATCH (n) RETURN n LIMIT 10") // ... } // Bad: Don't create new connections for each request func badQuery() error { db, _ := sql.Open("geode", "localhost:3141") // Creates new pool! defer db.Close() // ... } </code></pre></div> <h4 id="resource-cleanup" class="position-relative d-flex align-items-center group"> Resource Cleanup <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="resource-cleanup" aria-haspopup="dialog" aria-label="Share link: Resource Cleanup"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go">// Good: Always close rows rows, err := db.QueryContext(ctx, query) if err != nil { return err } defer rows.Close() // Good: Check rows.Err() after iteration for rows.Next() { // ... } if err := rows.Err(); err != nil { return err } </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-go" data-lang="go">func batchInsert(ctx context.Context, db *sql.DB, people []Person) error { tx, err := db.BeginTx(ctx, nil) if err != nil { return err } stmt, err := tx.PrepareContext(ctx, ` CREATE (p:Person {name: ?, age: ?}) `) if err != nil { tx.Rollback() return err } defer stmt.Close() for _, p := range people { if _, err := stmt.ExecContext(ctx, p.Name, p.Age); err != nil { tx.Rollback() return err } } return tx.Commit() } </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/sql-driver/" >SQL Driver Interface</a> </li> <li><a href="/tags/client-libraries/" >Client Libraries</a> </li> <li><a href="/tags/quic/" >QUIC Protocol</a> </li> <li><a href="/tags/go/" >Go Programming</a> </li> <li><a href="/tags/connection-pooling/" >Connection Pooling</a> </li> <li><a href="/tags/transactions/" >Transactions</a> </li> <li><a href="/tags/performance/" >Performance Tuning</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="https://pkg.go.dev/database/sql" aria-label="Go database/sql Documentation – opens in new window" target="_blank" rel="noopener noreferrer" >Go database/sql Documentation ↗ </a> </li> <li><a href="https://www.rfc-editor.org/rfc/rfc9000.html" aria-label="QUIC Protocol RFC 9000 – opens in new window" target="_blank" rel="noopener noreferrer" >QUIC Protocol RFC 9000 ↗ </a> </li> <li><a href="https://www.iso.org/standard/76120.html" aria-label="ISO/IEC 39075:2024 GQL Standard – opens in new window" target="_blank" rel="noopener noreferrer" >ISO/IEC 39075:2024 GQL Standard ↗ </a> </li> <li><a href="https://gitlab.com/devnw/codepros/geode/geode-client-go" aria-label="Go Client Repository – opens in new window" target="_blank" rel="noopener noreferrer" >Go Client Repository ↗ </a> </li> <li><a href="/docs/" >Geode Documentation</a> </li> </ul>

Popular

Related Articles