Method parse

src/connectors/mysql/index.ts:30–105

(dsn: string, config?: ConnectorConfig)

 */
class MySQLDSNParser implements DSNParser {
  async parse(dsn: string, config?: ConnectorConfig): Promise<mysql.ConnectionOptions> {
    const connectionTimeoutSeconds = config?.connectionTimeoutSeconds;
    // Capture this before the local `config` (mysql.ConnectionOptions) shadows the param below
    const timezone = config?.timezone;
    // Basic validation
    if (!this.isValidDSN(dsn)) {
      const obfuscatedDSN = obfuscateDSNPassword(dsn);
      const expectedFormat = this.getSampleDSN();
      throw new Error(
        `Invalid MySQL DSN format.\nProvided: ${obfuscatedDSN}\nExpected: ${expectedFormat}`
      );
    }

    try {
      // Use the SafeURL helper instead of the built-in URL
      // This will handle special characters in passwords, etc.
      const url = new SafeURL(dsn);

      const config: mysql.ConnectionOptions = {
        host: url.hostname,
        port: url.port ? parseInt(url.port) : 3306,
        database: url.pathname ? url.pathname.substring(1) : '', // Remove leading '/' if exists
        user: url.username,
        password: url.password,
        multipleStatements: true, // Enable native multi-statement support
        supportBigNumbers: true, // Return BIGINT as string when value exceeds Number.MAX_SAFE_INTEGER
      };

      // Handle query parameters
      url.forEachSearchParam((value, key) => {
        if (key === "sslmode") {
          if (value === "disable") {
            config.ssl = undefined;
          } else if (value === "require") {
            config.ssl = { rejectUnauthorized: false };
          } else {
            config.ssl = {};
          }
        }
        // Add other parameters as needed
      });

      // Apply connection timeout if specified
      if (connectionTimeoutSeconds !== undefined) {
        // mysql2 library expects connectTimeout in milliseconds
        config.connectTimeout = connectionTimeoutSeconds * 1000;
      }

      // Apply timezone if specified: controls how mysql2 interprets DATETIME values
      // ("Z", "local", or "±HH:MM"). Without it, mysql2 assumes "local", which can
      // produce an incorrect instant when the server timezone differs from the data's.
      if (timezone !== undefined) {
        config.timezone = timezone;
      }

      // Auto-detect AWS IAM authentication tokens and configure cleartext plugin
      // AWS RDS IAM tokens are ~800+ character strings containing "X-Amz-Credential"
      if (url.password && url.password.includes("X-Amz-Credential")) {