mysql 对于业务较为复杂的功能,我们常常使用存储过程进行编辑数据库的操作,当我们在进行数据库的操作时,进行着函数的嵌套或者是数据的算法较为复杂时,
我们怎么样在一个事物中进行数据的处理呢。
一:错误的方案:
insert into ..select 嵌套复杂的算法 from ..
INSERT INTO `inp_bill_detail` (`id`, `patient_id`, `visit_id`, `item_class`, `item_name`, `item_spec`, `item_code`, `amount`, `units`, `item_price`, `costs`, `charges`, `price_quotiety`, `order_dept`, `order_doctor`, `perform_dept`, `perform_person`, `class_on_reckoning`, `subj_code`, `class_on_mr`, `dept_stayed`, `ward_code`, `orders_id`, `org_id`, `del_flag`, `create_by`, `create_date`, `update_by`, `update_date`, `remarks`, `storage_id`, `price_id`, `source_type`) SELECT UUID(), `patient_id`, `visit_id`, `item_class`, `item_name`, `item_spec`, `item_code`, clinic_times*amount*IF((repeat_incaditor = '0'),1,IF((get_bill_type(freq_interval_unit)='0'),get_times_hour(freq_interval,last_accting_date,get_start_time(last_accting_date,start_date),pre_discharge_date),IF((get_bill_type(freq_interval_unit)='1'),get_times_day(freq_interval,freq_counter,last_accting_date,get_start_time(last_accting_date,start_date)),get_times_weeek(last_accting_date,nurse_perform_time)))) , `units`, `price`, clinic_times*price*amount*IF((repeat_incaditor = '0'),1,IF((get_bill_type(freq_interval_unit)='0'),get_times_hour(freq_interval,last_accting_date,get_start_time(last_accting_date,start_date),pre_discharge_date),IF((get_bill_type(freq_interval_unit)='1'),get_times_day(freq_interval,freq_counter,last_accting_date,get_start_time(last_accting_date,start_date)),get_times_weeek(last_accting_date,nurse_perform_time)))) , clinic_times*price*amount*IF((repeat_incaditor = '0'),1,IF((get_bill_type(freq_interval_unit)='0'),get_times_hour(freq_interval,last_accting_date,get_start_time(last_accting_date,start_date),pre_discharge_date),IF((get_bill_type(freq_interval_unit)='1'),get_times_day(freq_interval,freq_counter,last_accting_date,get_start_time(last_accting_date,start_date)),get_times_weeek(last_accting_date,nurse_perform_time)))) , 1, `new_dept`, create_by, `performed_by`, '', #`perform_person`, `class_on_reckoning`, subj_code, `class_on_mr`, `ward_code`, `ward_code`, orders_id,#`orders_id`, `org_id`, 0, temp, NOW(), 0000, NOW(), '自动计费', '', `price_id`, '5' FROM v_bill_items WHERE ward_code IS NOT NULL ;
此种方案虽然看着简单,实际上当算法的时间较为慢时 最为可能产生数据库的死锁问题。使得其他线程不能对相关的数据库表的访问。
原因分析:
当使用insert...select...进行记录的插入时,如果select的表是innodb类型的,不论insert的表是什么类型的表,都会对select的表的纪录进行锁定。
二:使用游标进行便利循环插入
三: 使用group_concat 函数进行连接insert 字符串 统一进行数据的保存操作,效率最高。