Method getTableSchema

src/connectors/mysql/index.ts:354–393

(tableName: string, schema?: string)

  }

  async getTableSchema(tableName: string, schema?: string): Promise<TableColumn[]> {
    if (!this.pool) {
      throw new Error("Not connected to database");
    }

    try {
      // In MySQL, schema is synonymous with database
      // If no schema is provided, use the current database context via DATABASE() function
      // This means tables will be retrieved from whatever database the connection is currently using
      const schemaClause = schema ? "WHERE TABLE_SCHEMA = ?" : "WHERE TABLE_SCHEMA = DATABASE()";

      const queryParams = schema ? [schema, tableName] : [tableName];

      // Get table columns with comments
      const [rows] = (await this.pool.query(
        `
        SELECT
          COLUMN_NAME as column_name,
          DATA_TYPE as data_type,
          IS_NULLABLE as is_nullable,
          COLUMN_DEFAULT as column_default,
          COLUMN_COMMENT as description
        FROM INFORMATION_SCHEMA.COLUMNS
        ${schemaClause}
        AND TABLE_NAME = ?
        ORDER BY ORDINAL_POSITION
      `,
        queryParams
      )) as [any[], any];

      // Normalize empty string comments to null for token-efficient output
      return rows.map((row: any) => ({
        ...row,
        description: row.description || null,
      }));
    } catch (error) {
      console.error("Error getting table schema:", error);
      throw error;
    }
  }

  async getTableComment(tableName: string, schema?: string): Promise<string | null> {
    if (!this.pool) {