records: Add example about library use

.github/dependabot.yml

@@ -112,6 +112,11 @@ updates:
     schedule:
       interval: "daily"
 
+  - directory: "/framework/records"
+    package-ecosystem: "pip"
+    schedule:
+      interval: "daily"
+
   - directory: "/framework/streamlit"
     package-ecosystem: "pip"
     schedule:

.github/workflows/framework-records.yml

@@ -0,0 +1,74 @@
+name: records
+
+on:
+  pull_request:
+    branches: ~
+    paths:
+    - '.github/workflows/framework-records.yml'
+    - 'framework/records/**'
+    - '/requirements.txt'
+  push:
+    branches: [ main ]
+    paths:
+    - '.github/workflows/framework-records.yml'
+    - 'framework/records/**'
+    - '/requirements.txt'
+
+  # Allow job to be triggered manually.
+  workflow_dispatch:
+
+  # Run job each night after CrateDB nightly has been published.
+  schedule:
+    - cron: '0 3 * * *'
+
+# Cancel in-progress jobs when pushing to the same branch.
+concurrency:
+  cancel-in-progress: true
+  group: ${{ github.workflow }}-${{ github.ref }}
+
+jobs:
+  test:
+    name: "
+     Python: ${{ matrix.python-version }}
+     CrateDB: ${{ matrix.cratedb-version }}
+     on ${{ matrix.os }}"
+    runs-on: ${{ matrix.os }}
+    strategy:
+      fail-fast: false
+      matrix:
+        os: [ 'ubuntu-latest' ]
+        python-version: [ '3.9', '3.13' ]
+        cratedb-version: [ 'nightly' ]
+
+    services:
+      cratedb:
+        image: crate/crate:${{ matrix.cratedb-version }}
+        ports:
+          - 4200:4200
+          - 5432:5432
+        env:
+          CRATE_HEAP_SIZE: 4g
+
+    steps:
+
+      - name: Acquire sources
+        uses: actions/checkout@v4
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: ${{ matrix.python-version }}
+          architecture: x64
+          cache: 'pip'
+          cache-dependency-path: |
+            requirements.txt
+            framework/records/requirements.txt
+            framework/records/requirements-dev.txt
+
+      - name: Install utilities
+        run: |
+          pip install -r requirements.txt
+
+      - name: Validate framework/records
+        run: |
+          ngr test --accept-no-venv framework/records

framework/records/README.md

@@ -0,0 +1,55 @@
+# Verify the `records` library with CrateDB
+
+Records: SQL for Humans™
+
+## About
+
+This folder includes software integration tests for verifying
+that the [Records] Python library works well together with [CrateDB].
+
+Records is a very simple, but powerful, library for making raw SQL
+queries to most relational databases. It uses [SQLAlchemy].
+
+Records is intended for report-style exports of database queries, and
+has not yet been optimized for extremely large data dumps.
+
+## What's Inside
+
+A basic test case that reads CrateDB's `sys.summits` table through
+`records`, after connecting to CrateDB using SQLAlchemy Core.
+
+## Install
+
+Set up sandbox and install packages.
+```bash
+pip install uv
+uv venv .venv
+source .venv/bin/activate
+uv pip install -r requirements.txt -r requirements-test.txt
+```
+
+## Synopsis
+```shell
+pip install --upgrade records sqlalchemy-cratedb
+```
+```python
+from pprint import pprint
+import records
+
+db = records.Database("crate://")
+rows = db.query("SELECT * FROM sys.summits ORDER BY height DESC LIMIT 3")
+data = rows.all()
+pprint(data)
+```
+
+## Usage
+
+Run integration tests.
+```bash
+pytest
+```
+
+
+[CrateDB]: https://cratedb.com/database
+[Records]: https://pypi.org/project/records/
+[SQLAlchemy]: https://www.sqlalchemy.org/

framework/records/example_all_types.py

