Daniele Varrazzo dvarrazzo

## wait_async_ebf8d9d4.py
"""The wait_async() implementation before the #1331 optimisation.

Copied verbatim from `git show ebf8d9d4:psycopg/psycopg/waiting.py`, which is
the merge of #1411, right after the `timeout` parameter refactoring: the first
commit whose signature matches what `AsyncConnection.wait()` passes today, so
no adaptation was needed. Only the function name differs.

It is NOT the 3.3.5 code: that one has no `timeout` parameter at all and would
raise a TypeError when called by the current connection classes.

## psycopg3_logical_replication.py
"""
PostgreSQL Logical Replication for psycopg3

A production-ready implementation of PostgreSQL logical replication using psycopg3.
Works around psycopg3's missing replication support by using a raw socket bridge.

Author: Richard Brandes
Date: October 2025
License: MIT

## bench-fetchall.py
import statistics as st
from time import sleep, monotonic
from argparse import ArgumentParser, Namespace

import psycopg
import psycopg2
from psycopg import sql

DSN = "dbname=psycopg3_test host=localhost sslmode=disable"

## walrusify.py
#!/usr/bin/env python
"""Convert a codebase to using the walrus operator.

Hint: in order to explore the AST of a module you can run:

    python -m ast path/to/module.py

"""

from __future__ import annotations

## dicttuple.py
class DictTuple(tuple):
    """Tuple class with added item getting by name.
    """
    def __new__(cls, d):
        rv = super().__new__(cls, d.values())
        rv._map = d
        return rv

    def __repr__(self):
        return f"{type(self).__qualname__}({self._map!r})"

## stream.mermaid

      
              1 file
            
          
              0 forks
            
          
                0 comments
              
            
              0 stars
            
          
                dvarrazzo
                / stream.mermaid
            
            
              Created
              May 1, 2022 19:41
            
              
                Flow diagram of a cursor.stream() iteration in psycopg 3
              
          
      Loading

      Sorry, something went wrong. Reload?
      Sorry, we cannot display this file.
      Sorry, this file is invalid so it cannot be displayed.
        
            Viewer requires iframe.
        
    
## tests.yaml
name: Tests

on:
  push:
    branches: [ master ]
  pull_request:
    branches: [ master ]

jobs:
  tests-python:

## dchost
#!/bin/bash

# Return the ip address for a container in docker-compose

set -euo pipefail
# set -x

if [[ "${1:-}" == "" ]]; then
    echo "usage: $0 container

## patch_db.py
#!/usr/bin/env python3
"""
Apply database patches.

Applied patches are recorded in the schema_patch table of the database.

The dsn to connect to defaults to a local one (empty connection string). It can
be chosen using the command line or an environment variable. Patches
application is interactive by default.

## ministan.py
r"""Implementation of a `stan`_\ -like XML description language.

.. _stan: http://www.kieranholland.com/code/documentation/nevow-stan/

An example XHTML page can be generated by:

.. python::

    def items():
        return [ T.li['foo'], T.li['bar'], T.li['baz'] ]
	"""The wait_async() implementation before the #1331 optimisation.

	Copied verbatim from `git show ebf8d9d4:psycopg/psycopg/waiting.py`, which is
	the merge of #1411, right after the `timeout` parameter refactoring: the first
	commit whose signature matches what `AsyncConnection.wait()` passes today, so
	no adaptation was needed. Only the function name differs.

	It is NOT the 3.3.5 code: that one has no `timeout` parameter at all and would
	raise a TypeError when called by the current connection classes.
	"""
	PostgreSQL Logical Replication for psycopg3

	A production-ready implementation of PostgreSQL logical replication using psycopg3.
	Works around psycopg3's missing replication support by using a raw socket bridge.

	Author: Richard Brandes
	Date: October 2025
	License: MIT
	import statistics as st
	from time import sleep, monotonic
	from argparse import ArgumentParser, Namespace

	import psycopg
	import psycopg2
	from psycopg import sql

	DSN = "dbname=psycopg3_test host=localhost sslmode=disable"
	#!/usr/bin/env python
	"""Convert a codebase to using the walrus operator.

	Hint: in order to explore the AST of a module you can run:

	python -m ast path/to/module.py

	"""

	from __future__ import annotations
	class DictTuple(tuple):
	"""Tuple class with added item getting by name.
	"""
	def __new__(cls, d):
	rv = super().__new__(cls, d.values())
	rv._map = d
	return rv

	def __repr__(self):
	return f"{type(self).__qualname__}({self._map!r})"
	name: Tests

	on:
	push:
	branches: [ master ]
	pull_request:
	branches: [ master ]

	jobs:
	tests-python:
	#!/bin/bash

	# Return the ip address for a container in docker-compose

	set -euo pipefail
	# set -x

	if [[ "${1:-}" == "" ]]; then
	echo "usage: $0 container
	#!/usr/bin/env python3
	"""
	Apply database patches.

	Applied patches are recorded in the schema_patch table of the database.

	The dsn to connect to defaults to a local one (empty connection string). It can
	be chosen using the command line or an environment variable. Patches
	application is interactive by default.
	r"""Implementation of a `stan`_\ -like XML description language.

	.. _stan: http://www.kieranholland.com/code/documentation/nevow-stan/

	An example XHTML page can be generated by:

	.. python::

	def items():
	return [ T.li['foo'], T.li['bar'], T.li['baz'] ]