added serive for mysql

Modules/MySQL.py

@@ -0,0 +1,120 @@
+from __future__ import annotations
+
+import os
+import sys
+from typing import Annotated, Literal
+
+import gradio as gr
+from ._docstrings import autodoc
+
+try:
+    import mysql.connector
+    from mysql.connector import Error
+except ImportError:
+    mysql = None
+    Error = Exception
+
+# Lấy thông tin kết nối từ biến môi trường
+DEFAULT_HOST = os.getenv("MYSQL_HOST", "localhost")
+DEFAULT_USER = os.getenv("MYSQL_USER", "root")
+DEFAULT_PASSWORD = os.getenv("MYSQL_PASSWORD", "")
+DEFAULT_DATABASE = os.getenv("MYSQL_DATABASE", "")
+DEFAULT_PORT = int(os.getenv("MYSQL_PORT", "3306"))
+
+# Single source of truth for the LLM-facing tool description
+TOOL_SUMMARY = (
+    "Execute MySQL queries against a database; returns query results or error messages. "
+    "Uses environment variables for connection parameters if not provided."
+)
+
+
+@autodoc(
+    summary=TOOL_SUMMARY,
+)
+def MySQL(
+    query: Annotated[str, "SQL query to execute"],
+    host: Annotated[str, "MySQL server host address"] = DEFAULT_HOST,
+    username: Annotated[str, "MySQL username"] = DEFAULT_USER,
+    password: Annotated[str, "MySQL password"] = DEFAULT_PASSWORD,
+    database: Annotated[str, "Database name to connect to"] = DEFAULT_DATABASE,
+    port: Annotated[int, "MySQL server port"] = DEFAULT_PORT,
+    query_type: Annotated[Literal["SELECT", "INSERT", "UPDATE", "DELETE", "DDL"], "Type of SQL query to execute"] = "SELECT"
+) -> str:
+    if mysql is None:
+        return "Error: mysql-connector-python package is not installed. Run: pip install mysql-connector-python"
+
+    if not query or not query.strip():
+        return "Error: Query is required."
+
+    if not host or not username:
+        return "Error: Host and username are required."
+
+    connection = None
+    try:
+        # Establish connection to MySQL database
+        connection = mysql.connector.connect(
+            host=host,
+            port=port,
+            database=database,
+            user=username,
+            password=password
+        )
+
+        if connection.is_connected():
+            cursor = connection.cursor(dictionary=True)
+            cursor.execute(query)
+
+            if query_type.upper() in ["SELECT", "SHOW", "DESCRIBE", "EXPLAIN"]:
+                # Fetch results for SELECT queries
+                records = cursor.fetchall()
+                if records:
+                    result = "Query Results:\n"
+                    for i, row in enumerate(records):
+                        result += f"Row {i+1}: {dict(row)}\n"
+                    result += f"\nTotal records: {len(records)}"
+                else:
+                    result = "Query executed successfully. No records found."
+            else:
+                # For INSERT, UPDATE, DELETE, DDL queries
+                connection.commit()
+                affected_rows = cursor.rowcount
+                result = f"Query executed successfully. Affected rows: {affected_rows}"
+
+            cursor.close()
+            return result
+    except Error as e:
+        error_msg = f"MySQL Error: {str(e)}"
+        return error_msg
+    except Exception as e:
+        error_msg = f"Error: {str(e)}"
+        return error_msg
+    finally:
+        if connection and connection.is_connected():
+            connection.close()
+
+
+def build_interface() -> gr.Interface:
+    return gr.Interface(
+        fn=MySQL,
+        inputs=[
+            gr.Code(label="SQL Query", language="sql"),
+            gr.Textbox(label="Host", value=DEFAULT_HOST),
+            gr.Textbox(label="Username", value=DEFAULT_USER),
+            gr.Textbox(label="Password", type="password", value=DEFAULT_PASSWORD),
+            gr.Textbox(label="Database", value=DEFAULT_DATABASE),
+            gr.Number(label="Port", value=DEFAULT_PORT),
+            gr.Radio(
+                label="Query Type",
+                choices=["SELECT", "INSERT", "UPDATE", "DELETE", "DDL"],
+                value="SELECT"
+            )
+        ],
+        outputs=gr.Textbox(label="Result", lines=10, max_lines=20),
+        title="MySQL Database Connector",
+        description="<div style=\"text-align:center\">Execute MySQL queries against a database. Uses environment variables for defaults.</div>",
+        api_description=TOOL_SUMMARY,
+        flagging_mode="never",
+    )
+
+
+__all__ = ["MySQL", "build_interface"]

Transcendent-SQL-4B/readme.md

