Remove .env.example file, update server script permissions, and modify SQL execution parameters for improved functionality

scripts/start_mcp_server.sh

@@ -27,6 +27,6 @@ if [ -n "$DATABRICKS_HOST" ]; then
     echo "Databricks Host: $DATABRICKS_HOST"
 fi
 
-uv run src.server.databricks_mcp_server
+python -m src.server.databricks_mcp_server
 
 echo "Server stopped at $(date)" 

src/api/sql.py

@@ -43,9 +43,11 @@ async def execute_statement(
     request_data = {
         "statement": statement,
         "warehouse_id": warehouse_id,
-        "wait_timeout": "0s",  # Wait indefinitely
+        "wait_timeout": "10s",
+        "format": "JSON_ARRAY",
+        "disposition": "INLINE",
         "row_limit": row_limit,
-        "byte_limit": byte_limit,
+        "byte_limit": 16777216,
     }
 
     if catalog:
@@ -57,7 +59,7 @@ async def execute_statement(
     if parameters:
         request_data["parameters"] = parameters
 
-    return make_api_request("POST", "/api/2.0/sql/statements/execute", data=request_data)
+    return make_api_request("POST", "/api/2.0/sql/statements", data=request_data)
 
 
 async def execute_and_wait(

src/server/databricks_mcp_server.py

@@ -202,7 +202,12 @@ async def execute_sql(params: Dict[str, Any]) -> List[TextContent]:
                 catalog = params.get("catalog")
                 schema = params.get("schema")
 
-                result = await sql.execute_sql(statement, warehouse_id, catalog, schema)
+                result = await sql.execute_statement(
+                    statement=statement,
+                    warehouse_id=warehouse_id,
+                    catalog=catalog,
+                    schema=schema
+                )
                 return [{"text": json.dumps(result)}]
             except Exception as e:
                 logger.error(f"Error executing SQL: {str(e)}")