Integration Testing

<h2 id="integration-testing-in-geode" class="position-relative d-flex align-items-center group"> Integration Testing in Geode <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-in-geode" aria-haspopup="dialog" aria-label="Share link: Integration Testing in Geode"> 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>Integration testing validates that Geode components work together correctly, from client libraries through the server to storage layers. Geode’s test harness provides comprehensive cross-client validation ensuring all polyglot clients behave consistently. <h3 id="geode-test-harness" class="position-relative d-flex align-items-center group"> Geode Test Harness <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="geode-test-harness" aria-haspopup="dialog" aria-label="Share link: Geode Test Harness"> Share link </button> </h3>The <code>geode-test-harness</code> validates all client libraries against a live Geode server: <div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash">cd geode-test-harness # Setup test environment make setup # Run all client tests make test-all # Generate HTML report make test-all-html # Test specific client make test-go make test-python make test-rust make test-zig </code></pre></div> <h3 id="test-categories" class="position-relative d-flex align-items-center group"> Test Categories <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="test-categories" aria-haspopup="dialog" aria-label="Share link: Test Categories"> Share link </button> </h3> <h4 id="1-basic-operations" class="position-relative d-flex align-items-center group"> 1. Basic 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="1-basic-operations" aria-haspopup="dialog" aria-label="Share link: 1. Basic Operations"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># geode-test-harness/tests/test_basic.py import pytest @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_ping(client): """Verify client can ping server""" result = await run_client_test(client, "ping") assert result.success @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_simple_query(client): """Execute simple MATCH query""" result = await run_client_test(client, "query", query="MATCH (n) RETURN count(n)") assert result.success assert 'count(n)' in result.columns </code></pre></div> <h4 id="2-crud-operations" class="position-relative d-flex align-items-center group"> 2. CRUD 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="2-crud-operations" aria-haspopup="dialog" aria-label="Share link: 2. CRUD Operations"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">@pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_node_create(client): """Create node and verify""" result = await run_client_test(client, "execute", query="CREATE (u:User {name: 'Alice', age: 30}) RETURN u") assert result.success assert result.rows_affected == 1 @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_relationship_create(client): """Create relationship between nodes""" await run_client_test(client, "execute", query="CREATE (a:User {name: 'Alice'})-[:KNOWS]->(b:User {name: 'Bob'})") result = await run_client_test(client, "query", query="MATCH (a:User)-[r:KNOWS]->(b:User) RETURN count(r)") assert result.bindings[0]['count(r)'] == 1 </code></pre></div> <h4 id="3-transaction-tests" class="position-relative d-flex align-items-center group"> 3. Transaction 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="3-transaction-tests" aria-haspopup="dialog" aria-label="Share link: 3. Transaction Tests"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">@pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_transaction_commit(client): """Test transaction commit""" result = await run_client_test(client, "transaction", operations=[ {"type": "begin"}, {"type": "execute", "query": "CREATE (u:User {name: 'TX Test'})"}, {"type": "commit"} ]) assert result.success # Verify committed verify = await run_client_test(client, "query", query="MATCH (u:User {name: 'TX Test'}) RETURN count(u)") assert verify.bindings[0]['count(u)'] == 1 @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_transaction_rollback(client): """Test transaction rollback""" result = await run_client_test(client, "transaction", operations=[ {"type": "begin"}, {"type": "execute", "query": "CREATE (u:User {name: 'Rollback Test'})"}, {"type": "rollback"} ]) assert result.success # Verify rolled back verify = await run_client_test(client, "query", query="MATCH (u:User {name: 'Rollback Test'}) RETURN count(u)") assert verify.bindings[0]['count(u)'] == 0 </code></pre></div> <h4 id="4-concurrent-access" class="position-relative d-flex align-items-center group"> 4. Concurrent Access <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="4-concurrent-access" aria-haspopup="dialog" aria-label="Share link: 4. Concurrent Access"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">@pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_concurrent_queries(client): """Test concurrent query execution""" import asyncio async def run_query(i): return await run_client_test(client, "query", query=f"MATCH (n) WHERE n.id = {i} RETURN n") # Run 100 concurrent queries results = await asyncio.gather(*[run_query(i) for i in range(100)]) # All should succeed assert all(r.success for r in results) </code></pre></div> <h3 id="end-to-end-scenarios" class="position-relative d-flex align-items-center group"> End-to-End Scenarios <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="end-to-end-scenarios" aria-haspopup="dialog" aria-label="Share link: End-to-End Scenarios"> Share link </button> </h3> <h4 id="multi-client-workflow" class="position-relative d-flex align-items-center group"> Multi-Client Workflow <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="multi-client-workflow" aria-haspopup="dialog" aria-label="Share link: Multi-Client Workflow"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_multi_client_workflow(): """Test workflow across different clients""" # Go client creates data await run_client_test("go", "execute", query="CREATE (p:Product {id: 1, name: 'Widget', price: 19.99})") # Python client queries data result = await run_client_test("python", "query", query="MATCH (p:Product {id: 1}) RETURN p.name, p.price") assert result.bindings[0]['p.name'] == 'Widget' # Rust client updates data await run_client_test("rust", "execute", query="MATCH (p:Product {id: 1}) SET p.price = 24.99") # Zig client verifies update result = await run_client_test("zig", "query", query="MATCH (p:Product {id: 1}) RETURN p.price") assert result.bindings[0]['p.price'] == 24.99 </code></pre></div> <h4 id="data-type-compatibility" class="position-relative d-flex align-items-center group"> Data Type Compatibility <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-type-compatibility" aria-haspopup="dialog" aria-label="Share link: Data Type Compatibility"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_data_type_roundtrip(): """Verify data types work across all clients""" test_data = { "null_value": None, "int_value": 42, "float_value": 3.14159, "string_value": "Hello, Geode!", "bool_value": True, "list_value": [1, 2, 3, 4, 5], "map_value": {"key": "value", "nested": {"a": 1}} } # Create with Go client await run_client_test("go", "execute", query="CREATE (n:Test $props)", params={"props": test_data}) # Verify with each client for client in ["go", "python", "rust", "zig"]: result = await run_client_test(client, "query", query="MATCH (n:Test) RETURN n") node = result.bindings[0]['n'] assert node['int_value'] == 42 assert abs(node['float_value'] - 3.14159) < 0.0001 assert node['string_value'] == "Hello, Geode!" assert node['list_value'] == [1, 2, 3, 4, 5] </code></pre></div> <h3 id="performance-testing" class="position-relative d-flex align-items-center group"> Performance 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="performance-testing" aria-haspopup="dialog" aria-label="Share link: Performance Testing"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_throughput(): """Measure queries per second for each client""" import time for client in ["go", "python", "rust", "zig"]: start = time.time() query_count = 1000 for i in range(query_count): await run_client_test(client, "query", query="MATCH (n) RETURN count(n)") duration = time.time() - start qps = query_count / duration print(f"{client}: {qps:.2f} QPS") # Verify minimum performance baseline_qps = 0 # Set based on your benchmark baseline assert qps >= baseline_qps, ( f"{client}: {qps:.2f} QPS below baseline {baseline_qps}" ) </code></pre></div> <h3 id="error-handling-tests" class="position-relative d-flex align-items-center group"> Error Handling 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="error-handling-tests" aria-haspopup="dialog" aria-label="Share link: Error Handling Tests"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">@pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_parse_error(client): """Verify parse errors handled correctly""" result = await run_client_test(client, "query", query="INVALID QUERY SYNTAX", expect_error=True) assert not result.success assert "ParseError" in result.error_type @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_connection_error(client): """Verify connection errors handled""" result = await run_client_test(client, "connect", host="nonexistent.host", port=9999, expect_error=True) assert not result.success assert "ConnectionError" in result.error_type </code></pre></div> <h3 id="test-reporting" class="position-relative d-flex align-items-center group"> Test Reporting <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="test-reporting" aria-haspopup="dialog" aria-label="Share link: Test Reporting"> Share link </button> </h3><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># Generate comprehensive test report def generate_test_report(results): report = { "timestamp": datetime.now().isoformat(), "summary": { "total_tests": len(results), "passed": sum(1 for r in results if r.success), "failed": sum(1 for r in results if not r.success), "duration_seconds": sum(r.duration for r in results) }, "by_client": {} } for client in ["go", "python", "rust", "zig"]: client_results = [r for r in results if r.client == client] report["by_client"][client] = { "total": len(client_results), "passed": sum(1 for r in client_results if r.success), "failed": sum(1 for r in client_results if not r.success), "avg_duration_ms": sum(r.duration for r in client_results) / len(client_results) * 1000 } return report </code></pre></div> <h3 id="continuous-integration-setup" class="position-relative d-flex align-items-center group"> Continuous Integration Setup <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="continuous-integration-setup" aria-haspopup="dialog" aria-label="Share link: Continuous Integration Setup"> Share link </button> </h3> <h4 id="github-actions-integration" class="position-relative d-flex align-items-center group"> GitHub Actions Integration <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="github-actions-integration" aria-haspopup="dialog" aria-label="Share link: GitHub Actions Integration"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-yaml" data-lang="yaml"># .github/workflows/integration-tests.yml name: Integration Tests on: [push, pull_request] jobs: test: runs-on: ubuntu-latest services: geode: image: geode:latest ports: - 3141:3141 options: >- --health-cmd "geode ping" --health-interval 10s --health-timeout 5s --health-retries 5 strategy: matrix: client: [go, python, rust, zig] steps: - uses: actions/checkout@v3 - name: Setup ${{ matrix.client }} run: | cd geode-test-harness make setup-${{ matrix.client }} - name: Run Integration Tests run: | cd geode-test-harness make test-${{ matrix.client }} - name: Upload Test Results if: always() uses: actions/upload-artifact@v3 with: name: test-results-${{ matrix.client }} path: geode-test-harness/reports/${{ matrix.client }}/ </code></pre></div> <h4 id="docker-compose-test-environment" class="position-relative d-flex align-items-center group"> Docker Compose Test Environment <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-compose-test-environment" aria-haspopup="dialog" aria-label="Share link: Docker Compose Test Environment"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-yaml" data-lang="yaml"># docker-compose.test.yml version: '3.8' services: geode: image: geode:latest ports: - "3141:3141" environment: - GEODE_LOG_LEVEL=debug - GEODE_MAX_CONNECTIONS=1000 healthcheck: test: ["CMD", "geode", "ping"] interval: 5s timeout: 3s retries: 5 test-runner: build: context: ./geode-test-harness dockerfile: Dockerfile.test depends_on: geode: condition: service_healthy environment: - GEODE_HOST=geode - GEODE_PORT=3141 volumes: - ./geode-test-harness:/app - ./test-results:/app/reports </code></pre></div> <h3 id="advanced-testing-patterns" class="position-relative d-flex align-items-center group"> Advanced Testing 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="advanced-testing-patterns" aria-haspopup="dialog" aria-label="Share link: Advanced Testing Patterns"> Share link </button> </h3> <h4 id="schema-validation-tests" class="position-relative d-flex align-items-center group"> Schema Validation 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="schema-validation-tests" aria-haspopup="dialog" aria-label="Share link: Schema Validation Tests"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_schema_consistency(): """Verify schema is consistent across all operations""" # Create schema await run_client_test("python", "execute", query=""" CREATE (u:User {id: 'test1', name: 'Test User', age: 25}) """) # Verify schema from all clients for client in ["go", "python", "rust", "zig"]: result = await run_client_test(client, "query", query="MATCH (u:User {id: 'test1'}) RETURN u.name, u.age") assert result.bindings[0]['u.name'] == 'Test User' assert result.bindings[0]['u.age'] == 25 </code></pre></div> <h4 id="stress-testing" class="position-relative d-flex align-items-center group"> Stress 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="stress-testing" aria-haspopup="dialog" aria-label="Share link: Stress Testing"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_connection_pool_under_load(): """Test connection pool handles high concurrent load""" import asyncio async def concurrent_queries(client, n=100): tasks = [] for i in range(n): task = run_client_test(client, "query", query=f"MATCH (n) WHERE n.id = {i} RETURN n") tasks.append(task) results = await asyncio.gather(*tasks) return results for client in ["go", "python", "rust", "zig"]: start = time.time() results = await concurrent_queries(client, n=500) duration = time.time() - start # All queries should succeed assert all(r.success for r in results) # Should complete in reasonable time assert duration < 30 # 30 seconds for 500 queries print(f"{client}: {500/duration:.2f} QPS") </code></pre></div> <h4 id="data-consistency-tests" class="position-relative d-flex align-items-center group"> Data Consistency 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="data-consistency-tests" aria-haspopup="dialog" aria-label="Share link: Data Consistency Tests"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_transaction_isolation(): """Verify transaction isolation between clients""" # Client 1 starts transaction tx1_id = await run_client_test("python", "transaction_begin") # Client 1 creates data await run_client_test("python", "execute", transaction_id=tx1_id, query="CREATE (u:User {id: 'iso_test', name: 'Isolated'})") # Client 2 should NOT see uncommitted data result = await run_client_test("go", "query", query="MATCH (u:User {id: 'iso_test'}) RETURN count(u)") assert result.bindings[0]['count(u)'] == 0 # Client 1 commits await run_client_test("python", "transaction_commit", transaction_id=tx1_id) # Now Client 2 should see data result = await run_client_test("go", "query", query="MATCH (u:User {id: 'iso_test'}) RETURN count(u)") assert result.bindings[0]['count(u)'] == 1 </code></pre></div> <h4 id="binary-data-handling" class="position-relative d-flex align-items-center group"> Binary Data 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="binary-data-handling" aria-haspopup="dialog" aria-label="Share link: Binary Data Handling"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_binary_data_roundtrip(): """Test binary data handling across clients""" import base64 # Create binary data binary_data = bytes([i % 256 for i in range(1000)]) encoded = base64.b64encode(binary_data).decode('utf-8') # Store via Python client await run_client_test("python", "execute", query="CREATE (b:Binary {id: 'test', data: $data})", params={"data": encoded}) # Retrieve via each client for client in ["go", "python", "rust", "zig"]: result = await run_client_test(client, "query", query="MATCH (b:Binary {id: 'test'}) RETURN b.data") retrieved = base64.b64decode(result.bindings[0]['b.data']) assert retrieved == binary_data </code></pre></div> <h4 id="time-zone-handling" class="position-relative d-flex align-items-center group"> Time Zone 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="time-zone-handling" aria-haspopup="dialog" aria-label="Share link: Time Zone Handling"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">async def test_timezone_consistency(): """Verify timestamp handling across timezones""" from datetime import datetime, timezone # Create timestamp in UTC now_utc = datetime.now(timezone.utc) # Store via Go client await run_client_test("go", "execute", query="CREATE (e:Event {id: 'tz_test', occurred_at: $timestamp})", params={"timestamp": now_utc.isoformat()}) # Verify all clients read same timestamp for client in ["go", "python", "rust", "zig"]: result = await run_client_test(client, "query", query="MATCH (e:Event {id: 'tz_test'}) RETURN e.occurred_at") timestamp = parse_iso8601(result.bindings[0]['e.occurred_at']) # Should match within 1 second (allowing for clock skew) assert abs((timestamp - now_utc).total_seconds()) < 1 </code></pre></div> <h3 id="test-organization" class="position-relative d-flex align-items-center group"> Test Organization <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="test-organization" aria-haspopup="dialog" aria-label="Share link: Test Organization"> Share link </button> </h3> <h4 id="test-categorization" class="position-relative d-flex align-items-center group"> Test Categorization <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="test-categorization" aria-haspopup="dialog" aria-label="Share link: Test Categorization"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># tests/test_categories.py import pytest class TestBasicOperations: """Basic CRUD operations""" @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_ping(self, client): """Basic connectivity""" pass @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_create_node(self, client): """Create single node""" pass class TestComplexQueries: """Complex graph patterns""" @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_multi_hop_traversal(self, client): """Multi-hop graph traversal""" pass class TestTransactions: """Transaction behavior""" @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) async def test_commit(self, client): """Transaction commit""" pass class TestPerformance: """Performance and scalability""" @pytest.mark.parametrize("client", ["go", "python", "rust", "zig"]) @pytest.mark.slow async def test_bulk_insert(self, client): """Bulk data insertion""" pass </code></pre></div> <h4 id="fixtures-and-helpers" class="position-relative d-flex align-items-center group"> Fixtures and Helpers <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="fixtures-and-helpers" aria-haspopup="dialog" aria-label="Share link: Fixtures and Helpers"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># tests/conftest.py import pytest from geode_test_harness import GeodeTestClient @pytest.fixture(scope="session") async def geode_server(): """Start Geode server for tests""" server = await start_geode_server() yield server await server.stop() @pytest.fixture async def clean_database(geode_server): """Clean database before each test""" await geode_server.execute("MATCH (n) DETACH DELETE n") yield # Cleanup after test await geode_server.execute("MATCH (n) DETACH DELETE n") @pytest.fixture def sample_graph_data(): """Sample graph data for tests""" return { "nodes": [ {"id": 1, "label": "User", "name": "Alice"}, {"id": 2, "label": "User", "name": "Bob"}, {"id": 3, "label": "Product", "name": "Widget"} ], "relationships": [ {"from": 1, "to": 2, "type": "KNOWS"}, {"from": 1, "to": 3, "type": "PURCHASED"} ] } async def load_sample_data(client, data): """Helper to load sample data""" for node in data["nodes"]: await client.execute( f"CREATE (n:{node['label']} {{id: $id, name: $name}})", node ) for rel in data["relationships"]: await client.execute( f"MATCH (a {{id: $from}}), (b {{id: $to}}) CREATE (a)-[:{rel['type']}]->(b)", rel ) </code></pre></div> <h3 id="test-reporting-1" class="position-relative d-flex align-items-center group"> Test Reporting <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="test-reporting-1" aria-haspopup="dialog" aria-label="Share link: Test Reporting"> Share link </button> </h3> <h4 id="custom-test-reporter" class="position-relative d-flex align-items-center group"> Custom Test Reporter <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="custom-test-reporter" aria-haspopup="dialog" aria-label="Share link: Custom Test Reporter"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python"># test_reporter.py class IntegrationTestReporter: """Generate comprehensive test reports""" def __init__(self): self.results = [] def record_result(self, client, test_name, result): """Record individual test result""" self.results.append({ 'client': client, 'test': test_name, 'status': 'passed' if result.success else 'failed', 'duration_ms': result.duration * 1000, 'error': result.error if hasattr(result, 'error') else None }) def generate_html_report(self, output_file): """Generate HTML test report""" html = f""" <!DOCTYPE html> <html> <head> <title>Geode Integration Test Report</title> <style> .passed {{ color: green; }} .failed {{ color: red; }} table {{ border-collapse: collapse; width: 100%; }} th, td {{ border: 1px solid #ddd; padding: 8px; }} </style> </head> <body> <h1>Integration Test Results</h1> Generated: {datetime.now()} <h2>Summary</h2> <table> <tr> <th>Client</th> <th>Total</th> <th>Passed</th> <th>Failed</th> <th>Pass Rate</th> </tr> """ for client in ["go", "python", "rust", "zig"]: client_results = [r for r in self.results if r['client'] == client] total = len(client_results) passed = sum(1 for r in client_results if r['status'] == 'passed') failed = total - passed pass_rate = (passed / total * 100) if total > 0 else 0 html += f""" <tr> <td>{client}</td> <td>{total}</td> <td class="passed">{passed}</td> <td class="failed">{failed}</td> <td>{pass_rate:.1f}%</td> </tr> """ html += """ </table> <h2>Detailed Results</h2> <table> <tr> <th>Client</th> <th>Test</th> <th>Status</th> <th>Duration (ms)</th> <th>Error</th> </tr> """ for result in self.results: status_class = result.rows['status'] html += f""" <tr> <td>{result.rows['client']}</td> <td>{result.rows['test']}</td> <td class="{status_class}">{result.rows['status']}</td> <td>{result.rows['duration_ms']:.2f}</td> <td>{result.rows['error'] or ''}</td> </tr> """ html += """ </table> </body> </html> """ with open(output_file, 'w') as f: f.write(html) </code></pre></div> <h4 id="performance-comparison-report" class="position-relative d-flex align-items-center group"> Performance Comparison Report <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-comparison-report" aria-haspopup="dialog" aria-label="Share link: Performance Comparison Report"> Share link </button> </h4><div class="highlight"><pre tabindex="0" class="chroma"><code class="language-python" data-lang="python">def generate_performance_comparison(results): """Compare performance across clients""" performance_data = {} for result in results: test_name = result.rows['test'] if test_name not in performance_data: performance_data[test_name] = {} client = result.rows['client'] duration = result.rows['duration_ms'] if client not in performance_data[test_name]: performance_data[test_name][client] = [] performance_data[test_name][client].append(duration) # Generate comparison chart data comparison = [] for test_name, client_data in performance_data.items(): test_comparison = {'test': test_name} for client, durations in client_data.items(): avg_duration = sum(durations) / len(durations) test_comparison[client] = avg_duration comparison.append(test_comparison) return comparison </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/unit-tests/" >Unit Tests</a> : Unit testing strategies</li> <li><a href="/tags/ci-cd/" >CI/CD</a> : Continuous integration</li> <li><a href="/tags/deployment/" >Deployment</a> : Deployment strategies</li> <li><a href="/tags/containers/" >Containers</a> : Container-based testing</li> <li><a href="/tags/testing/" >Testing</a> : General testing practices</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>Integration Testing Guide: <code>/docs/development/integration-testing/</code></li> <li>Test Harness Documentation: <code>/docs/development/test-harness/</code></li> <li>Cross-Client Compatibility: <code>/docs/clients/compatibility/</code></li> <li>CI/CD Best Practices: <code>/docs/development/ci-cd-practices/</code></li> <li>Performance Testing: <code>/docs/testing/performance-testing/</code></li> </ul>

Popular

Related Articles

Testing Strategies Guide