mceachen/with_advisory_lock

# frozen_string_literal: true

module WithAdvisoryLock
  class MySQL < Base
    # See https://dev.mysql.com/doc/refman/5.7/en/locking-functions.html
    # See https://dev.mysql.com/doc/refman/8.0/en/locking-functions.html
    def try_lock
      raise ArgumentError, 'shared locks are not supported on MySQL' if shared
      raise ArgumentError, 'transaction level locks are not supported on MySQL' if transaction

      execute_successful?("GET_LOCK(#{quoted_lock_str}, 0)")
    end

    def release_lock
      execute_successful?("RELEASE_LOCK(#{quoted_lock_str})")
    end

    def execute_successful?(mysql_function)
      execute_query(mysql_function) == 1
    end

    def execute_query(mysql_function)
      sql = "SELECT #{mysql_function}"
      connection.query_value(sql)
    end

    # MySQL wants a string as the lock key.
    def quoted_lock_str
      connection.quote(lock_str)
    end
  end
end