From 68549532d4dc14686920559251bf4b1712bd5de3 Mon Sep 17 00:00:00 2001
From: Ben Borla <benborla@icloud.com>
Date: Mon, 9 Dec 2024 14:52:33 +0800
Subject: [PATCH] removed index.js, should rely on the build index.js in
 dist/index.js

---
 src/mysql/index.js | 184 ---------------------------------------------
 1 file changed, 184 deletions(-)
 delete mode 100644 src/mysql/index.js

diff --git a/src/mysql/index.js b/src/mysql/index.js
deleted file mode 100644
index b2992e2..0000000
--- a/src/mysql/index.js
+++ /dev/null
@@ -1,184 +0,0 @@
-#!/usr/bin/env node
-
-import { Server } from "@modelcontextprotocol/sdk/server/index.js";
-import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
-import {
-  CallToolRequestSchema,
-  ListResourcesRequestSchema,
-  ListToolsRequestSchema,
-  ReadResourceRequestSchema,
-} from "@modelcontextprotocol/sdk/types.js";
-import mysql from "mysql";
-
-const server = new Server(
-  {
-    name: "example-servers/mysql",
-    version: "0.1.0",
-  },
-  {
-    capabilities: {
-      resources: {},
-      tools: {},
-    },
-  },
-);
-
-const MYSQL_HOST = process.env.MYSQL_HOST || "127.0.0.1";
-const MYSQL_PORT = process.env.MYSQL_PORT || "3306";
-const MYSQL_USER = process.env.MYSQL_USER || "root";
-const MYSQL_PASS = process.env.MYSQL_PASS || "";
-const MYSQL_DB = process.env.MYSQL_DB || "";
-
-const pool = mysql.createPool({
-  connectionLimit: 10,
-  host: MYSQL_HOST,
-  port: MYSQL_PORT,
-  user: MYSQL_USER,
-  password: MYSQL_PASS,
-  database: MYSQL_DB,
-});
-
-const SCHEMA_PATH = "schema";
-
-server.setRequestHandler(ListResourcesRequestSchema, async () => {
-  return new Promise((resolve, reject) => {
-    pool.query(
-      "SELECT table_name FROM information_schema.tables WHERE table_schema = DATABASE()",
-      (error, results) => {
-        if (error) reject(error);
-        resolve({
-          resources: results.map((row) => ({
-            uri: new URL(`${row.table_name}/${SCHEMA_PATH}`, resourceBaseUrl)
-              .href,
-            mimeType: "application/json",
-            name: `"${row.table_name}" database schema`,
-          })),
-        });
-      },
-    );
-  });
-});
-
-server.setRequestHandler(ReadResourceRequestSchema, async (request) => {
-  const resourceUrl = new URL(request.params.uri);
-
-  const pathComponents = resourceUrl.pathname.split("/");
-  const schema = pathComponents.pop();
-  const tableName = pathComponents.pop();
-
-  if (schema !== SCHEMA_PATH) {
-    throw new Error("Invalid resource URI");
-  }
-
-  return new Promise((resolve, reject) => {
-    pool.query(
-      "SELECT column_name, data_type FROM information_schema.columns WHERE table_name = ?",
-      [tableName],
-      (error, results) => {
-        if (error) reject(error);
-        resolve({
-          contents: [
-            {
-              uri: request.params.uri,
-              mimeType: "application/json",
-              text: JSON.stringify(results, null, 2),
-            },
-          ],
-        });
-      },
-    );
-  });
-});
-
-server.setRequestHandler(ListToolsRequestSchema, async () => {
-  return {
-    tools: [
-      {
-        name: "mysql_query",
-        description: "Run a read-only MySQL query",
-        inputSchema: {
-          type: "object",
-          properties: {
-            sql: { type: "string" },
-          },
-        },
-      },
-    ],
-  };
-});
-
-server.setRequestHandler(CallToolRequestSchema, async (request) => {
-  if (request.params.name === "mysql_query") {
-    const sql = request.params.arguments?.sql;
-
-    return new Promise((resolve, reject) => {
-      pool.getConnection((err, connection) => {
-        if (err) reject(err);
-
-        // @INFO: Set session to read only BEFORE beginning the transaction
-        connection.query("SET SESSION TRANSACTION READ ONLY", (err) => {
-          if (err) {
-            connection.release();
-            reject(err);
-            return;
-          }
-
-          connection.beginTransaction((err) => {
-            if (err) {
-              connection.release();
-              reject(err);
-              return;
-            }
-
-            connection.query(sql, (error, results) => {
-              if (error) {
-                connection.rollback(() => {
-                  connection.release();
-                  reject(error);
-                });
-                return;
-              }
-
-              connection.rollback(() => {
-                // @INFO: Reset the transaction mode back to default before releasing
-                connection.query(
-                  "SET SESSION TRANSACTION READ WRITE",
-                  (err) => {
-                    connection.release();
-                    if (err) {
-                      console.warn("Failed to reset transaction mode:", err);
-                    }
-                    resolve({
-                      content: [
-                        {
-                          type: "text",
-                          text: JSON.stringify(results, null, 2),
-                        },
-                      ],
-                      isError: false,
-                    });
-                  },
-                );
-              });
-            });
-          });
-        });
-      });
-    });
-  }
-  throw new Error(`Unknown tool: ${request.params.name}`);
-});
-
-async function runServer() {
-  const transport = new StdioServerTransport();
-  await server.connect(transport);
-}
-
-process.on("SIGINT", () => {
-  pool.end((err) => {
-    if (err) console.error("Error closing pool:", err);
-    process.exit(err ? 1 : 0);
-  });
-});
-
-runServer().catch(console.error);