AI Slop Code Risk Monitor

pgdogdev/pgdog

SlopCodeMonitor badge for pgdogdev/pgdog Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

PostgreSQL connection pooler, load balancer and database sharder.

3.1 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for pgdogdev/pgdog, a Rust project with 5,592 GitHub stars. SynthScan examined 229,965 lines of code across 1407 source files, recording 490 pattern matches distributed across 15 syntactic categories. The legacy adjusted pattern signal is 3.1 (Low pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

3.1
Adjusted Signal
3.1
Raw Pattern Score
100%
Time Factor
2026-10-31
Last Push
5.6K
Stars
Rust
Language
230.0K
Lines of Code
1.4K
Files
490
Pattern Hits
2026-10-31
Scan Date
0.01
HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 7.6/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 351 finding(s).

Hallucinated Dependency & Supply Chain Risk 0.7/100 · LOW

Are imports declared and package/API names verified? 34 finding(s).

Agent Over-Engineering Ratio 8.1/100 · LOW

Are wrappers, guards, and repeated structures necessary? 171 finding(s).

PR Review Velocity Impact 14.5/100 · LOW

Which changes need focused human review? 490 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 0HIGH 12MEDIUM 85LOW 393

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 490 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Decorative Section Separators83 hits · 262 pts
SeverityFileLineSnippetContext
MEDIUMpgdog-postgres-types/src/array.rs462 // ── Text decode ──────────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs567 // ── Text roundtrip ───────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs597 // ── Cross-format encode ──────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs634 // ── Binary roundtrip ─────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs661 // ── Rejection / validation ───────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs761 // ── Equality ─────────────────────────────────────────────────────COMMENT
MEDIUMpgdog-postgres-types/src/array.rs771 // ── Datum integration ────────────────────────────────────────────COMMENT
MEDIUM⚡integration/pgdog.toml241# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml250# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml260# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml270# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml280# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml290# ------------------------------------------------------------------------------COMMENT
MEDIUM⚡integration/pgdog.toml299# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml1# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml50# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml63# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml131# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml205# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml318# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml337# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml364# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml389# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml406# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml425# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml458# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml482# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml489# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/pgdog.toml546# ------------------------------------------------------------------------------COMMENT
MEDIUMintegration/rust/tests/integration/cancel.rs127 // ── Cancel connection 1 ────────────────────────────────────────────────COMMENT
MEDIUMintegration/rust/tests/integration/cancel.rs145 // ── Cancel connection 2 ────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/net/messages/replication/logical/update.rs127 // ── 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.rs172 // ── AssumeRolePlan::new (cross-account RDS IAM) ──────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/rds_iam.rs204 // ── infer_region_from_rds_host ───────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/rds_iam.rs237 // ── resolve_region ───────────────────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs198 // ── credentials(): config-level error cases ───────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs224 // ── credentials(): HTTP responses ─────────────────────────────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs319 // ── static_backend_credentials(): config-level error cases ────────────────COMMENT
MEDIUMpgdog/src/backend/auth/vault.rs347 // ── static_backend_credentials(): HTTP responses ───────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs510 // ── Routing helpers ────────────────────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs521 // ── Shape-cache helpers ──────────────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs733 // ── FULL identity path ──────────────────────────────────────────────COMMENT
MEDIUM…g/src/backend/replication/logical/subscriber/stream.rs774 // ── DEFAULT / INDEX path ────────────────────────────────────────────COMMENT
MEDIUM…og/src/backend/replication/logical/subscriber/tests.rs516// ── State machine tests ─────────────────────────────────────────────COMMENT
MEDIUM…og/src/backend/replication/logical/subscriber/tests.rs602// ── Relation handling tests ─────────────────────────────────────────COMMENT
MEDIUM…og/src/backend/replication/logical/subscriber/tests.rs758// ── Data flow tests ─────────────────────────────────────────────────COMMENT
MEDIUM…og/src/backend/replication/logical/subscriber/tests.rs1141// ── CopyData round-trip tests ───────────────────────────────────────COMMENT
23 more matches not shown…
Over-Commented Block246 hits · 234 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: disabledCOMMENT
LOWexample.pgdog.toml161# Default: textCOMMENT
LOWexample.pgdog.toml181log_dedup_threshold = 0COMMENT
LOWexample.pgdog.toml201# Default: unlimitedCOMMENT
LOWexample.pgdog.toml221# cache used for query routing and sharding.COMMENT
LOWexample.pgdog.toml241# How long to wait for Postgres server connections to be created by the pool beforeCOMMENT
LOWexample.pgdog.toml261#COMMENT
LOWexample.pgdog.toml281client_idle_timeout = 60_000COMMENT
LOWexample.pgdog.toml301# Default: disabledCOMMENT
LOWexample.pgdog.toml321user = "admin"COMMENT
LOWexample.pgdog.toml341#COMMENT
LOWexample.pgdog.toml461# [multi_tenant]COMMENT
LOWexample.pgdog.toml481# sets `server_auth = "vault_dynamic"` or `"vault_static"`, or configuresCOMMENT
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.rs221 ///COMMENT
LOWpgdog-config/src/core.rs241 pub databases: Vec<Database>,COMMENT
LOWpgdog-config/src/core.rs261 #[serde(default)]COMMENT
LOWpgdog-config/src/core.rs281COMMENT
LOWpgdog-config/src/pooling.rs61/// <https://docs.pgdog.dev/configuration/pgdog.toml/general/#pooler_mode>COMMENT
LOWpgdog-config/src/database.rs41 }COMMENT
LOWpgdog-config/src/database.rs121}COMMENT
LOWpgdog-config/src/database.rs141 ///COMMENT
LOWpgdog-config/src/database.rs161 ///COMMENT
LOWpgdog-config/src/database.rs181 pub min_pool_size: Option<usize>,COMMENT
LOWpgdog-config/src/database.rs201 ///COMMENT
LOWpgdog-config/src/users.rs21pub struct Plugin {COMMENT
LOWpgdog-config/src/users.rs261 }COMMENT
LOWpgdog-config/src/users.rs281 /// Name of the user. Clients that connect to PgDog will need to use this username.COMMENT
LOWpgdog-config/src/users.rs301 #[serde(default)]COMMENT
LOWpgdog-config/src/users.rs321 ///COMMENT
LOWpgdog-config/src/users.rs341 /// e.g. `database/creds/my-role` for `server_auth = "vault_dynamic"` orCOMMENT
LOWpgdog-config/src/users.rs361 /// Lock timeout.COMMENT
LOWpgdog-config/src/users.rs381 /// Sharding target database for replication.COMMENT
LOWpgdog-config/src/users.rs401 pub two_phase_commit_auto: Option<bool>,COMMENT
LOWpgdog-config/src/users.rs501 #[serde(default = "Admin::name")]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 schema: Option<String>,COMMENT
LOWpgdog-config/src/sharding.rs61 /// Path to a JSON file containing centroid vectors. This is useful when centroids are large (1000+ dimensions).COMMENT
LOWpgdog-config/src/sharding.rs81 /// The hash function to use for sharding.COMMENT
LOWpgdog-config/src/sharding.rs101 ///COMMENT
LOWpgdog-config/src/sharding.rs121 /// **Note:** With `shard`, the query must return a number between 0 andCOMMENT
LOWpgdog-config/src/sharding.rs161/// A single value-to-shard routing rule within a table's `mapping`.COMMENT
LOWpgdog-config/src/sharding.rs181COMMENT
LOWpgdog-config/src/sharding.rs221 /// Variable-length text.COMMENT
LOWpgdog-config/src/sharding.rs281}COMMENT
LOWpgdog-config/src/sharding.rs481pub enum QueryParserEngine {COMMENT
LOWpgdog-config/src/otel.rs21/// to the configured URL.COMMENT
LOWpgdog-config/src/otel.rs41 ///COMMENT
LOWpgdog-config/src/otel.rs61 /// Datadog API key. Convenience shorthand that adds a `DD-API-KEY` headerCOMMENT
186 more matches not shown…
Hyper-Verbose Identifiers66 hits · 62 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_set_shard_allows_omnisharded_write():STRING
LOWintegration/python/test_asyncpg.py637async def test_schema_sharding_search_path():STRING
LOWintegration/python/test_asyncpg.py668async def test_pgdog_role_selection():STRING
LOWintegration/python/test_asyncpg.py697async def test_omni_time_function_unnamed_statement():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_qualified_advisory_locks.py8def test_qualified_advisory_lock_keeps_session_ownership(extended):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_copy_cancel_slots.py29def test_cancel_copy_data_removes_replication_slots(blocked_copy):CODE
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_listen_then_query():CODE
LOWintegration/python/test_psycopg.py181def test_pipeline_many_queries():CODE
LOWintegration/python/test_psycopg.py204def test_pipeline_executemany():CODE
LOWintegration/python/test_psycopg.py234def test_pipeline_transaction():CODE
LOWintegration/python/test_psycopg.py258def test_pipeline_fetch_after_exit():CODE
LOWintegration/python/test_psycopg.py304def test_pipeline_query_then_nonpipeline():CODE
LOWintegration/python/test_psycopg.py326def test_pipeline_error_recovery():CODE
LOWintegration/python/test_psycopg.py350def test_pipeline_multiple_errors():CODE
LOWintegration/python/test_psycopg.py372def test_server_cursor_with_shard_pin():CODE
LOWintegration/python/test_psycopg.py388def test_describe_portal_with_shard_pin():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/python/alembic/env.py15def _patch_dialect_initialize_wrapper(CODE
LOWintegration/python/alembic/test_migration.py27def conservative_read_write_strategy():CODE
LOWintegration/python/alembic/test_migration.py65def test_alembic_migration_on_schema_shard(schema):CODE
LOWintegration/complex/rds_iam/test_rds_iam.py26def test_generate_rds_iam_token(rds_iam_token):CODE
6 more matches not shown…
Empty Error Handlers11 hits · 55 pts
SeverityFileLineSnippetContext
HIGHintegration/python/test_asyncpg.py50except asyncpg.exceptions.UndefinedTableError:CODE
HIGHintegration/python/test_asyncpg.py131except asyncpg.exceptions.DuplicateTableError:CODE
HIGHintegration/python/test_asyncpg.py185except asyncpg.exceptions.UndefinedTableError:CODE
HIGHintegration/python/test_asyncpg.py375except asyncpg.exceptions.UndefinedTableError:CODE
HIGHintegration/python/test_asyncpg.py99except asyncpg.exceptions.UndefinedColumnError:CODE
HIGHintegration/python/test_asyncpg.py111except asyncpg.exceptions.UndefinedColumnError:CODE
HIGHintegration/python/test_psycopg.py129except psycopg.Error:CODE
HIGHintegration/python/test_float_binary.py38except asyncpg.exceptions.UndefinedTableError:CODE
HIGHintegration/python/test_session_mode.py294except Exception:CODE
HIGHintegration/complex/cancel_query/run.py55except Exception:CODE
HIGHintegration/server/shutdown/clients.py77except psycopg.OperationalError:CODE
Fake / Example Data25 hits · 24 pts
SeverityFileLineSnippetContext
LOW⚡integration/load_balancer/test_lb_asyncpy.py30 """, 1, "test@test.com", datetime.now(), json.dumps({"banned": False}))STRING
LOW⚡integration/load_balancer/test_lb_asyncpy.py35 assert row[1] == "test@test.com"STRING
LOW⚡integration/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.sql971('admin@example.com', 'admin', '$2a$10$abcdefghijklmnopqrstuv', 'Admin', 'User', '+1234567892', '1980-01-01', 'active', CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs46 Parameter::new("test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs63 ("1".as_bytes(), "test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs91 Parameter::new("test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs102 ("1".as_bytes(), "test@test.com".as_bytes()),CODE
LOW…ntend/client/query_engine/test/rewrite_insert_split.rs123 "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.rs131 ProtocolMessage::Query(query) if query.query() == "INSERT INTO test (id, email) VALUES (1, 'test@test.com') RETUCODE
LOWpgdog/src/frontend/router/parser/column.rs141 let result = parse("INSERT INTO my_table (id, email) VALUES (1, 'test@test.com')").unwrap();CODE
LOWpgdog/src/frontend/router/parser/query/explain.rs174 &[b"11", b"test@test.com"],CODE
LOWpgdog/src/frontend/router/parser/query/explain.rs273 &[b"1", b"test@test.com"],CODE
LOWpgdog/src/frontend/router/parser/query/test/mod.rs271 ["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.rs469 let email = Data::Column(Bytes::copy_from_slice("test@test.com".as_bytes()));CODE
LOWpgdog/src/backend/pool/connection/buffer.rs343 let emails = ["test@test.com", "admin@test.com"];CODE
LOWpgdog/src/backend/pool/connection/buffer.rs674 for email in ["test@test.com", "apples@test.com", "domain@test.com"] {CODE
LOWpgdog/src/backend/pool/connection/buffer.rs708 for email in ["test@test.com", "apples@test.com", "domain@test.com"] {CODE
Verbosity Indicators9 hits · 17 pts
SeverityFileLineSnippetContext
LOW⚡integration/copy_data/commit_sync/run.sh81# Step 1: load source schema + data, and create the destination table empty on each shard.COMMENT
LOW⚡integration/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.rs316 // Get the password. We always need it because we need to check ifCOMMENT
LOW⚡pgdog/src/backend/pool/taken.rs214 // Step 1: take A.COMMENT
LOW⚡pgdog/src/backend/pool/taken.rs218 // Step 3: F retakes with B before A's deferred check-in fires.COMMENT
LOW⚡pgdog/src/backend/pool/taken.rs223 // Step 4: deferred check-in for A. Must NOT touch F's entry,COMMENT
Deep Nesting16 hits · 16 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_timestamp_infinity.py20CODE
LOWintegration/python/test_psycopg.py115CODE
LOWintegration/python/test_float_binary.py249CODE
LOWintegration/logical/gutenberg.py25CODE
LOWintegration/two_pc/crash_recovery.py240CODE
LOWintegration/sql/lib.py242CODE
LOWintegration/sql/lib.py281CODE
LOWintegration/sql/lib.py361CODE
Structural Annotation Overuse8 hits · 16 pts
SeverityFileLineSnippetContext
LOW⚡integration/copy_data/commit_sync/run.sh81# Step 1: load source schema + data, and create the destination table empty on each shard.COMMENT
LOW⚡integration/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
LOW⚡pgdog/src/backend/pool/taken.rs214 // Step 1: take A.COMMENT
LOW⚡pgdog/src/backend/pool/taken.rs218 // Step 3: F retakes with B before A's deferred check-in fires.COMMENT
LOW⚡pgdog/src/backend/pool/taken.rs223 // Step 4: deferred check-in for A. Must NOT touch F's entry,COMMENT
Unused Imports9 hits · 9 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/two_pc/crash_recovery.py4CODE
LOWintegration/sql/lib.py1CODE
Excessive Try-Catch Wrapping10 hits · 9 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
LOWintegration/two_pc/crash_recovery.py306 except Exception as error:STRING
MEDIUMintegration/two_pc/crash_recovery.py302def main() -> int:CODE
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHpgdog/src/net/decoder.rs12 /// Expected result column formats, as requested by [`Bind`] sent by client.COMMENT
Example Usage Blocks3 hits · 4 pts
SeverityFileLineSnippetContext
LOWbenches/resharding/copy_data/run.sh11# Usage:COMMENT
LOWbenches/resharding/replication/run.sh12# Usage:COMMENT
LOWbenches/resharding/toxi/setup.sh24# Usage:COMMENT
AI Slop Vocabulary1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUM.cargo/config.toml36# Test-harness threads: libtest/nextest run #[tokio::test] bodies onCOMMENT
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOW…dog/src/backend/replication/logical/subscriber/copy.rs248 // 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.py455__all__ = [CODE