docs: fix docs build failure due to bad example code

Author: terry-docker

docs/modules/influxdb.md

@@ -20,4 +20,8 @@ pip install testcontainers[influxdb] influxdb-client
 
 ## Usage example
 
+<!--codeinclude-->
+
 [Creating an InfluxDB container](../../modules/influxdb/example_basic.py)
+
+<!--/codeinclude-->

docs/modules/mssql.md

@@ -11,7 +11,7 @@ The Testcontainers module for Microsoft SQL Server.
 Please run the following command to add the MSSQL module to your python dependencies:
 
 ```bash
-pip install testcontainers[mssql] sqlalchemy pymssql
+pip install testcontainers[mssql] pymssql
 ```
 
 ## Usage example

docs/modules/mssql/example_basic.py

@@ -44,92 +44,63 @@ def basic_example():
         query_api = client.query_api()
 
         # Query data
-        query = f'''
-        from(bucket: "{bucket}")
-            |> range(start: -1h)
-            |> filter(fn: (r) => r["_measurement"] == "test_measurement")
-        '''
+        query = f'from(bucket: "{bucket}") |> range(start: -1h) |> filter(fn: (r) => r["_measurement"] == "test_measurement")'
 
         result = query_api.query(query)
         print("\nQuery results:")
         for table in result:
             for record in table.records:
-                print(
-                    json.dumps(
-                        {
-                            "measurement": record.get_measurement(),
-                            "time": record.get_time().isoformat(),
-                            "location": record.values.get("location"),
-                            "device": record.values.get("device"),
-                            "field": record.get_field(),
-                            "value": record.get_value(),
-                        },
-                        indent=2,
-                    )
-                )
+                record_data = {
+                    "measurement": record.get_measurement(),
+                    "time": record.get_time().isoformat(),
+                    "location": record.values.get("location"),
+                    "device": record.values.get("device"),
+                    "field": record.get_field(),
+                    "value": record.get_value(),
+                }
+                print(json.dumps(record_data, indent=2))
 
         # Create aggregation query
-        agg_query = f'''
-        from(bucket: "{bucket}")
-            |> range(start: -1h)
-            |> filter(fn: (r) => r["_measurement"] == "test_measurement")
-            |> group(columns: ["location"])
-            |> mean()
-        '''
+        agg_query = f'from(bucket: "{bucket}") |> range(start: -1h) |> filter(fn: (r) => r["_measurement"] == "test_measurement") |> group(columns: ["location"]) |> mean()'
 
         agg_result = query_api.query(agg_query)
         print("\nAggregation results:")
         for table in agg_result:
             for record in table.records:
-                print(
-                    json.dumps(
-                        {
-                            "location": record.values.get("location"),
-                            "field": record.get_field(),
-                            "mean": record.get_value(),
-                        },
-                        indent=2,
-                    )
-                )
+                record_data = {
+                    "location": record.values.get("location"),
+                    "field": record.get_field(),
+                    "mean": record.get_value(),
+                }
+                print(json.dumps(record_data, indent=2))
 
         # Create window query
-        window_query = f'''
-        from(bucket: "{bucket}")
-            |> range(start: -1h)
-            |> filter(fn: (r) => r["_measurement"] == "test_measurement")
-            |> window(every: 5m)
-            |> mean()
-        '''
+        window_query = f'from(bucket: "{bucket}") |> range(start: -1h) |> filter(fn: (r) => r["_measurement"] == "test_measurement") |> window(every: 5m) |> mean()'
 
         window_result = query_api.query(window_query)
         print("\nWindow results:")
         for table in window_result:
             for record in table.records:
-                print(
-                    json.dumps(
-                        {
-                            "window_start": record.get_start().isoformat(),
-                            "window_stop": record.get_stop().isoformat(),
-                            "field": record.get_field(),
-                            "mean": record.get_value(),
-                        },
-                        indent=2,
-                    )
-                )
+                record_data = {
+                    "window_start": record.get_start().isoformat(),
+                    "window_stop": record.get_stop().isoformat(),
+                    "field": record.get_field(),
+                    "mean": record.get_value(),
+                }
+                print(json.dumps(record_data, indent=2))
 
         # Create task