@@ -0,0 +1,146 @@
+"""
+Using `records` with CrateDB: All data types.
+
+An end-to-end lifecycle, defining a table, inserting data, and querying it.
+This example uses all data types supported by CrateDB.
+
+- https://pypi.org/project/records/
+- https://cratedb.com/docs/crate/reference/en/latest/general/ddl/data-types.html#supported-types
+"""
+
+from copy import deepcopy
+
+import pytest
+import records
+
+
+# The record that is inserted into the database.
+RECORD_IN = dict(
+    null_integer=None,
+    integer=42,
+    bigint=42,
+    float=42.42,
+    double=42.42,
+    decimal=42.42,
+    bit="01010101",
+    bool=True,
+    text="foobar",
+    char="foo",
+    timestamp_tz="1970-01-02T00:00:00+01:00",
+    timestamp_notz="1970-01-02T00:00:00",
+    ip="127.0.0.1",
+    array=["foo", "bar"],
+    object={"for": "bar"},
+    geopoint=[85.43, 66.23],
+    geoshape="POLYGON ((5 5, 10 5, 10 10, 5 10, 5 5))",
+    float_vector=[1.0, 2.0, 3.0],
+)
+
+# When querying it, a few values will be canonicalized.
+RECORD_OUT = deepcopy(RECORD_IN)
+RECORD_OUT.update(
+    dict(
+        bit="B'01010101'",
+        char="foo  ",
+        timestamp_tz=82800000,
+        timestamp_notz=86400000,
+        geopoint=[pytest.approx(85.43), pytest.approx(66.23)],
+        geoshape={
+            "coordinates": [
+                [[5.0, 5.0], [5.0, 10.0], [10.0, 10.0], [10.0, 5.0], [5.0, 5.0]]
+            ],
+            "type": "Polygon",
+        },
+    )
+)
+
+
+def records_ddl_dml_dql():
+    """
+    Validate all types of CrateDB.
+
+    https://cratedb.com/docs/crate/reference/en/latest/general/ddl/data-types.html#supported-types
+    """
+    db = records.Database("crate://", echo=True)
+
+    # DDL
+    db.query("DROP TABLE IF EXISTS testdrive.example;")
+    db.query("""
+    CREATE TABLE testdrive.example (
+        -- Numeric types
+        null_integer INT,
+        integer INT,
+        bigint BIGINT,
+        float FLOAT,
+        double DOUBLE,
+        decimal DECIMAL(8, 2),
+        -- Other scalar types
+        bit BIT(8),
+        bool BOOLEAN,
+        text TEXT,
+        char CHARACTER(5),
+        timestamp_tz TIMESTAMP WITH TIME ZONE,
+        timestamp_notz TIMESTAMP WITHOUT TIME ZONE,
+        ip IP,
+        -- Container types
+        "array" ARRAY(STRING),
+        "object" OBJECT(DYNAMIC),
+        -- Geospatial types
+        geopoint GEO_POINT,
+        geoshape GEO_SHAPE,
+        -- Vector type
+        "float_vector" FLOAT_VECTOR(3)
+    );
+    """)
+
+    # DML
+    db.query(
+        """
+    INSERT INTO testdrive.example (
+        null_integer,
+        integer,
+        bigint,
+        float,
+        double,
+        decimal,
+        bit,
+        bool,
+        text,
+        char,
+        timestamp_tz,
+        timestamp_notz,
+        ip,
+        "array",
+        "object",
+        geopoint,
+        geoshape,
+        float_vector
+    ) VALUES (
+        :null_integer,
+        :integer,
+        :bigint,
+        :float,
+        :double,
+        :decimal,
+        :bit,
+        :bool,
+        :text,
+        :char,
+        :timestamp_tz,
+        :timestamp_notz,
+        :ip,
+        :array,
+        :object,
+        :geopoint,
+        :geoshape,
+        :float_vector
+    );
+    """,
+        **RECORD_IN,
+    )
+
+    # DQL
+    db.query("REFRESH TABLE testdrive.example")
+    rows = db.query("SELECT * FROM testdrive.example")
+    data = rows.all()
+    return data

framework/records/example_basic.py

@@ -0,0 +1,56 @@
+"""
+Using `records` with CrateDB: Basic usage.
+
+A few basic operations using the `records` library with CrateDB.
+
+- https://pypi.org/project/records/
+"""
+
+import records
+
+
+def records_select_sys_summits():
+    """
+    Query CrateDB's built-in `sys.summits` table.
+    :return:
+    """
+    db = records.Database("crate://", echo=True)
+    rows = db.query("SELECT * FROM sys.summits ORDER BY height DESC LIMIT 3")
+    data = rows.all()
+    return data
+
+
+def records_export_sys_summits_pandas():
+    """
+    Query CrateDB's built-in `sys.summits` table, returning a pandas dataframe.
+    """
+    db = records.Database("crate://", echo=True)
+    rows = db.query("SELECT * FROM sys.summits ORDER BY height DESC LIMIT 3")
+    data = rows.export("df")
+    return data
+
+
+def records_export_sys_summits_csv():
+    """
+    Query CrateDB's built-in `sys.summits` table, returning CSV.
+    """
+    db = records.Database("crate://", echo=True)
+    rows = db.query("SELECT * FROM sys.summits ORDER BY height DESC LIMIT 3")
+    data = rows.export("csv")
+    return data
+
+
+def records_get_table_names():
+    """
+    Inquire table names of the system schema `sys`.
+    """
+    db = records.Database("crate://?schema=sys", echo=True)
+    table_names = db.get_table_names()
+    return table_names
+
+
+if __name__ == "__main__":
+    print(records_select_sys_summits())
+    print(records_export_sys_summits_pandas())
+    print(records_export_sys_summits_csv())
+    print(records_get_table_names())

framework/records/pyproject.toml

@@ -0,0 +1,12 @@
+[tool.pytest.ini_options]
+minversion = "2.0"
+addopts = """
+  -rfEXs -p pytester --strict-markers --verbosity=3
+  --capture=no
+  """
+log_level = "DEBUG"
+log_cli_level = "DEBUG"
+testpaths = ["*.py"]
+xfail_strict = true
+markers = [
+]

framework/records/requirements-test.txt

@@ -0,0 +1 @@
+pytest<9

framework/records/requirements.txt

@@ -0,0 +1,3 @@
+records<0.7
+sqlalchemy-cratedb<0.41
+tablib[pandas]