import { BaseTool } from './base.js';
import { TableInfo } from '../types.js';
import { ParameterValidator } from '../validation.js';
export class ListTablesTool extends BaseTool {
getName(): string {
return 'list_tables';
}
getDescription(): string {
return 'List all tables in the current database or specified schema';
}
getInputSchema(): any {
return {
type: 'object',
properties: {
schema: {
type: 'string',
description: 'Schema name to filter tables (optional)',
},
},
required: [],
};
}
async execute(params: { schema?: string }): Promise<TableInfo[]> {
const validatedParams = ParameterValidator.validateListTablesParameters(params);
const { schema } = validatedParams;
let query = `
SELECT
TABLE_CATALOG as table_catalog,
TABLE_SCHEMA as table_schema,
TABLE_NAME as table_name,
TABLE_TYPE as table_type
FROM INFORMATION_SCHEMA.TABLES
WHERE TABLE_TYPE = 'BASE TABLE'
`;
if (schema) {
const escapedSchema = ParameterValidator.escapeIdentifier(schema);
query += ` AND TABLE_SCHEMA = ${escapedSchema}`;
}
query += ' ORDER BY TABLE_SCHEMA, TABLE_NAME';
return await this.executeSafeQuery<TableInfo>(query);
}
}