@@ -0,0 +1,81 @@
+## Convert mysql sang sqlite
+
+Giả sử tôi đặt tên file .sql sử dụng trong mysql là schema.sql
+
+```python
+
+import sqlite3
+import re
+import os
+
+# Cấu hình tên file
+INPUT_SQL_FILE = 'schema.sql'  # Tên file SQL gốc của bạn
+OUTPUT_DB_FILE = 'database.db'     # Tên file SQLite muốn tạo
+
+def convert_mysql_to_sqlite(sql_content):
+    # 1. Xóa các dòng comment SQL (bắt đầu bằng -- hoặc /*)
+    sql_content = re.sub(r'/\*.*?\*/', '', sql_content, flags=re.DOTALL)
+    
+    # 2. Xóa cú pháp COMMENT '...' của MySQL
+    # Regex này tìm từ khóa COMMENT theo sau là chuỗi trong dấu nháy đơn
+    sql_content = re.sub(r"COMMENT\s+'.*?'", "", sql_content)
+    
+    # 3. Xử lý AUTO_INCREMENT
+    # SQLite tự động tăng nếu là INTEGER PRIMARY KEY, nên chỉ cần xóa từ khóa này
+    sql_content = re.sub(r"AUTO_INCREMENT", "", sql_content, flags=re.IGNORECASE)
+    
+    # 4. Thay thế kiểu dữ liệu BIT(1) thành INTEGER (SQLite không có BIT)
+    sql_content = re.sub(r"BIT$1$", "INTEGER", sql_content, flags=re.IGNORECASE)
+    
+    # 5. Thay thế giá trị bit b'0', b'1' thành 0, 1
+    sql_content = re.sub(r"b'0'", "0", sql_content)
+    sql_content = re.sub(r"b'1'", "1", sql_content)
+    
+    # 6. Xóa các thiết lập cuối bảng của MySQL (ENGINE=InnoDB...)
+    sql_content = re.sub(r"\) ENGINE=.*?;", ");", sql_content, flags=re.DOTALL)
+    
+    # 7. Thay thế \' trong chuỗi thành '' (cách escape của SQLite)
+    sql_content = sql_content.replace("\\'", "''")
+    
+    return sql_content
+
+# Xóa file cũ nếu có
+if os.path.exists(OUTPUT_DB_FILE):
+    os.remove(OUTPUT_DB_FILE)
+    
+# Kết nối SQLite
+conn = sqlite3.connect(OUTPUT_DB_FILE)
+cursor = conn.cursor()
+
+print("Đang đọc và xử lý file SQL...")
+
+try:
+    with open(INPUT_SQL_FILE, 'r', encoding='utf-8') as f:
+        raw_sql = f.read()
+        
+    clean_sql = convert_mysql_to_sqlite(raw_sql)
+    
+    # Tách các câu lệnh bằng dấu chấm phẩy và thực thi từng câu
+    statements = clean_sql.split(';')
+    
+    count = 0
+    for statement in statements:
+        if statement.strip():
+            try:
+                cursor.execute(statement)
+                count += 1
+            except sqlite3.Error as e:
+                print(f"Lỗi tại câu lệnh: {statement[:50]}...")
+                print(f"Chi tiết: {e}")
+
+    conn.commit()
+    print(f"Xong! Đã tạo file '{OUTPUT_DB_FILE}' với {count} câu lệnh thành công.")
+
+except FileNotFoundError:
+    print(f"Lỗi: Không tìm thấy file '{INPUT_SQL_FILE}'")
+except Exception as e:
+    print(f"Lỗi không mong muốn: {e}")
+finally:
+    conn.close()
+```
+

app.py

@@ -94,6 +94,7 @@ from Modules.Deep_Research import build_interface as build_research_interface
 from Modules.File_System import build_interface as build_fs_interface
 from Modules.Obsidian_Vault import build_interface as build_obsidian_interface
 from Modules.Shell_Command import build_interface as build_shell_interface
+from Modules.MySQL import build_interface as build_mysql_interface
 
 # Optional environment flags used to conditionally show API schemas (unchanged behavior)
 HF_IMAGE_TOKEN = bool(os.getenv("HF_READ_TOKEN"))
@@ -118,6 +119,7 @@ deep_research_interface = build_research_interface()
 fs_interface = build_fs_interface()
 shell_interface = build_shell_interface()
 obsidian_interface = build_obsidian_interface()
+mysql_interface = build_mysql_interface()
 
 _interfaces = [
     agent_terminal_interface,
@@ -132,6 +134,7 @@ _interfaces = [
     image_generation_interface,
     video_generation_interface,
     deep_research_interface,
+    mysql_interface,
 ]
 _tab_names = [
     "Agent Terminal",
@@ -146,6 +149,7 @@ _tab_names = [
     "Generate Image",
     "Generate Video",
     "Deep Research",
+    "MySQL Database",
 ]
 
 with gr.Blocks(title="Nymbo/Tools MCP") as demo:

requirements.txt

@@ -11,4 +11,5 @@ Pillow
 huggingface_hub>=0.30.0
 markdownify
 scipy
-onnxruntime
+onnxruntime
+mysql-connector-python