def METHOD_NAME(self, logger: AirbyteLogger, config: Mapping[str, Any]) -> AirbyteConnectionStatus:
    """
    Tests if the input configuration can be used to successfully connect to the destination with the needed permissions
        e.g: if a provided API token or password can be used to connect and write to the destination.
    :param logger: Logging object to display debug/info/error to the logs
        (logs will not be accessible via airbyte UI if they are not passed to this logger)
    :param config: Json object containing the configuration of this destination, content of this json is as specified in
    the properties of the spec.json file
    :return: AirbyteConnectionStatus indicating a Success or Failure
    """
    try:
        client = DatabendClient(**config)
        cursor = client.open()
        cursor.execute("DROP TABLE IF EXISTS test")
        cursor.execute("CREATE TABLE if not exists test (x Int32,y VARCHAR)")
        cursor.execute("INSERT INTO test (x,y) VALUES (%,%)", [1, "yy", 2, "xx"])
        cursor.execute("DROP TABLE IF EXISTS test")
        return AirbyteConnectionStatus(status=Status.SUCCEEDED)
    except Exception as e:
        return AirbyteConnectionStatus(status=Status.FAILED, message=f"An exception occurred: {repr(e)}")