Baidu Vector Database MCP Server

Instructions

Select rows with a filter expression in the Mochow instance.

Args:
    table_name (str): Name of the table.
    filter_expr (str): Filter expression to select data. Defaults to None.
    limit (int): Maximum number of results. Defaults to 10.
    output_fields (Optional[list[str]]): Fields to return in the results. Defaults to None.

Returns:
    str: A string containing the selected rows.

Implementation Reference

• src/mochow_mcp_server/server.py:655-680 (handler)

  The main handler function for the 'select_table_rows' tool. It is registered via the @mcp.tool() decorator, receives parameters, calls the underlying connector method, and formats the results as a string.

  @mcp.tool()
  async def select_table_rows(
      table_name: str,
      filter_expr: str = None, 
      limit: int = 10,
      output_fields: Optional[list[str]] = None,
      ctx: Context = None,
  ) -> str:
      """
      Select rows with a filter expression in the Mochow instance.
  
      Args:
          table_name (str): Name of the table.
          filter_expr (str): Filter expression to select data. Defaults to None.
          limit (int): Maximum number of results. Defaults to 10.
          output_fields (Optional[list[str]]): Fields to return in the results. Defaults to None.
  
      Returns:
          str: A string containing the selected rows.
      """
      connector = ctx.request_context.lifespan_context.connector
      select_results = await connector.select_rows(table_name, filter_expr, limit, output_fields)
      output = f"Select rows results for '{table_name}':\n"
      for row in select_results.rows:
          output += f"{str(row)}\n"
      return output

• src/mochow_mcp_server/server.py:318-345 (helper)

  Helper method in MochowConnector class that performs the actual database query to select rows from a table using filter expression, limit, and output fields.

  async def select_rows(
      self,
      table_name: str,
      filter_expr: str = None,
      limit: int = 10,
      output_fields: Optional[list[str]] = None,
  ) -> HttpResponse:
      """
      Select rows in a given table using a filter expression.
  
      Args:
          table_name (str): Name of the table.
          filter_expr (str): Filter expression to select data.
          limit (int): Maximum number of results. Defaults to 10.
          output_fields (Optional[list[str]]): Fields to return in the results. Defaults to None.
  
      Returns:
          HttpResponse: The HTTP response containing the selected rows.
      """
      if self.database is None:
          raise ValueError("Switch to the database before select rows with filter expression.")
  
      # select data with filter expression
      try:
          return self.database.table(table_name).select(filter=filter_expr, projections=output_fields, limit=limit)
      except ServerError as e:
          raise ValueError(f"Failed to select data with filter expression: {str(e)}")