UniCloudDB-MCP

Implementation Reference

• database.js:285-299 (handler)

  Handler function for the 'update' MCP tool. Extracts parameters and calls the core updateDatabase function, formatting the response for MCP.
  async function handleUpdateTool(params, dbUrl) { const { collection, where, data } = params; try { const result = await updateDatabase(collection, where, data, dbUrl); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }], }; } catch (error) { return { content: [{ type: 'text', text: error.message }], isError: true, }; } }
• database.js:403-410 (schema)

  Schema definition for the 'update' tool parameters using Zod: collection (string), where (record), data (record).
  updateTool: { name: 'update', params: { collection: z.string().describe('集合名称'), where: z.record(z.any()).describe('查询条件 (JQL格式)'), data: z.record(z.any()).describe('要更新的数据 (object)'), }, handler: (params) => handleUpdateTool(params, dbServiceUrl),
• database.js:367-423 (registration)

  Tool definitions including the 'update' tool registration with name, params schema, and handler reference within getToolDefinitions.
  function getToolDefinitions(z, options = {}) { // 如果有传入dbServiceUrl则优先使用，否则使用配置 const dbServiceUrl = options.dbServiceUrl || DEFAULT_DB_URL; return { // 查询工具 queryTool: { name: 'query', params: { collection: z.string().describe('集合名称'), where: z.record(z.any()).describe('查询条件 (JQL格式)'), field: z.record(z.any()).optional().describe('返回字段 (可选)'), orderBy: z .object({ field: z.string(), order: z.enum(['asc', 'desc']), }) .optional() .describe('排序条件 (可选)'), limit: z.number().optional().describe('限制返回数量 (可选)'), skip: z.number().optional().describe('跳过记录数 (可选)'), }, handler: (params) => handleQueryTool(params, dbServiceUrl), }, // 添加工具 addTool: { name: 'add', params: { collection: z.string().describe('集合名称'), data: z.record(z.any()).describe('要添加的数据 (object/array)'), }, handler: (params) => handleAddTool(params, dbServiceUrl), }, // 更新工具 updateTool: { name: 'update', params: { collection: z.string().describe('集合名称'), where: z.record(z.any()).describe('查询条件 (JQL格式)'), data: z.record(z.any()).describe('要更新的数据 (object)'), }, handler: (params) => handleUpdateTool(params, dbServiceUrl), }, // 删除工具 removeTool: { name: 'remove', params: { collection: z.string().describe('集合名称'), where: z.record(z.any()).describe('查询条件 (JQL格式)'), }, handler: (params) => handleRemoveTool(params, dbServiceUrl), }, }; }
• index.js:47-50 (registration)

  Final MCP server registration of the 'update' tool using server.tool() with name, params, and handler from database.js tools.
  tools.updateTool.name, tools.updateTool.params, tools.updateTool.handler );
• database.js:136-172 (helper)

  Core helper function that performs the actual database update by sending a POST request to the uniCloud DB service with JQL operation.
  async function updateDatabase(collection, where, data, dbUrl = DEFAULT_DB_URL) { try { const controller = new AbortController(); const timeoutId = setTimeout(() => controller.abort(), REQUEST_TIMEOUT); // 使用传入的dbUrl或默认URL const targetUrl = dbUrl || DEFAULT_DB_URL; // console.log('更新操作使用URL:', targetUrl); const response = await fetch(targetUrl, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ operation: { collection, action: 'update', where, data, }, }), signal: controller.signal, }); clearTimeout(timeoutId); const result = await response.json(); if (result.code !== 0) { throw new Error(result.msg || '更新失败'); } return result.data; } catch (error) { if (error.name === 'AbortError') { throw new Error(`更新超时: 请求超过${REQUEST_TIMEOUT}毫秒`); } throw new Error(`更新错误: ${error.message}`); }