init

pom.xml

@@ -36,10 +36,16 @@
             <artifactId>spring-ai-starter-mcp-server-webflux</artifactId>
         </dependency>
 
-<!--        <dependency>-->
+        <dependency>
-<!--            <groupId>org.springframework.boot</groupId>-->
+            <groupId>org.springframework.boot</groupId>
-<!--            <artifactId>spring-boot-starter-jdbc</artifactId>-->
+            <artifactId>spring-boot-starter-jdbc</artifactId>
-<!--        </dependency>-->
+        </dependency>
+
+        <dependency>
+            <groupId>com.mysql</groupId>
+            <artifactId>mysql-connector-j</artifactId>
+            <version>8.3.0</version>
+        </dependency>
 
         <dependency>
             <groupId>org.springframework.boot</groupId>

src/main/java/cn/louisxiv/mcp/dbconnect/tool/DbConnectTool.java

@@ -2,15 +2,21 @@ package cn.louisxiv.mcp.dbconnect.tool;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.ai.tool.annotation.Tool;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
 public class DbConnectTool {
 
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @Tool(description = "获取表结构定义，参数是表名")
     public String getTableDefinition(String tableName) {
         log.info("get table definition: {}", tableName);
-        return "create " + tableName;
+        String sql = "SHOW CREATE TABLE " + tableName;
+        return jdbcTemplate.queryForObject(sql, (rs, rowNum) -> rs.getString("Create Table"));
     }
 }