Merge pull request #103 from schemacrawler/nextrel

Support streamable HTTP and resources

Author: sualeh

.github/README.md

@@ -1,6 +1,6 @@
 <!-- markdownlint-disable MD041 -->
 [![Quick Build](https://github.com/schemacrawler/SchemaCrawler-AI/workflows/Quick%20Build/badge.svg)](https://github.com/schemacrawler/SchemaCrawler-AI/actions?query=workflow%3A%22Quick+Build%22)
-
+[![Docker Pulls](https://img.shields.io/docker/pulls/schemacrawler/schemacrawler-ai?color=FFDAB9)](https://hub.docker.com/r/schemacrawler/schemacrawler-ai/)
 
 # <img src="https://raw.githubusercontent.com/schemacrawler/SchemaCrawler/main/schemacrawler-website/src/site/resources/images/schemacrawler_logo.png" height="100px" width="100px" valign="middle"/> SchemaCrawler - AI
 

.github/workflows/publish-mcp.yml

@@ -0,0 +1,34 @@
+name: Publish to MCP Registry
+
+on:
+  workflow_dispatch:
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    permissions:
+      id-token: write  # Required for OIDC authentication
+      contents: read
+
+    steps:
+
+      - id: install-mcp-publisher
+        name: Install MCP Publisher
+        run: |
+          curl -L "https://github.com/modelcontextprotocol/registry/releases/download/v1.0.0/mcp-publisher_1.0.0_$(uname -s | tr '[:upper:]' '[:lower:]')_$(uname -m | sed 's/x86_64/amd64/;s/aarch64/arm64/').tar.gz" | tar xz mcp-publisher
+
+      - id: checkout-code
+        name: Checkout code
+        uses: actions/checkout@v5
+
+      - id: publish-mcp-registry
+        name: Publish to MCP Registry
+        shell: bash
+        run: |
+          ./mcp-publisher login github-oidc
+          ./mcp-publisher publish \
+            --dry-run \
+            --file=./schemacrawler-ai-mcpserver/mcp-registration.json
+          ./mcp-publisher publish \
+            --file=./schemacrawler-ai-mcpserver/mcp-registration.json
+          ./mcp-publisher logout

Dockerfile

@@ -7,7 +7,7 @@
 # ========================================================================
 
 # Provided arguments
-ARG FROM_IMAGE=schemacrawler/schemacrawler:v16.28.1
+ARG FROM_IMAGE=schemacrawler/schemacrawler:v16.28.2
 
 # BUILDER stage - Build SchemaCrawler AI
 FROM maven:3.9-eclipse-temurin-21 AS builder

changelog.md

@@ -2,14 +2,21 @@
 
 SchemaCrawler AI release notes.
 
+<a name="v16.28.2-1"></a>
+## Release 16.28.2-1 - 2025-09-21
+
+- Support streamable HTTP protocol for MCP Server
+- Publish MCP resources for database object metadata
+
+
 <a name="v16.28.1-2"></a>
-## Release 16.28.1-2 - 2025-09-17
+## Release 16.28.2-2 - 2025-09-17
 
 - Add tags to publish to https://github.com/modelcontextprotocol/registry/
 
 
 <a name="v16.28.1-1"></a>
-## Release 16.28.1-1 - 2025-09-16
+## Release 16.28.2-1 - 2025-09-16
 
 - Refactor code to make it more idiomatic in the Spring Frameork
 - Format tool error messages in JSON

pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>us.fatehi</groupId>
   <artifactId>schemacrawler-ai-aggregator</artifactId>
-  <version>16.28.1-2</version>
+  <version>16.28.2-2</version>
   <packaging>pom</packaging>
   <name>SchemaCrawler AI [Aggregator]</name>
 

schemacrawler-ai-aichat/pom.xml

@@ -4,7 +4,7 @@
    <parent>
       <groupId>us.fatehi</groupId>
       <artifactId>schemacrawler-ai-parent</artifactId>
-      <version>16.28.1-2</version>
+      <version>16.28.2-2</version>
       <relativePath>../schemacrawler-ai-parent</relativePath>
    </parent>
    <artifactId>schemacrawler-ai-aichat</artifactId>

schemacrawler-ai-core/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>us.fatehi</groupId>
     <artifactId>schemacrawler-ai-parent</artifactId>
-    <version>16.28.1-2</version>
+    <version>16.28.2-2</version>
     <relativePath>../schemacrawler-ai-parent</relativePath>
   </parent>
 

schemacrawler-ai-core/src/main/java/schemacrawler/tools/ai/tools/AbstractFunctionDefinition.java

@@ -8,8 +8,9 @@
 
 package schemacrawler.tools.ai.tools;
 
+import static schemacrawler.tools.ai.utility.JsonUtility.mapper;
+
 import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.PropertyNamingStrategies.KebabCaseStrategy;
 
 public abstract class AbstractFunctionDefinition<P extends FunctionParameters>
@@ -44,7 +45,7 @@ private void buildToString() {
     try {
       final FunctionParameters parametersObject =
           getParametersClass().getDeclaredConstructor().newInstance();
-      parameters = new ObjectMapper().writeValueAsString(parametersObject);
+      parameters = mapper.writeValueAsString(parametersObject);
     } catch (final Exception e) {
       parameters =
           new KebabCaseStrategy()

schemacrawler-ai-core/src/main/java/schemacrawler/tools/ai/tools/FunctionCallback.java

@@ -9,11 +9,11 @@
 package schemacrawler.tools.ai.tools;
 
 import static java.util.Objects.requireNonNull;
+import static schemacrawler.tools.ai.utility.JsonUtility.mapper;
 import static schemacrawler.tools.ai.utility.JsonUtility.wrapException;
 import static us.fatehi.utility.Utility.isBlank;
 
 import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import java.sql.Connection;
 import java.util.Optional;
@@ -32,8 +32,6 @@ public final class FunctionCallback {
 
   private static final Logger LOGGER = Logger.getLogger(FunctionCallback.class.getCanonicalName());
 
-  private static ObjectMapper objectMapper = new ObjectMapper();
-
   private FunctionDefinition<FunctionParameters> functionDefinition;
   private final Catalog catalog;
 
@@ -71,9 +69,9 @@ public String execute(final String argumentsString, final Connection connection)
 
     requireNonNull(connection, "No database connection provided");
 
-    final PropertyName functionName = getFunctionName();
     LOGGER.log(
-        Level.INFO, new StringFormat("Executing%n%s", toObject(argumentsString).toPrettyString()));
+        Level.FINER,
+        new StringFormat("Executing%n%s", toCallObject(argumentsString).toPrettyString()));
 
     if (functionDefinition == null) {
       return "";
@@ -89,8 +87,7 @@ public String execute(final String argumentsString, final Connection connection)
           Level.INFO,
           e,
           new StringFormat(
-              "Could not call function with arguments: %s(%s)%n%s",
-              functionName, argumentsString, e.getMessage()));
+              "Exception executing: %s%n%s", toCallObject(argumentsString), e.getMessage()));
       return wrapException(e);
     }
   }
@@ -110,9 +107,31 @@ public PropertyName getFunctionName() {
     return functionName;
   }
 
+  public JsonNode toCallObject(final String argumentsString) {
+    final ObjectNode objectNode = mapper.createObjectNode();
+
+    final PropertyName functionName = getFunctionName();
+    objectNode.put("name", functionName.getName());
+
+    try {
+      final String functionArguments;
+      if (isBlank(argumentsString)) {
+        functionArguments = "{}";
+      } else {
+        functionArguments = argumentsString;
+      }
+      final JsonNode arguments = mapper.readTree(functionArguments);
+      objectNode.set("arguments", arguments);
+    } catch (final Exception e) {
+      objectNode.set("arguments", mapper.createObjectNode());
+    }
+
+    return objectNode;
+  }
+
   @Override
   public String toString() {
-    return toObject(null).toPrettyString();
+    return toCallObject(null).toPrettyString();
   }
 
   private String executeFunction(final FunctionParameters arguments, final Connection connection)
@@ -141,9 +160,8 @@ private <P extends FunctionParameters> P instantiateArguments(final String argum
     } else {
       functionArguments = argumentsString;
     }
-    final ObjectMapper objectMapper = new ObjectMapper();
     try {
-      final P parameters = objectMapper.readValue(functionArguments, parametersClass);
+      final P parameters = mapper.readValue(functionArguments, parametersClass);
       LOGGER.log(Level.FINE, String.valueOf(parameters));
       return parameters;
     } catch (final Exception e) {
@@ -156,26 +174,4 @@ private <P extends FunctionParameters> P instantiateArguments(final String argum
       return parametersClass.getDeclaredConstructor().newInstance();
     }
   }
-
-  private ObjectNode toObject(final String argumentsString) {
-    final ObjectNode objectNode = objectMapper.createObjectNode();
-
-    final PropertyName functionName = getFunctionName();
-    objectNode.put("name", functionName.getName());
-
-    try {
-      final String functionArguments;
-      if (isBlank(argumentsString)) {
-        functionArguments = "{}";
-      } else {
-        functionArguments = argumentsString;
-      }
-      final JsonNode arguments = objectMapper.readTree(functionArguments);
-      objectNode.set("arguments", arguments);
-    } catch (final Exception e) {
-      objectNode.set("arguments", objectMapper.createObjectNode());
-    }
-
-    return objectNode;
-  }
 }

schemacrawler-ai-core/src/main/java/schemacrawler/tools/ai/tools/ToolSpecification.java

@@ -8,8 +8,9 @@
 
 package schemacrawler.tools.ai.tools;
 
+import static schemacrawler.tools.ai.utility.JsonUtility.mapper;
+
 import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 
 public record ToolSpecification(String name, String description, JsonNode parameters) {
@@ -18,10 +19,8 @@ public String getParametersAsString() {
     return parameters.toPrettyString();
   }
 
-  private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
-
   public JsonNode getToolSpecification() {
-    final ObjectNode toolSpecification = OBJECT_MAPPER.createObjectNode();
+    final ObjectNode toolSpecification = mapper.createObjectNode();
     toolSpecification.put("name", name);
     toolSpecification.put("description", description);
     toolSpecification.set("parameters", parameters);