Extend test_services.test_query_service_rollback_on_error

Signed-off-by: David Rapan <[email protected]>

Author: davidrapan

tests/components/sql/test_sensor.py

@@ -193,18 +193,6 @@ def make_test_db():
 @pytest.mark.parametrize(
     ("patch_create", "url", "expected_patterns", "not_expected_patterns"),
     [
-        (
-            "homeassistant.components.sql.util.sqlalchemy.create_engine",
-            "sqlite://homeassistant:[email protected]",
-            ["sqlite://****:****@homeassistant.local"],
-            ["sqlite://homeassistant:[email protected]"],
-        ),
-        (
-            "homeassistant.components.sql.util.sqlalchemy.create_engine",
-            "sqlite://homeassistant.local",
-            ["sqlite://homeassistant.local"],
-            [],
-        ),
         (
             "homeassistant.components.sql.util.create_async_engine",
             "sqlite+aiosqlite://homeassistant:[email protected]",
@@ -217,6 +205,18 @@ def make_test_db():
             ["sqlite+aiosqlite://homeassistant.local"],
             [],
         ),
+        (
+            "homeassistant.components.sql.util.sqlalchemy.create_engine",
+            "sqlite://homeassistant:[email protected]",
+            ["sqlite://****:****@homeassistant.local"],
+            ["sqlite://homeassistant:[email protected]"],
+        ),
+        (
+            "homeassistant.components.sql.util.sqlalchemy.create_engine",
+            "sqlite://homeassistant.local",
+            ["sqlite://homeassistant.local"],
+            [],
+        ),
     ],
 )
 async def test_invalid_url_setup(
@@ -301,7 +301,7 @@ def rollback(self) -> None:
     assert "sqlite://****:****@homeassistant.local" in caplog.text
 
 
-@pytest.mark.parametrize("async_driver", [False, True])
+@pytest.mark.parametrize("async_driver", [True, False])
 async def test_query_from_yaml(
     recorder_mock: Recorder, hass: HomeAssistant, async_driver: bool
 ) -> None:
@@ -411,18 +411,6 @@ async def test_config_from_old_yaml(
 @pytest.mark.parametrize(
     ("patch_create", "url", "expected_patterns", "not_expected_patterns"),
     [
-        (
-            "homeassistant.components.sql.util.sqlalchemy.create_engine",
-            "sqlite://homeassistant:[email protected]",
-            ["sqlite://****:****@homeassistant.local"],
-            ["sqlite://homeassistant:[email protected]"],
-        ),
-        (
-            "homeassistant.components.sql.util.sqlalchemy.create_engine",
-            "sqlite://homeassistant.local",
-            ["sqlite://homeassistant.local"],
-            [],
-        ),
         (
             "homeassistant.components.sql.util.create_async_engine",
             "sqlite+aiosqlite://homeassistant:[email protected]",
@@ -435,6 +423,18 @@ async def test_config_from_old_yaml(
             ["sqlite+aiosqlite://homeassistant.local"],
             [],
         ),
+        (
+            "homeassistant.components.sql.util.sqlalchemy.create_engine",
+            "sqlite://homeassistant:[email protected]",
+            ["sqlite://****:****@homeassistant.local"],
+            ["sqlite://homeassistant:[email protected]"],
+        ),
+        (
+            "homeassistant.components.sql.util.sqlalchemy.create_engine",
+            "sqlite://homeassistant.local",
+            ["sqlite://homeassistant.local"],
+            [],
+        ),
     ],
 )
 async def test_invalid_url_setup_from_yaml(
@@ -728,17 +728,17 @@ async def test_attributes_from_entry_config(
 @pytest.mark.parametrize(
     ("config", "patch_rollback"),
     [
-        (
-            {},
-            "sqlalchemy.orm.session.Session.rollback",
-        ),
         (
             {CONF_DB_URL: "sqlite+aiosqlite:///"},
             "sqlalchemy.ext.asyncio.session.AsyncSession.rollback",
         ),
+        (
+            {},
+            "sqlalchemy.orm.session.Session.rollback",
+        ),
     ],
 )
-async def test_session_rollback_on_error(
+async def test_query_rollback_on_error(
     recorder_mock: Recorder,
     hass: HomeAssistant,
     freezer: FrozenDateTimeFactory,

tests/components/sql/test_services.py

@@ -2,12 +2,14 @@
 
 from __future__ import annotations
 
+from datetime import timedelta
 from pathlib import Path
 import sqlite3
 from unittest.mock import patch
 
+from freezegun.api import FrozenDateTimeFactory
 import pytest
-from sqlalchemy.exc import SQLAlchemyError
+from sqlalchemy import text
 import voluptuous as vol
 from voluptuous import MultipleInvalid
 
@@ -18,6 +20,7 @@
 from homeassistant.exceptions import ServiceValidationError
 from homeassistant.setup import async_setup_component
 
+from tests.common import async_fire_time_changed
 from tests.components.recorder.common import async_wait_recording_done
 
 
@@ -87,14 +90,30 @@ async def test_query_service_external_db(hass: HomeAssistant, tmp_path: Path) ->
     }
 
 
+@pytest.mark.parametrize(
+    ("async_driver", "patch_rollback"),
+    [
+        (
+            True,
+            "sqlalchemy.ext.asyncio.session.AsyncSession.rollback",
+        ),
+        (
+            False,
+            "sqlalchemy.orm.session.Session.rollback",
+        ),
+    ],
+)
 async def test_query_service_rollback_on_error(
     hass: HomeAssistant,
     tmp_path: Path,
+    freezer: FrozenDateTimeFactory,
     caplog: pytest.LogCaptureFixture,
+    async_driver: bool,
+    patch_rollback: str,
 ) -> None:
     """Test the query service."""
     db_path = tmp_path / "test.db"
-    db_url = f"sqlite:///{db_path}"
+    db_url = f"sqlite{'+aiosqlite' if async_driver else ''}:///{db_path}"
 
     # Create and populate the external database
     conn = sqlite3.connect(db_path)
@@ -109,12 +128,12 @@ async def test_query_service_rollback_on_error(
     with (
         patch(
             "homeassistant.components.sql.services.generate_lambda_stmt",
-            side_effect=SQLAlchemyError("Error executing query"),
+            return_value=text("Faulty syntax create operational issue"),
         ),
         pytest.raises(
             ServiceValidationError, match="An error occurred when executing the query"
         ),
-        patch("sqlalchemy.orm.session.Session.rollback") as mock_session_rollback,
+        patch(patch_rollback) as mock_session_rollback,
     ):
         await hass.services.async_call(
             DOMAIN,
@@ -124,8 +143,14 @@ async def test_query_service_rollback_on_error(
             return_response=True,
         )
 
+    freezer.tick(timedelta(minutes=1))
+    async_fire_time_changed(hass)
+    await hass.async_block_till_done(wait_background_tasks=True)
+    assert "sqlite3.OperationalError" in caplog.text
     assert mock_session_rollback.call_count == 1
 
+    await hass.async_stop()
+
 
 async def test_query_service_data_conversion(
     hass: HomeAssistant, tmp_path: Path