Class MySQLConnector

src/connectors/mysql/index.ts:123–687

 * MySQL Connector Implementation
 */
export class MySQLConnector implements Connector {
  id: ConnectorType = "mysql";
  name = "MySQL";
  dsnParser = new MySQLDSNParser();

  private pool: mysql.Pool | null = null;
  // Source ID is set by ConnectorManager after cloning
  private sourceId: string = "default";
  private queryTimeoutMs?: number;

  getId(): string {
    return this.sourceId;
  }

  clone(): Connector {
    return new MySQLConnector();
  }

  async connect(dsn: string, initScript?: string, config?: ConnectorConfig): Promise<void> {
    try {
      const connectionOptions = await this.dsnParser.parse(dsn, config);
      this.pool = mysql.createPool(connectionOptions);

      // Store query timeout for per-query application
      if (config?.queryTimeoutSeconds !== undefined) {
        this.queryTimeoutMs = config.queryTimeoutSeconds * 1000;
      }

      // Test the connection
      const [rows] = await this.pool.query("SELECT 1");
    } catch (err) {
      console.error("Failed to connect to MySQL database:", err);
      throw err;
    }
  }

  async disconnect(): Promise<void> {
    if (this.pool) {
      await this.pool.end();
      this.pool = null;
    }
  }

  async getSchemas(): Promise<string[]> {
    if (!this.pool) {
      throw new Error("Not connected to database");
    }

    try {
      // In MySQL, schemas are equivalent to databases. Exclude server-level
      // system databases so the list matches the user-facing schemas only
      // (parity with the PostgreSQL connector, which hides pg_catalog et al.).
      const [rows] = (await this.pool.query(`
        SELECT SCHEMA_NAME
        FROM INFORMATION_SCHEMA.SCHEMATA
        WHERE SCHEMA_NAME NOT IN ('information_schema', 'performance_schema', 'mysql', 'sys')
        ORDER BY SCHEMA_NAME
      `)) as [any[], any];