Function executeDatabaseQuery

src/tools/siyuan/database-query.ts:22–45

(params: DatabaseQueryParams)

// 执行数据库查询的函数
export async function executeDatabaseQuery(params: DatabaseQueryParams): Promise<DatabaseQueryResult> {
  try {
    const { stmt, limit, offset } = params;

    // 构建查询语句（如果需要分页）
    let queryStmt = stmt.trim();
    if (limit !== undefined) {
      queryStmt += ` LIMIT ${limit}`;
    }
    if (offset !== undefined) {
      queryStmt += ` OFFSET ${offset}`;
    }

    const result = await makeSiYuanRequest<DatabaseQueryResult>({
      endpoint: 'query/sql',
      data: { stmt: queryStmt },
    });

    return result;
  } catch (error) {
    logger.error('Database query execution failed', { stmt: params.stmt, error });
    throw error;
  }
}

// 注册数据库查询工具
export function registerDatabaseQueryTool(server: McpServer) {