updates to README.md and connx_server.py including tests.

Author: deec

.env.example

@@ -2,4 +2,4 @@
 CONNX_DSN=your_dsn_name
 CONNX_USER=your_username
 CONNX_PASS=your_password
-CONNX_ALLOW_WRITES=false
+CONNX_TIMEOUT=30

README.md

@@ -224,17 +224,17 @@ Below are examples of how MCP-compatible clients (such as Claude Desktop or othe
 
 CONNX Database Server Tools:
 
-query_connx - Query data from CONNX-connected databases using SQL (SELECT-only queries)
-update_connx - Perform update operations (requires CONNX_ALLOW_WRITES=true)
-count_customers - Get total number of customers
-customers_by_state - Get customer distribution by state
-customer_cities - Get customer cities information
-customers_missing_phone - Find customers without phone numbers
-get_customer - Retrieve a specific customer by ID
-find_customers - Search for customers by state and optional city
-describe_entities - Describe known business entities and their data sources
-count_entities - Count rows for business entities (customers, clients, etc.)
----
+* query_connx - Query data from CONNX-connected databases using SQL (SELECT-only queries)
+* update_connx - Perform update operations (requires CONNX_ALLOW_WRITES=true)
+* count_customers - Get total number of customers
+* customers_by_state - Get customer distribution by state
+* customer_cities - Get customer cities information
+* customers_missing_phone - Find customers without phone numbers
+* get_customer - Retrieve a specific customer by ID
+* find_customers - Search for customers by state and optional city
+* describe_entities - Describe known business entities and their data sources
+* count_entities - Count rows for business entities (customers, clients, etc.)
+* ---
 
 ## Testing 
 This project uses pytest for unit testing. Tests mock database interactions to run without a real CONNX setup.

connx_server.py

@@ -100,9 +100,11 @@ def _is_select_only(sql: str) -> bool:
 def get_connx_connection():
     """Establish a connection to CONNX via pyodbc."""
     _assert_config()
+
+    timeout = int(os.getenv("CONNX_TIMEOUT", "30"))
     conn_str = f"DSN={CONNX_DSN};UID={CONNX_USER};PWD={CONNX_PASS}"
     try:
-        conn = pyodbc.connect(conn_str)
+        conn = pyodbc.connect(conn_str, timeout=timeout)
         logger.info("Successfully connected to CONNX")
         return conn
     except pyodbc.Error as e:
@@ -122,6 +124,7 @@ def execute_query(query: str, params: Optional[List[Any]] = None) -> List[Dict[s
     fp = _sql_fingerprint(query)
     try:
         cursor = conn.cursor()
+     #   cursor.timeout = int(os.getenv("CONNX_TIMEOUT", "30"))
         cursor.execute(query, params or [])
         if cursor.description is None:
             # A SELECT should provide a description; if not, treat as an error.

requirements-dev.txt

@@ -1,4 +1,4 @@
-pytest
-pytest-mock
-pytest-asyncio
-pytest-cov
+pytest-mock==3.15.1
+pytest-asyncio==1.3.0
+pytest==9.0.2
+pytest-cov==7.0.0

requirements.txt

@@ -1,7 +1,3 @@
-pytest-mock==3.15.1
-pytest-asyncio==1.3.0
-pytest==9.0.2
-pytest-cov==7.0.0
 mcp==1.24.0
 pyodbc==5.3.0
 python-dotenv==1.2.1