Oct 24, 2025 · Oct 3, 2025 · Oct 3, 2025 · Oct 3, 2025 · Oct 3, 2025 · Oct 3, 2025
diff --git a/.github/workflows/coverage-check.yml → .github/workflows/code-coverage.yml b/.github/workflows/coverage-check.yml → .github/workflows/code-coverage.yml
 on: [pull_request, workflow_dispatch]

 jobs:
  coverage:
 test-with-coverage:
    runs-on: ubuntu-latest
    environment: azure-prod
    env:
      - name: Check out repository
        uses: actions/checkout@v4
        with:
          fetch-depth: 0  # Needed for coverage comparison
          fetch-depth: 0
          ref: ${{ github.event.pull_request.head.ref || github.ref_name }}
          repository: ${{ github.event.pull_request.head.repo.full_name ||github.repository }}
          repository: ${{ github.event.pull_request.head.repo.full_name || github.repository }}
      - name: Set up python
        id: setup-python
        uses: actions/setup-python@v5
      - name: Install library
        run: poetry install --no-interaction --all-extras
      #----------------------------------------------
      #run all tests
      #    run all tests with coverage
      #----------------------------------------------
      - name: Run tests with coverage
        continue-on-error:true
      - name: Runalltests with coverage
        continue-on-error:false
        run: |
          poetry run python -m pytest \
            tests/unit tests/e2e \
            --cov=src --cov-report=xml --cov-report=term -v
          poetry run pytest tests/unit tests/e2e \
            -n auto \
            --cov=src \
            --cov-report=xml \
            --cov-report=term \
            -v

      #----------------------------------------------
      #         check for coverage override
      #----------------------------------------------
            echo "Please ensure this override is justified and temporary"
          else
            echo "✅ Coverage checks enforced - minimum 85% required"
          fi
          fi

diff --git a/.github/workflows/integration.yml b/.github/workflows/integration.yml
      #              run test suite
      #----------------------------------------------
      - name: Run e2e tests
        run: poetry run python -m pytest tests/e2e
        run: poetry run python -m pytest tests/e2e -n auto
diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
 black = "^22.3.0"
 pytest-dotenv = "^0.5.2"
 pytest-cov = "^4.0.0"
 pytest-xdist = "^3.0.0"
 numpy = [
    { version = ">=1.16.6", python = ">=3.8,<3.11" },
    { version = ">=1.23.4", python = ">=3.11" },
diff --git a/tests/e2e/test_complex_types.py b/tests/e2e/test_complex_types.py
 import pytest
 from numpy import ndarray
 from typing import Sequence
 from uuid import uuid4

 from tests.e2e.test_driver import PySQLPytestTestCase

    def table_fixture(self, connection_details):
        self.arguments = connection_details.copy()
        """A pytest fixture that creates a table with a complex type, inserts a record, yields, and then drops the table"""

        table_name = f"pysql_test_complex_types_table_{str(uuid4()).replace('-', '_')}"
        self.table_name = table_name

        with self.cursor() as cursor:
            # Create the table
            cursor.execute(
                """
                CREATE TABLE IF NOT EXISTSpysql_test_complex_types_table (
 f"""
                CREATE TABLE IF NOT EXISTS{table_name} (
                    array_col ARRAY<STRING>,
                    map_col MAP<STRING, INTEGER>,
                    struct_col STRUCT<field1: STRING, field2: INTEGER>,
            )
            # Insert a record
            cursor.execute(
                """
                INSERT INTOpysql_test_complex_types_table
 f"""
                INSERT INTO{table_name}
                VALUES (
                    ARRAY('a', 'b', 'c'),
                    MAP('a', 1, 'b', 2, 'c', 3),
                """
            )
            try:
                yield
                yield table_name
            finally:
                # Clean up the table after the test
                cursor.execute("DELETE FROM pysql_test_complex_types_table")
                cursor.execute(f"DROP TABLE IF EXISTS {table_name}")

    @pytest.mark.parametrize(
        "field,expected_type",

        with self.cursor() as cursor:
            result = cursor.execute(
                "SELECT * FROMpysql_test_complex_types_table LIMIT 1"
 f"SELECT * FROM{table_fixture} LIMIT 1"
            ).fetchone()

        assert isinstance(result[field], expected_type)
            extra_params={"_use_arrow_native_complex_types": False}
        ) as cursor:
            result = cursor.execute(
                "SELECT * FROMpysql_test_complex_types_table LIMIT 1"
 f"SELECT * FROM{table_fixture} LIMIT 1"
            ).fetchone()

        assert isinstance(result[field], str)
Original file line number	Diff line number	Diff line change
Expand Up		@@ -6,7 +6,7 @@ permissions:
		on: [pull_request, workflow_dispatch]

		jobs:
		coverage:
		test-with-coverage:
		runs-on: ubuntu-latest
		environment: azure-prod
		env:
Expand All		@@ -22,9 +22,9 @@ jobs:
		- name: Check out repository
		uses: actions/checkout@v4
		with:
		fetch-depth: 0 # Needed for coverage comparison
		fetch-depth: 0
		ref: ${{ github.event.pull_request.head.ref \|\| github.ref_name }}
		repository: ${{ github.event.pull_request.head.repo.full_name \|\|github.repository }}
		repository: ${{ github.event.pull_request.head.repo.full_name \|\| github.repository }}
		- name: Set up python
		id: setup-python
		uses: actions/setup-python@v5
Expand DownExpand Up		@@ -61,14 +61,18 @@ jobs:
		- name: Install library
		run: poetry install --no-interaction --all-extras
		#----------------------------------------------
		#run all tests
		# run all tests with coverage
		#----------------------------------------------
		- name: Run tests with coverage
		continue-on-error:true
		- name: Runalltests with coverage
		continue-on-error:false
		run: \|
		poetry run python -m pytest \
		tests/unit tests/e2e \
		--cov=src --cov-report=xml --cov-report=term -v
		poetry run pytest tests/unit tests/e2e \
		-n auto \
		--cov=src \
		--cov-report=xml \
		--cov-report=term \
		-v

		#----------------------------------------------
		# check for coverage override
		#----------------------------------------------
Expand DownExpand Up		@@ -128,4 +132,5 @@ jobs:
		echo "Please ensure this override is justified and temporary"
		else
		echo "✅ Coverage checks enforced - minimum 85% required"
		fi
		fi
Original file line number	Diff line number	Diff line change
Expand Up		@@ -55,4 +55,4 @@ jobs:
		# run test suite
		#----------------------------------------------
		- name: Run e2e tests
		run: poetry run python -m pytest tests/e2e
		run: poetry run python -m pytest tests/e2e -n auto
Original file line number	Diff line number	Diff line change
Expand Up		@@ -39,6 +39,7 @@ pylint = ">=2.12.0"
		black = "^22.3.0"
		pytest-dotenv = "^0.5.2"
		pytest-cov = "^4.0.0"
		pytest-xdist = "^3.0.0"
		numpy = [
		{ version = ">=1.16.6", python = ">=3.8,<3.11" },
		{ version = ">=1.23.4", python = ">=3.11" },
Expand Down
Original file line number	Diff line number	Diff line change
		@@ -1,6 +1,7 @@
		import pytest
		from numpy import ndarray
		from typing import Sequence
		from uuid import uuid4

		from tests.e2e.test_driver import PySQLPytestTestCase

Expand All		@@ -10,12 +11,15 @@ class TestComplexTypes(PySQLPytestTestCase):
		def table_fixture(self, connection_details):
		self.arguments = connection_details.copy()
		"""A pytest fixture that creates a table with a complex type, inserts a record, yields, and then drops the table"""

		table_name = f"pysql_test_complex_types_table_{str(uuid4()).replace('-', '_')}"
		self.table_name = table_name

		with self.cursor() as cursor:
		# Create the table
		cursor.execute(
		"""
		CREATE TABLE IF NOT EXISTSpysql_test_complex_types_table (
		f"""
		CREATE TABLE IF NOT EXISTS{table_name} (
		array_col ARRAY<STRING>,
		map_col MAP<STRING, INTEGER>,
		struct_col STRUCT<field1: STRING, field2: INTEGER>,
Expand All		@@ -27,8 +31,8 @@ def table_fixture(self, connection_details):
		)
		# Insert a record
		cursor.execute(
		"""
		INSERT INTOpysql_test_complex_types_table
		f"""
		INSERT INTO{table_name}
		VALUES (
		ARRAY('a', 'b', 'c'),
		MAP('a', 1, 'b', 2, 'c', 3),
Expand All		@@ -40,10 +44,10 @@ def table_fixture(self, connection_details):
		"""
		)
		try:
		yield
		yield table_name
		finally:
		# Clean up the table after the test
		cursor.execute("DELETE FROM pysql_test_complex_types_table")
		cursor.execute(f"DROP TABLE IF EXISTS {table_name}")

		@pytest.mark.parametrize(
		"field,expected_type",
Expand All		@@ -61,7 +65,7 @@ def test_read_complex_types_as_arrow(self, field, expected_type, table_fixture):

		with self.cursor() as cursor:
		result = cursor.execute(
		"SELECT * FROMpysql_test_complex_types_table LIMIT 1"
		f"SELECT * FROM{table_fixture} LIMIT 1"
		).fetchone()

		assert isinstance(result[field], expected_type)
Expand All		@@ -83,7 +87,7 @@ def test_read_complex_types_as_string(self, field, table_fixture):
		extra_params={"_use_arrow_native_complex_types": False}
		) as cursor:
		result = cursor.execute(
		"SELECT * FROMpysql_test_complex_types_table LIMIT 1"
		f"SELECT * FROM{table_fixture} LIMIT 1"
		).fetchone()

		assert isinstance(result[field], str)