specify the priority for different tables

mall-search/init.sql

@@ -28,9 +28,9 @@ create table lucene$message_history(
 -- 创建存储过程 入队消息
 drop procedure if exists enqueue_lucene_message;
 delimiter $$
-create procedure enqueue_lucene_message(in v_table_name varchar(64), v_method_type varchar(6), v_data_id int, v_data text)
+create procedure enqueue_lucene_message(in v_table_name varchar(64), v_method_type varchar(6), v_data_id int, v_data text, v_priority int)
 begin
-	insert into lucene$message (me_table_name, me_method_type, me_data_id, me_data, me_create_time) values(v_table_name, v_method_type, v_data_id, v_data, sysdate());
+	insert into lucene$message (me_table_name, me_method_type, me_data_id, me_data, me_priority, me_create_time) values(v_table_name, v_method_type, v_data_id, v_data, v_priority, sysdate());
 end;$$
 delimiter ;
 
@@ -54,9 +54,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_i` AFTER INSERT ON `product$br
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.br_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -71,9 +72,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_u` AFTER UPDATE ON `product$br
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.br_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -88,9 +90,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_d` AFTER DELETE ON `product$br
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.br_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -105,13 +108,14 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_i` AFTER INSERT ON `produc
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=new.cmp_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
-    
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
+
     set v_table_name='v$product$cmpgoods';
     set v_data='cmpId';
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -126,13 +130,14 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_u` AFTER UPDATE ON `produc
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.cmp_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
-    
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
+
     set v_table_name='v$product$cmpgoods';
     set v_data='cmpId';
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -147,13 +152,14 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_d` AFTER DELETE ON `produc
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.cmp_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
-    
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
+
     set v_table_name='v$product$cmpgoods';
     set v_data='cmpId';
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -168,9 +174,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_i` AFTER INSERT ON `product$kin
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.ki_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -185,9 +192,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_u` AFTER UPDATE ON `product$kin
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.ki_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -202,9 +210,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_d` AFTER DELETE ON `product$kin
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.ki_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -219,9 +228,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_i` AFTER INSERT ON `pr
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=new.pv_componentid;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -236,9 +246,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_u` AFTER UPDATE ON `pr
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.pv_componentid;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -253,9 +264,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_d` AFTER DELETE ON `pr
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.pv_componentid;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -270,9 +282,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_i` AFTER INSERT ON `sec$
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.en_uu;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -287,9 +300,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_u` AFTER UPDATE ON `sec$
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.en_uu;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -304,9 +318,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_d` AFTER DELETE ON `sec$
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.en_uu;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -321,9 +336,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_i` AFTER INSERT ON `trad
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default 'goId';
-    
+    declare v_priority int default 0;
+
     set v_data_id=new.go_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -338,9 +354,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_u` AFTER UPDATE ON `trad
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default 'goId';
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.go_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -355,9 +372,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_d` AFTER DELETE ON `trad
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default 'goId';
-    
+    declare v_priority int default 0;
+
     set v_data_id=old.go_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -372,9 +390,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_i` AFTER INSERT ON `trade$
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -389,9 +408,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_u` AFTER UPDATE ON `trade$
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -406,9 +426,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_d` AFTER DELETE ON `trade$
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -423,9 +444,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_i` AFTER INSERT ON `tra
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -440,9 +462,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_u` AFTER UPDATE ON `tra
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -457,9 +480,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_d` AFTER DELETE ON `tra
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -474,9 +498,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_i` AFTER INSERT ON `tra
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -491,9 +516,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_u` AFTER UPDATE ON `tra
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -508,9 +534,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_d` AFTER DELETE ON `tra
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -525,9 +552,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_i` AFTER INSERT ON `
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -542,9 +570,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_u` AFTER UPDATE ON `
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -559,9 +588,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_d` AFTER DELETE ON `
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.invoice_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -576,9 +606,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_i` AFTER INSERT ON `trade$orde
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -593,9 +624,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_u` AFTER UPDATE ON `trade$orde
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -610,9 +642,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_d` AFTER DELETE ON `trade$orde
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -627,9 +660,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_i` AFTER INSERT ON `trade$o
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.order_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -644,9 +678,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_u` AFTER UPDATE ON `trade$o
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.order_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -661,9 +696,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_d` AFTER DELETE ON `trade$o
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.order_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -678,9 +714,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_i` AFTER INSERT ON `trade$p
     declare v_method_type varchar(6) default 'insert';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -695,9 +732,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_u` AFTER UPDATE ON `trade$p
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -712,9 +750,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_d` AFTER DELETE ON `trade$p
     declare v_method_type varchar(6) default 'delete';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -729,9 +768,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_i` AFTER INSERT ON `trad
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=new.purchase_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -746,9 +786,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_u` AFTER UPDATE ON `trad
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.purchase_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;
@@ -763,9 +804,10 @@ CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_d` AFTER DELETE ON `trad
     declare v_method_type varchar(6) default 'update';
     declare v_data_id int;
     declare v_data text default null;
-    
+    declare v_priority int default 1;
+
     set v_data_id=old.purchase_id;
-    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data, v_priority);
 end
 ;;
 delimiter ;