# File lib/rubyrep/replication_extenders/mysql_replication.rb, line 10
      def create_or_replace_replication_trigger_function(params)
        execute("DROP PROCEDURE IF EXISTS `\#{params[:trigger_name]}`;\n")
        
        activity_check = ""
        if params[:exclude_rr_activity] then
          activity_check = "DECLARE active INT;\nSELECT count(*) INTO active FROM \#{params[:activity_table]};\nIF active <> 0 THEN\nLEAVE p;\nEND IF;\n"
        end

        execute("CREATE PROCEDURE `\#{params[:trigger_name]}`(change_key varchar(2000), change_new_key varchar(2000), change_type varchar(1))\np: BEGIN\n\#{activity_check}\nINSERT INTO \#{params[:log_table]}(change_table, change_key, change_new_key, change_type, change_time)\nVALUES('\#{params[:table]}', change_key, change_new_key, change_type, now());\nEND;\n")
        
      end