Repository Analysis

pgdogdev/pgdog

PostgreSQL connection pooler, load balancer and database sharder.

3.4 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of pgdogdev/pgdog, a Rust project with 5,287 GitHub stars. SynthScan v2.0 examined 185,617 lines of code across 1194 source files, recording 437 pattern matches distributed across 13 syntactic categories. The overall adjusted score of 3.4 places this repository in the Likely human-written band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

3.4
Adjusted Score
3.4
Raw Score
100%
Time Factor
2026-07-14
Last Push
5.3K
Stars
Rust
Language
185.6K
Lines of Code
1.2K
Files
437
Pattern Hits
2026-07-14
Scan Date
0.00
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.

No multi-scan history yet — run the scanner again to build trend data.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 0HIGH 0MEDIUM 88LOW 349

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 437 distinct pattern matches across 13 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Decorative Section Separators87 hits · 274 pts
SeverityFileLineSnippetContext
MEDIUMpgdog-postgres-types/src/array.rs397 // ── Text decode ──────────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs502 // ── Text roundtrip ───────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs532 // ── Cross-format encode ──────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs569 // ── Binary roundtrip ─────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs596 // ── Rejection / validation ───────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs696 // ── Equality ─────────────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs706 // ── Datum integration ────────────────────────────────────────────COMMENT
MEDIUMintegration/pgdog.toml186# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml195# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml205# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml215# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml225# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml235# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml244# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml1# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml42# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml55# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml97# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml171# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml263# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml282# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml309# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml334# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml351# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml370# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml403# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml427# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml434# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml487# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/rust/tests/integration/cancel.rs127 // ── Cancel connection 1 ────────────────────────────────────────────────COMMENT
MEDIUMintegration/rust/tests/integration/cancel.rs145 // ── Cancel connection 2 ────────────────────────────────────────────────COMMENT
MEDIUMintegration/rust/tests/integration/admin/tasks.rs9// ─── Constants ──────────────────────────────────────────────────────────────COMMENT
MEDIUMintegration/rust/tests/integration/admin/tasks.rs24// ─── Helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUMintegration/rust/tests/integration/admin/tasks.rs358// ─── Tests ──────────────────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/net/messages/replication/logical/update.rs129 // ── partial_new ───────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/frontend/router/sharding/mapping.rs153 // ── helpers ──────────────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/frontend/router/sharding/mapping.rs382 // ── construction ─────────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/frontend/router/sharding/mapping.rs399 // ── list mapping ─────────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/frontend/router/sharding/mapping.rs448 // ── range mapping ─────────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/frontend/router/sharding/mapping.rs540 // ── resolution order ─────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs328 // ── static_client_password(): config-level error cases ─────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs343 // ── static_client_password(): cache behaviour ───────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs402 // ── static_client_password(): HTTP responses ────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs502 // ── login(): parameter validation ─────────────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs569 // ── login(): HTTP responses ────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs612 // ── vault_token(): cache behaviour ────────────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs627 // ── client(): namespace header ─────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/auth/vault.rs652 // ── resolve_passwords() ────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/rds_iam.rs110 // ── infer_region_from_rds_host ───────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/rds_iam.rs143 // ── resolve_region ───────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs196 // ── credentials(): config-level error cases ───────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs222 // ── credentials(): HTTP responses ─────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs317 // ── static_backend_credentials(): config-level error cases ────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs345 // ── static_backend_credentials(): HTTP responses ───────────────────────────COMMENT
MEDIUM…ackend/replication/logical/publisher/publisher_impl.rs726 // ── Helpers ─────────────────────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs496 // ── Routing helpers ────────────────────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs506 // ── Shape-cache helpers ──────────────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs753 // ── FULL identity path ──────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs794 // ── DEFAULT / INDEX path ────────────────────────────────────────────COMMENT
MEDIUM…og/src/backend/replication/logical/subscriber/tests.rs399// ── State machine tests ─────────────────────────────────────────────COMMENT
27 more matches not shown…
Over-Commented Block214 hits · 205 pts
SeverityFileLineSnippetContext
LOWcli.sh1#!/bin/bashCOMMENT
LOWexample.pgdog.toml1#:schema ./.schema/pgdog.schema.jsonCOMMENT
LOWexample.pgdog.toml21host = "0.0.0.0"COMMENT
LOWexample.pgdog.toml41# client until they disconnect.COMMENT
LOWexample.pgdog.toml61# How long to wait for a health check to complete before banning a database.COMMENT
LOWexample.pgdog.toml81# - round_robinCOMMENT
LOWexample.pgdog.toml101# 'replica'`, or a `/* pgdog_role: replica */` comment. Useful for migrating anCOMMENT
LOWexample.pgdog.toml121# NOTE: if any user sets `server_auth = "rds_iam"` in users.toml,COMMENT
LOWexample.pgdog.toml141# Default: not setCOMMENT
LOWexample.pgdog.toml161log_level = "info"COMMENT
LOWexample.pgdog.toml181# Default: extendedCOMMENT
LOWexample.pgdog.toml201#COMMENT
LOWexample.pgdog.toml221# more queries.COMMENT
LOWexample.pgdog.toml241checkout_timeout = 5_000COMMENT
LOWexample.pgdog.toml261#COMMENT
LOWexample.pgdog.toml281#COMMENT
LOWexample.pgdog.toml301# Name of the database. This is what your clients will need to specify inCOMMENT
LOWexample.pgdog.toml461# Allows a new cluster to be validated and load testedCOMMENT
LOWexample.pgdog.toml481# Auth method used to log into Vault: "kubernetes" or "approle".COMMENT
LOWexample.users.toml21# Example: backend authentication with Azure Workload Identity token generation.COMMENT
LOWexample.users.toml41# Example: backend authentication with a HashiCorp Vault static role.COMMENT
LOWpgdog-config/src/core.rs181 /// General settings are relevant to the operations of the pooler itself, or apply to all database pools.COMMENT
LOWpgdog-config/src/core.rs201 pub tcp: Tcp,COMMENT
LOWpgdog-config/src/core.rs221 ///COMMENT
LOWpgdog-config/src/core.rs241 /// https://docs.pgdog.dev/features/sharding/omnishards/COMMENT
LOWpgdog-config/src/core.rs261 pub replication: Replication,COMMENT
LOWpgdog-config/src/pooling.rs61/// https://docs.pgdog.dev/configuration/pgdog.toml/general/#pooler_modeCOMMENT
LOWpgdog-config/src/database.rs121#[serde(deny_unknown_fields)]COMMENT
LOWpgdog-config/src/database.rs141 #[serde(default = "Database::port")]COMMENT
LOWpgdog-config/src/database.rs161 // #[serde(default = "Database::max_connections")]COMMENT
LOWpgdog-config/src/database.rs181 pub statement_timeout: Option<u64>,COMMENT
LOWpgdog-config/src/users.rs21 ///COMMENT
LOWpgdog-config/src/users.rs261)]COMMENT
LOWpgdog-config/src/users.rs281 /// The password for the user. Clients will need to provide this when connecting to PgDog.COMMENT
LOWpgdog-config/src/users.rs301 /// https://docs.pgdog.dev/configuration/users.toml/users/#pooler_modeCOMMENT
LOWpgdog-config/src/users.rs321 /// e.g. `database/creds/my-role` for `server_auth = "vault_dynamic"` orCOMMENT
LOWpgdog-config/src/users.rs341 /// Lock timeout.COMMENT
LOWpgdog-config/src/users.rs361 /// Sharding target database for replication.COMMENT
LOWpgdog-config/src/users.rs441 ///COMMENT
LOWpgdog-config/src/memory.rs1use schemars::JsonSchema;COMMENT
LOWpgdog-config/src/auth.rs1use schemars::JsonSchema;COMMENT
LOWpgdog-config/src/sharding.rs21 ///COMMENT
LOWpgdog-config/src/sharding.rs41 pub column: String,COMMENT
LOWpgdog-config/src/sharding.rs61 /// The data type of the column. Currently supported options are: `bigint`, `uuid`, `varchar`, `vector`.COMMENT
LOWpgdog-config/src/sharding.rs121/// A single value-to-shard routing rule within a table's `mapping`.COMMENT
LOWpgdog-config/src/sharding.rs141COMMENT
LOWpgdog-config/src/sharding.rs161 /// 64-bit integer (default).COMMENT
LOWpgdog-config/src/sharding.rs401 /// Enable automatically when sharding or read/write splitting is configured (default).COMMENT
LOWpgdog-config/src/otel.rs1use std::collections::HashMap;COMMENT
LOWpgdog-config/src/otel.rs21 #[serde(default = "Otel::endpoint")]COMMENT
LOWpgdog-config/src/otel.rs41 /// [otel.headers]COMMENT
LOWpgdog-config/src/general.rs61 Serialize, Deserialize, Debug, Copy, Clone, PartialEq, Eq, Hash, Default, JsonSchema, FromStr,COMMENT
LOWpgdog-config/src/general.rs81 ///COMMENT
LOWpgdog-config/src/general.rs101 ///COMMENT
LOWpgdog-config/src/general.rs121 ///COMMENT
LOWpgdog-config/src/general.rs141COMMENT
LOWpgdog-config/src/general.rs161 /// _Default:_ `5000`COMMENT
LOWpgdog-config/src/general.rs181 ///COMMENT
LOWpgdog-config/src/general.rs201 ///COMMENT
LOWpgdog-config/src/general.rs221 #[serde(default)]COMMENT
154 more matches not shown…
Hyper-Verbose Identifiers54 hits · 52 pts
SeverityFileLineSnippetContext
LOWintegration/python/test_prepared.py26def test_prepare_execute_parallel():CODE
LOWintegration/python/test_asyncpg.py300async def test_execute_many_cross_shard(conns):CODE
LOWintegration/python/test_asyncpg.py366async def test_timestamp_sorting_binary_format():CODE
LOWintegration/python/test_asyncpg.py543async def test_schema_sharding_transactions():STRING
LOWintegration/python/test_asyncpg.py584async def test_schema_sharding_default():STRING
LOWintegration/python/test_asyncpg.py605async def test_schema_sharding_search_path():STRING
LOWintegration/python/test_asyncpg.py636async def test_pgdog_role_selection():STRING
LOWintegration/python/test_numeric_binary.py9async def test_numeric_binary_format():CODE
LOWintegration/python/test_numeric_binary.py114async def test_numeric_sorting_binary():STRING
LOWintegration/python/test_numeric_binary.py175async def test_numeric_aggregates_binary():STRING
LOWintegration/python/test_numeric_sorting.py11async def setup_sharded_numeric_table(conn):CODE
LOWintegration/python/test_numeric_sorting.py23async def test_numeric_cross_shard_sorting():STRING
LOWintegration/python/test_numeric_sorting.py79async def test_numeric_precision_and_edge_cases():CODE
LOWintegration/python/test_numeric_sorting.py135async def test_numeric_arithmetic_operations():CODE
LOWintegration/python/test_sqlalchemy.py92async def schema_sharding_startup_param():CODE
LOWintegration/python/test_sqlalchemy.py232async def test_connection_pool_stress(engines):CODE
LOWintegration/python/test_sqlalchemy.py575async def test_schema_sharding_with_startup_param_and_set_after_query(STRING
LOWintegration/python/test_psycopg.py34def test_admin_pgcli_detection():CODE
LOWintegration/python/test_psycopg.py115def test_postgres_variants_parameter_limits(count, expect_error_keywords):CODE
LOWintegration/python/test_psycopg.py164def test_pipeline_many_queries():CODE
LOWintegration/python/test_psycopg.py187def test_pipeline_executemany():CODE
LOWintegration/python/test_psycopg.py217def test_pipeline_transaction():CODE
LOWintegration/python/test_psycopg.py241def test_pipeline_fetch_after_exit():CODE
LOWintegration/python/test_psycopg.py287def test_pipeline_query_then_nonpipeline():CODE
LOWintegration/python/test_psycopg.py309def test_pipeline_error_recovery():CODE
LOWintegration/python/test_psycopg.py333def test_pipeline_multiple_errors():CODE
LOWintegration/python/test_idle_in_transaction.py100async def test_idle_in_transaction_timeout():CODE
LOWintegration/python/test_idle_in_transaction.py107async def _disconnect_mid_transaction():CODE
LOWintegration/python/test_idle_in_transaction.py144async def test_disconnect_mid_transaction_rolls_back():CODE
LOWintegration/python/test_float_binary.py129async def test_float_special_values(conns):CODE
LOWintegration/python/test_float_binary.py165async def test_float_vs_numeric_difference(conns):CODE
LOWintegration/python/test_float_binary.py205async def test_float_binary_roundtrip(conns):CODE
LOWintegration/python/test_session_mode.py29async def async_session_conn_no_search_path():CODE
LOWintegration/python/test_session_mode.py40def test_session_simple_queries():CODE
LOWintegration/python/test_session_mode.py87def test_session_transactions():CODE
LOWintegration/python/test_session_mode.py125def test_session_transaction_set_local():CODE
LOWintegration/python/test_session_mode.py138def test_session_search_path_visible():CODE
LOWintegration/python/test_session_mode.py150def test_session_multiple_statements_in_transaction():CODE
LOWintegration/python/test_session_mode.py200def test_no_search_path_cross_shard_insert_blocked():CODE
LOWintegration/python/test_session_mode.py212def test_no_search_path_cross_shard_update_blocked():CODE
LOWintegration/python/test_session_mode.py223async def test_async_session_simple_queries():CODE
LOWintegration/python/test_session_mode.py233async def test_async_session_ddl_and_dml():CODE
LOWintegration/python/test_session_mode.py269async def test_async_session_transactions():CODE
LOWintegration/python/test_session_mode.py306async def test_async_session_transaction_set_local():CODE
LOWintegration/python/test_session_mode.py318async def test_async_session_search_path_visible():CODE
LOWintegration/python/test_session_mode.py328async def test_async_session_multiple_statements_in_transaction():CODE
LOWintegration/python/test_session_mode.py351async def test_no_search_path_session_mode():CODE
LOWintegration/python/test_session_mode.py361async def test_unrecognized_aggregate_function_works_on_schema_based_sharding():CODE
LOWintegration/python/test_psycopg2.py102def test_transaction_reads_explicit(conn_reads, conn_writes):CODE
LOWintegration/prefer_primary/test_prefer_primary.py37async def test_default_routes_to_primary(conn):CODE
LOWintegration/prefer_primary/test_prefer_primary.py44async def test_session_set_replica_routes_to_replica(conn):CODE
LOWintegration/prefer_primary/test_prefer_primary.py52async def test_session_reset_back_to_primary(conn):CODE
LOWintegration/prefer_primary/test_prefer_primary.py63async def test_query_comment_routes_to_replica(conn):CODE
LOWintegration/two_pc_crash_safety/rspec_helper.rb109def wait_for_no_prepared_xacts(timeout: 30)CODE
Fake / Example Data26 hits · 25 pts
SeverityFileLineSnippetContext
LOWintegration/load_balancer/test_lb_asyncpy.py30 """, 1, "test@test.com", datetime.now(), json.dumps({"banned": False}))STRING
LOWintegration/load_balancer/test_lb_asyncpy.py35 assert row[1] == "test@test.com"STRING
LOWintegration/load_balancer/test_lb_asyncpy.py41 assert row[0][1] == "test@test.com"STRING
LOWintegration/python/test_sqlalchemy.py129 Sharded(id=1, value="test@test.com"),CODE
LOWintegration/rust/tests/integration/distinct.rs14 for email in ["test@test.com", "apples@test.com"] {CODE
LOWintegration/rust/tests/integration/distinct.rs52 vec!["apples@test.com".to_string(), "test@test.com".to_string()]CODE
LOWintegration/schema_sync/ecommerce_schema.sql952('admin@example.com', 'admin', '$2a$10$abcdefghijklmnopqrstuv', 'Admin', 'User', '+1234567892', '1980-01-01', 'active', CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs39 Parameter::new("test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs56 ("1".as_bytes(), "test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs84 Parameter::new("test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs95 ("1".as_bytes(), "test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs116 "INSERT INTO test (id, email) VALUES (1, 'test@test.com'), (2, 'test2@test.com') RETURNING *",CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs125 "INSERT INTO test (id, email) VALUES (1, 'test@test.com') RETURNING *"CODE
LOWpgdog/src/frontend/router/parser/column.rs270 let result = parse("INSERT INTO my_table (id, email) VALUES (1, 'test@test.com')").unwrap();CODE
LOWpgdog/src/frontend/router/parser/column.rs291 let query = parse("INSERT INTO my_table (id, email) VALUES (1, 'test@test.com')").unwrap();CODE
LOWpgdog/src/frontend/router/parser/query/explain.rs236 &[b"11", b"test@test.com"],CODE
LOWpgdog/src/frontend/router/parser/query/explain.rs335 &[b"1", b"test@test.com"],CODE
LOWpgdog/src/frontend/router/parser/query/test/mod.rs214 ["11".as_bytes(), "test@test.com".as_bytes()]CODE
LOW…/src/frontend/router/parser/query/test/test_special.rs153 &[Parameter::new(b"5"), Parameter::new(b"test@test.com")],CODE
LOWpgdog/src/frontend/router/parser/query/test/test_dml.rs18 &[Parameter::new(b"11"), Parameter::new(b"test@test.com")],CODE
LOWpgdog/src/frontend/router/parser/query/test/test_dml.rs80 &[Parameter::new(b"1"), Parameter::new(b"test@test.com")],CODE
LOW…ntend/router/parser/query/test/test_schema_sharding.rs242 Query::new("INSERT INTO shard_0.sharded (id, email) VALUES (999, 'test@test.com')").into(),CODE
LOW…dog/src/backend/replication/logical/subscriber/copy.rs446 let email = Data::Column(Bytes::copy_from_slice("test@test.com".as_bytes()));CODE
LOWpgdog/src/backend/pool/connection/buffer.rs303 let emails = ["test@test.com", "admin@test.com"];CODE
LOWpgdog/src/backend/pool/connection/buffer.rs582 for email in ["test@test.com", "apples@test.com", "domain@test.com"] {CODE
LOWpgdog/src/backend/pool/connection/buffer.rs616 for email in ["test@test.com", "apples@test.com", "domain@test.com"] {CODE
Verbosity Indicators9 hits · 17 pts
SeverityFileLineSnippetContext
LOWintegration/copy_data/commit_sync/run.sh81# Step 1: load source schema + data, and create the destination table empty on each shard.COMMENT
LOWintegration/copy_data/commit_sync/run.sh88# Step 2: start toxiproxy and create one proxy per shard (one severable link each).COMMENT
LOWintegration/copy_data/commit_sync/run.sh101# Step 3: size the toxic to let every data byte through and sever only the trailingCOMMENT
LOWintegration/copy_data/commit_sync/run.sh118# Step 4: sever shard 2 at its CopyDone, run data-sync in the background, then heal it whileCOMMENT
LOWintegration/copy_data/commit_sync/run.sh145# Step 5: the retry must recover. data-sync should exit cleanly and every shard shouldCOMMENT
LOWpgdog/src/frontend/client/mod.rs254 // Get the password. We always need it because we need to check ifCOMMENT
LOWpgdog/src/backend/pool/taken.rs185 // Step 1: take A.COMMENT
LOWpgdog/src/backend/pool/taken.rs189 // Step 3: F retakes with B before A's deferred check-in fires.COMMENT
LOWpgdog/src/backend/pool/taken.rs194 // Step 4: deferred check-in for A. Must NOT touch F's entry,COMMENT
Structural Annotation Overuse8 hits · 16 pts
SeverityFileLineSnippetContext
LOWintegration/copy_data/commit_sync/run.sh81# Step 1: load source schema + data, and create the destination table empty on each shard.COMMENT
LOWintegration/copy_data/commit_sync/run.sh88# Step 2: start toxiproxy and create one proxy per shard (one severable link each).COMMENT
LOWintegration/copy_data/commit_sync/run.sh101# Step 3: size the toxic to let every data byte through and sever only the trailingCOMMENT
LOWintegration/copy_data/commit_sync/run.sh118# Step 4: sever shard 2 at its CopyDone, run data-sync in the background, then heal it whileCOMMENT
LOWintegration/copy_data/commit_sync/run.sh145# Step 5: the retry must recover. data-sync should exit cleanly and every shard shouldCOMMENT
LOWpgdog/src/backend/pool/taken.rs185 // Step 1: take A.COMMENT
LOWpgdog/src/backend/pool/taken.rs189 // Step 3: F retakes with B before A's deferred check-in fires.COMMENT
LOWpgdog/src/backend/pool/taken.rs194 // Step 4: deferred check-in for A. Must NOT touch F's entry,COMMENT
Deep Nesting15 hits · 15 pts
SeverityFileLineSnippetContext
LOWintegration/copy_data/loader/loader.py132CODE
LOWintegration/copy_data/loader/loader.py188CODE
LOWintegration/copy_data/loader/loader.py237CODE
LOWintegration/copy_data/loader/loader.py292CODE
LOWintegration/copy_data/loader/loader.py357CODE
LOWintegration/python/test_numeric_binary.py9CODE
LOWintegration/python/test_sqlalchemy.py232CODE
LOWintegration/python/test_sqlalchemy.py280CODE
LOWintegration/python/test_psycopg.py115CODE
LOWintegration/python/test_float_binary.py249CODE
LOWintegration/logical/gutenberg.py25CODE
LOWintegration/sql/lib.py239CODE
LOWintegration/sql/lib.py278CODE
LOWintegration/sql/lib.py358CODE
LOWpgdog/tests/vector/read_parquet.py17CODE
Unused Imports10 hits · 10 pts
SeverityFileLineSnippetContext
LOWintegration/copy_data/loader/loader.py11CODE
LOWintegration/copy_data/loader/loader.py15CODE
LOWintegration/python/test_numeric_binary.py1CODE
LOWintegration/python/test_numeric_binary.py5CODE
LOWintegration/python/test_numeric_sorting.py5CODE
LOWintegration/python/test_sqlalchemy.py1CODE
LOWintegration/python/test_float_binary.py3CODE
LOWintegration/sql/lib.py1CODE
LOWpgdog/tests/vector/read_parquet.py2CODE
LOWpgdog/tests/vector/read_parquet.py8CODE
Excessive Try-Catch Wrapping8 hits · 6 pts
SeverityFileLineSnippetContext
LOWintegration/load_balancer/test_lb_asyncpy.py77 except Exception as e:STRING
LOWintegration/python/test_asyncpg.py35 except Exception as e:CODE
LOWintegration/python/test_asyncpg.py320 except Exception as e:CODE
LOWintegration/python/test_asyncpg.py599 except Exception as e:STRING
LOWintegration/python/test_sqlalchemy.py544 except Exception as e:STRING
LOWintegration/python/test_idle_in_transaction.py72 except Exception as e:CODE
LOWintegration/python/test_session_mode.py294 except Exception:CODE
LOWintegration/complex/cancel_query/run.py55 except Exception:CODE
Example Usage Blocks3 hits · 4 pts
SeverityFileLineSnippetContext
LOWbenches/resharding/copy_data/run.sh11# Usage:COMMENT
LOWbenches/resharding/replication/run.sh8# Usage:COMMENT
LOWbenches/resharding/toxi/setup.sh17# Usage:COMMENT
Self-Referential Comments1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUMintegration/two_pc_crash_safety/setup.sh6# Create the per-shard table so cross-shard transactions have somethingCOMMENT
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOW…dog/src/backend/replication/logical/subscriber/copy.rs215 // TODO: implement complete 2pc to copy data to minimize chances of partial commits even moreCOMMENT
Modern Structural Boilerplate1 hit · 1 pts
SeverityFileLineSnippetContext
LOWintegration/sql/lib.py452__all__ = [CODE