备份 sql

init.sql

@@ -0,0 +1,771 @@
+-- 创建消息表
+drop table if exists lucene$message;
+create table lucene$message(
+    me_id bigint not null primary key auto_increment,
+    me_table_name varchar(64) not null,
+    me_method_type varchar(6) not null,
+    me_data_id int not null,
+    me_data text,
+    me_priority int default 0,
+    me_retry_count int default 0,
+    me_create_time datetime not null
+);
+
+-- 创建消息历史表
+drop table if exists lucene$message_history;
+create table lucene$message_history(
+    mh_id bigint not null primary key auto_increment,
+    mh_dequeue_time datetime not null,
+    me_id bigint not null,
+    me_table_name varchar(64) not null,
+    me_method_type varchar(6) not null,
+    me_data_id int not null,
+    me_data text,
+    me_priority int default 0,
+    me_create_time datetime not null
+);
+
+-- 创建存储过程 入队消息
+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)
+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());
+end;$$
+delimiter ;
+
+-- 创建存储过程 出队消息
+drop procedure if exists dequeue_lucene_message;
+delimiter $$
+create procedure dequeue_lucene_message(in v_id bigint)
+begin
+	insert into lucene$message_history (mh_dequeue_time, me_id, me_table_name, me_method_type, me_data_id, me_data, me_priority, me_create_time) select sysdate(), me_id, me_table_name, me_method_type, me_data_id, me_data, me_priority, me_create_time from lucene$message where me_id = v_id;
+	delete from lucene$message where me_id = v_id;
+end;$$
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$brand
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_brand_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_i` AFTER INSERT ON `product$brand` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$brand';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.br_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$brand
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_brand_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_u` AFTER UPDATE ON `product$brand` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$brand';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.br_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$brand
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_brand_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_brand_d` AFTER DELETE ON `product$brand` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$brand';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.br_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$component
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_component_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_i` AFTER INSERT ON `product$component` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.cmp_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    
+    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);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$component
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_component_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_u` AFTER UPDATE ON `product$component` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.cmp_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    
+    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);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$component
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_component_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_component_d` AFTER DELETE ON `product$component` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.cmp_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+    
+    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);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$kind
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_kind_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_i` AFTER INSERT ON `product$kind` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$kind';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.ki_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$kind
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_kind_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_u` AFTER UPDATE ON `product$kind` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$kind';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.ki_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$kind
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_kind_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_kind_d` AFTER DELETE ON `product$kind` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$kind';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.ki_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$propertyvalue
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_propertyvalue_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_i` AFTER INSERT ON `product$propertyvalue` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.pv_componentid;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$propertyvalue
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_propertyvalue_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_u` AFTER UPDATE ON `product$propertyvalue` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.pv_componentid;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table product$propertyvalue
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_propertyvalue_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_propertyvalue_d` AFTER DELETE ON `product$propertyvalue` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'product$component';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.pv_componentid;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table sec$enterprises
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_enterprises_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_i` AFTER INSERT ON `sec$enterprises` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'sec$enterprises';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.en_uu;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table sec$enterprises
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_enterprises_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_u` AFTER UPDATE ON `sec$enterprises` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'sec$enterprises';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.en_uu;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table sec$enterprises
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_enterprises_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_enterprises_d` AFTER DELETE ON `sec$enterprises` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'sec$enterprises';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.en_uu;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$goods
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_trade_goods_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_i` AFTER INSERT ON `trade$goods` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'v$product$cmpgoods';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default 'goId';
+    
+    set v_data_id=new.go_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$goods
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_trade_goods_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_u` AFTER UPDATE ON `trade$goods` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'v$product$cmpgoods';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default 'goId';
+    
+    set v_data_id=old.go_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$goods
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_trade_goods_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_trade_goods_d` AFTER DELETE ON `trade$goods` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'v$product$cmpgoods';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default 'goId';
+    
+    set v_data_id=old.go_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_i` AFTER INSERT ON `trade$invoice_fmor` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_u` AFTER UPDATE ON `trade$invoice_fmor` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_d` AFTER DELETE ON `trade$invoice_fmor` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_dt_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_i` AFTER INSERT ON `trade$invoice_fmor_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_dt_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_u` AFTER UPDATE ON `trade$invoice_fmor_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmor_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_inv_dt_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_inv_dt_d` AFTER DELETE ON `trade$invoice_fmor_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmor';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_i` AFTER INSERT ON `trade$invoice_fmpu` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_u` AFTER UPDATE ON `trade$invoice_fmpu` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_d` AFTER DELETE ON `trade$invoice_fmpu` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_dt_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_i` AFTER INSERT ON `trade$invoice_fmpu_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_dt_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_u` AFTER UPDATE ON `trade$invoice_fmpu_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$invoice_fmpu_dt
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_inv_dt_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_inv_dt_d` AFTER DELETE ON `trade$invoice_fmpu_dt` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$invoice_fmpu';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.invoice_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_i` AFTER INSERT ON `trade$order` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_u` AFTER UPDATE ON `trade$order` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_d` AFTER DELETE ON `trade$order` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_dt_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_i` AFTER INSERT ON `trade$order_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.order_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_dt_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_u` AFTER UPDATE ON `trade$order_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.order_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$order_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_order_dt_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_order_dt_d` AFTER DELETE ON `trade$order_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$order';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.order_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_i` AFTER INSERT ON `trade$purchase` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'insert';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_u` AFTER UPDATE ON `trade$purchase` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_d` AFTER DELETE ON `trade$purchase` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'delete';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_dt_i`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_i` AFTER INSERT ON `trade$purchase_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=new.purchase_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_dt_u`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_u` AFTER UPDATE ON `trade$purchase_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.purchase_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;
+
+-- ----------------------------
+-- Triggers structure for table trade$purchase_detail
+-- ----------------------------
+DROP TRIGGER IF EXISTS `lucene_purchase_dt_d`;
+delimiter ;;
+CREATE DEFINER = `root`@`%` TRIGGER `lucene_purchase_dt_d` AFTER DELETE ON `trade$purchase_detail` FOR EACH ROW begin
+	declare v_table_name varchar(64) default 'trade$purchase';
+    declare v_method_type varchar(6) default 'update';
+    declare v_data_id int;
+    declare v_data text default null;
+    
+    set v_data_id=old.purchase_id;
+    call enqueue_lucene_message(v_table_name, v_method_type, v_data_id, v_data);
+end
+;;
+delimiter ;