Function getMySQLConnection

src/lib/connectors/mysql/index.ts:8–45

(connection: Connection)

const systemDatabases = ["information_schema", "mysql", "performance_schema", "sys"];

const getMySQLConnection = async (connection: Connection): Promise<mysql.Connection> => {
  const connectionOptions: ConnectionOptions = {
    host: connection.host,
    port: parseInt(connection.port),
    user: connection.username,
    password: connection.password,
    database: connection.database,
  };
  if (connection.ssl) {
    connectionOptions.ssl = {
      ca: connection.ssl?.ca,
      cert: connection.ssl?.cert,
      key: connection.ssl?.key,
    };
  } else {
    // rejectUnauthorized=false to infer sslmode=prefer since hosted MySQL venders have SSL enabled.
    connectionOptions.ssl = {
      rejectUnauthorized: false,
    };
  }

  let conn;
  if (connection.ssl) {
    conn = await mysql.createConnection(connectionOptions);
  } else {
    try {
      conn = await mysql.createConnection(connectionOptions);
    } catch (error) {
      if (error instanceof Error && error.message.includes("Server does not support secure")) {
        connectionOptions.ssl = undefined;
        conn = await mysql.createConnection(connectionOptions);
      } else {
        throw error;
      }
    }
  }
  return conn;
};

const testConnection = async (connection: Connection): Promise<boolean> => {
  const conn = await getMySQLConnection(connection);