-        task_flux = f'''
-        option task = {{
-            name: "test_task",
-            every: 1h
-        }}
-
-        from(bucket: "{bucket}")
-            |> range(start: -1h)
-            |> filter(fn: (r) => r["_measurement"] == "test_measurement")
-            |> mean()
-            |> to(bucket: "{bucket}", measurement: "test_measurement_agg")
-        '''
+        task_flux = (
+            "option task = {\n"
+            '    name: "test_task",\n'
+            "    every: 1h\n"
+            "}\n\n"
+            f'from(bucket: "{bucket}")\n'
+            "    |> range(start: -1h)\n"
+            '    |> filter(fn: (r) => r["_measurement"] == "test_measurement")\n'
+            "    |> mean()\n"
+            f'    |> to(bucket: "{bucket}", measurement: "test_measurement_agg")'
+        )
 
         tasks_api = client.tasks_api()
         task = tasks_api.create_task(name="test_task", flux=task_flux, org=org)
@@ -138,12 +109,13 @@ def basic_example():
         # Get task info
         task_info = tasks_api.find_task_by_id(task.id)
         print("\nTask info:")
-        print(
-            json.dumps(
-                {"id": task_info.id, "name": task_info.name, "status": task_info.status, "every": task_info.every},
-                indent=2,
-            )
-        )
+        task_data = {
+            "id": task_info.id,
+            "name": task_info.name,
+            "status": task_info.status,
+            "every": task_info.every,
+        }
+        print(json.dumps(task_data, indent=2))
 
         # Create dashboard
         dashboards_api = client.dashboards_api()
@@ -159,11 +131,12 @@ def basic_example():
         # Get dashboard info
         dashboard_info = dashboards_api.find_dashboard_by_id(dashboard.id)
         print("\nDashboard info:")
-        print(
-            json.dumps(
-                {"id": dashboard_info.id, "name": dashboard_info.name, "cells": len(dashboard_info.cells)}, indent=2
-            )
-        )
+        dashboard_data = {
+            "id": dashboard_info.id,
+            "name": dashboard_info.name,
+            "cells": len(dashboard_info.cells),
+        }
+        print(json.dumps(dashboard_data, indent=2))
 
         # Create bucket
         buckets_api = client.buckets_api()
@@ -173,7 +146,12 @@ def basic_example():
         # Get bucket info
         bucket_info = buckets_api.find_bucket_by_id(new_bucket.id)
         print("\nBucket info:")
-        print(json.dumps({"id": bucket_info.id, "name": bucket_info.name, "org_id": bucket_info.org_id}, indent=2))
+        bucket_data = {
+            "id": bucket_info.id,
+            "name": bucket_info.name,
+            "org_id": bucket_info.org_id,
+        }
+        print(json.dumps(bucket_data, indent=2))
 
         # Clean up
         tasks_api.delete_task(task.id)

modules/influxdb/example_basic.py

@@ -1,4 +1,4 @@
-import pyodbc
+import pymssql
 
 from testcontainers.mssql import MsSqlContainer
 
@@ -12,11 +12,8 @@ def basic_example():
         password = mssql.password
         database = mssql.database
 
-        # Create connection string
-        conn_str = f"DRIVER={{ODBC Driver 17 for SQL Server}};SERVER={host},{port};DATABASE={database};UID={username};PWD={password}"
-
         # Connect to MSSQL
-        connection = pyodbc.connect(conn_str)
+        connection = pymssql.connect(server=host, port=port, user=username, password=password, database=database)
         print("Connected to MSSQL")
 
         # Create cursor
@@ -40,7 +37,7 @@ def basic_example():
         cursor.executemany(
             """
             INSERT INTO test_table (name, value, category)
-            VALUES (?, ?, ?)
+            VALUES (%s, %s, %s)
         """,
             test_data,
         )