Initial Commit

0.13

@@ -0,0 +1,9 @@
+Collecting starlette
+  Using cached starlette-0.47.0-py3-none-any.whl.metadata (6.2 kB)
+Requirement already satisfied: anyio<5,>=3.6.2 in c:\files\codes\research\mcp\.venv\lib\site-packages (from starlette) (4.9.0)
+Requirement already satisfied: idna>=2.8 in c:\files\codes\research\mcp\.venv\lib\site-packages (from anyio<5,>=3.6.2->starlette) (3.10)
+Requirement already satisfied: sniffio>=1.1 in c:\files\codes\research\mcp\.venv\lib\site-packages (from anyio<5,>=3.6.2->starlette) (1.3.1)
+Requirement already satisfied: typing_extensions>=4.5 in c:\files\codes\research\mcp\.venv\lib\site-packages (from anyio<5,>=3.6.2->starlette) (4.14.0)
+Using cached starlette-0.47.0-py3-none-any.whl (72 kB)
+Installing collected packages: starlette
+Successfully installed starlette-0.47.0

Dockerfile

@@ -0,0 +1,25 @@
+# Use an official Python 3.11 (or a future version if released) runtime as the base image
+FROM python:3.11-slim
+
+# Set environment variables to avoid Python writing .pyc files
+# and to ensure that output is sent straight to the terminal
+ENV PYTHONDONTWRITEBYTECODE 1
+ENV PYTHONUNBUFFERED 1
+
+# Set the working directory to /app
+WORKDIR /app
+
+# Copy the requirements file into the container
+COPY requirements.txt /app/
+
+# Install the dependencies
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Copy the entire project into the container
+COPY . /app/
+
+# Expose the server port (7860)
+EXPOSE 7860
+
+# Run the FastMCP server using uvicorn (with FastAPI)
+CMD ["uvicorn", "server:app", "--host", "0.0.0.0", "--port", "7860"]

requirements.txt

@@ -0,0 +1,8 @@
+
+fastapi-mcp>=0.2.0,
+ipykernel>=6.29.5,
+linkup-sdk>=0.2.4,
+llama-index>=0.12.30,
+llama-index-llms-ollama>=0.5.4,
+llama-index-tools-mcp>=0.1.1,
+mcp[cli]>=1.6.0

server.py

@@ -0,0 +1,130 @@
+import sqlite3
+import argparse
+from mcp.server.fastmcp import FastMCP
+
+mcp = FastMCP('sqlite-demo')
+
+def init_db():
+    conn = sqlite3.connect('demo.db')
+    cursor = conn.cursor()
+    cursor.execute('''
+        CREATE TABLE IF NOT EXISTS people (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            name TEXT NOT NULL,
+            age INTEGER NOT NULL,
+            profession TEXT NOT NULL
+        )
+    ''')
+    conn.commit()
+    return conn, cursor
+
+@mcp.tool()
+def add_data(query: str) -> bool:
+    """Add new data to the people table using a SQL INSERT query.
+
+    Args:
+        query (str): SQL INSERT query following this format:
+            INSERT INTO people (name, age, profession)
+            VALUES ('John Doe', 30, 'Engineer')
+        
+    Schema:
+        - name: Text field (required)
+        - age: Integer field (required)
+        - profession: Text field (required)
+        Note: 'id' field is auto-generated
+    
+    Returns:
+        bool: True if data was added successfully, False otherwise
+    
+    Example:
+        >>> query = '''
+        ... INSERT INTO people (name, age, profession)
+        ... VALUES ('Alice Smith', 25, 'Developer')
+        ... '''
+        >>> add_data(query)
+        True
+    """
+    conn, cursor = init_db()
+    try:
+        cursor.execute(query)
+        conn.commit()
+        return True
+    except sqlite3.Error as e:
+        print(f"Error adding data: {e}")
+        return False
+    finally:
+        conn.close()
+
+@mcp.tool()
+def read_data(query: str = "SELECT * FROM people") -> list:
+    """Read data from the people table using a SQL SELECT query.
+
+    Args:
+        query (str, optional): SQL SELECT query. Defaults to "SELECT * FROM people".
+            Examples:
+            - "SELECT * FROM people"
+            - "SELECT name, age FROM people WHERE age > 25"
+            - "SELECT * FROM people ORDER BY age DESC"
+    
+    Returns:
+        list: List of tuples containing the query results.
+              For default query, tuple format is (id, name, age, profession)
+    
+    Example:
+        >>> # Read all records
+        >>> read_data()
+        [(1, 'John Doe', 30, 'Engineer'), (2, 'Alice Smith', 25, 'Developer')]
+        
+        >>> # Read with custom query
+        >>> read_data("SELECT name, profession FROM people WHERE age < 30")
+        [('Alice Smith', 'Developer')]
+    """
+    conn, cursor = init_db()
+    try:
+        cursor.execute(query)
+        return cursor.fetchall()
+    except sqlite3.Error as e:
+        print(f"Error reading data: {e}")
+        return []
+    finally:
+        conn.close()
+
+
+
+if __name__ == "__main__":
+    # Start the server
+    print("🚀Starting server... ")
+
+    # Debug Mode
+    #  uv run mcp dev server.py
+
+    # Production Mode
+    # uv run server.py --server_type=sse
+
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--server_type", type=str, default="sse", choices=["sse", "stdio"]
+    )
+
+    args = parser.parse_args()
+    mcp.run(args.server_type)
+
+
+
+# # Example usage
+# if __name__ == "__main__":
+#     # Example INSERT query
+#     insert_query = """
+#     INSERT INTO people (name, age, profession)
+#     VALUES ('John Doe', 30, 'Engineer')
+#     """
+    
+#     # Add data
+#     if add_data(insert_query):
+#         print("Data added successfully")
+    
+#     # Read all data
+#     results = read_data()
+#     print("\nAll records:")
+#     for record in results:
+#         print(record)