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