【討論】帶參數(shù)的游標(biāo)的寫(xiě)法

voi-jia

比較表中 cell_id相同的記錄在兩個(gè)不同時(shí)間段發(fā)生的更新，如某項(xiàng)發(fā)生變化則記錄到另一個(gè)表 test_ne_change 中
開(kāi)始寫(xiě)的，效率極低

1. CREATE OR REPLACE PROCEDURE w_ne_change
   
2. AS
   
3. 
   
4.    CURSOR cur_new
   
5.    IS
   
6.       SELECT int_id, omc_id || ':' || msc_id || ':' || bsc_id AS related_id,
   
7.              omc_id, msc_id, bsc_id, ne_name, cell_id, lac, freq_band,
   
8.              trx_count, tch, sdcch, gprs_enabled, gprs_trx, dedicated_pdch,
   
9.              max_pdch, device_type, software_version, dumpfre_type, site_no,
   
10.              cell_no, rac, ncc, bcc, sms_cb_used, bsc_omc_int_id, omc_int_id,
    
11.              TIMESTAMP
    
12.         FROM appuser.W_C_CELL
    
13.        WHERE TIMESTAMP = '2004-04-23 8' AND cell_id < 200;
    
14. 
    
15.    CURSOR cur_old
    
16.    IS
    
17.       SELECT int_id, omc_id || ':' || msc_id || ':' || bsc_id AS related_id,
    
18.              omc_id, msc_id, bsc_id, ne_name, cell_id, lac, freq_band,
    
19.              trx_count, tch, sdcch, gprs_enabled, gprs_trx, dedicated_pdch,
    
20.              max_pdch, device_type, software_version, dumpfre_type, site_no,
    
21.              cell_no, rac, ncc, bcc, sms_cb_used, bsc_omc_int_id, omc_int_id,
    
22.              TIMESTAMP
    
23.         FROM appuser.W_C_CELL
    
24.        WHERE TIMESTAMP = '2004-04-23 6' AND cell_id < 200;
    
25. BEGIN
    
26.    FOR v_new IN cur_new
    
27.    LOOP
    
28.       FOR v_old IN cur_old
    
29.       LOOP
    
30.          IF v_old.cell_id = v_new.cell_id
    
31.          THEN
    
32.             BEGIN
    
33.                IF v_new.related_id <>; v_old.related_id
    
34.                THEN
    
35.                   INSERT INTO TEST_NE_CHANGE
    
36.                               (omc_id, omc_int_id,
    
37.                                ne_id, old_value,
    
38.                                now_value, modify_item,
    
39.                                modify_time
    
40.                               )
    
41.                        VALUES (v_new.omc_id, v_new.omc_int_id,
    
42.                                v_new.cell_id, v_old.related_id,
    
43.                                v_new.related_id, 'related_id',
    
44.                                v_new.TIMESTAMP
    
45.                               );
    
46. 
    
47.                   COMMIT;
    
48.                  
    
49.                END IF;
    
50.             END;
    
51.          END IF;
    
52.       END LOOP;
    
53.    END LOOP;
    
54. END;

復(fù)制代碼

效率太慢了，如果有一萬(wàn)條數(shù)據(jù)比較的話就超慢。高手們幫我看看吧

voi-jia

如此改了一下，效率高了不少 ：）

1. CREATE OR REPLACE PROCEDURE x_ne_change
   
2. AS
   
3.    CURSOR cur_new
   
4.    IS
   
5.       SELECT int_id, omc_id || ':' || msc_id || ':' || bsc_id AS related_id,
   
6.              omc_id, msc_id, bsc_id, ne_name, cell_id, lac, freq_band,
   
7.              trx_count, tch, sdcch, gprs_enabled, gprs_trx, dedicated_pdch,
   
8.              max_pdch, device_type, software_version, dumpfre_type, site_no,
   
9.              cell_no, rac, ncc, bcc, sms_cb_used, bsc_omc_int_id, omc_int_id,
   
10.              TIMESTAMP
    
11.         FROM appuser.K_C_CELL
    
12.        WHERE TIMESTAMP = '2004-04-23 8' AND cell_id < 2000;
    
13. 
    
14.    CURSOR cur_old (c_no NUMBER)
    
15.    IS
    
16.       SELECT int_id, omc_id || ':' || msc_id || ':' || bsc_id AS related_id,
    
17.              omc_id, msc_id, bsc_id, ne_name, cell_id, lac, freq_band,
    
18.              trx_count, tch, sdcch, gprs_enabled, gprs_trx, dedicated_pdch,
    
19.              max_pdch, device_type, software_version, dumpfre_type, site_no,
    
20.              cell_no, rac, ncc, bcc, sms_cb_used, bsc_omc_int_id, omc_int_id,
    
21.              TIMESTAMP
    
22.         FROM appuser.K_C_CELL
    
23.        WHERE TIMESTAMP = '2004-04-21 6' AND cell_id = c_no;
    
24. BEGIN
    
25.    FOR v_new IN cur_new
    
26.    LOOP
    
27.       FOR v_old IN cur_old (v_new.cell_id)
    
28.       LOOP
    
29.          BEGIN
    
30.             IF v_new.related_id <>; v_old.related_id
    
31.             THEN
    
32.                INSERT INTO TEST_NE_CHANGE
    
33.                            (omc_id, omc_int_id, ne_id,
    
34.                             old_value, now_value,
    
35.                             modify_item, modify_time
    
36.                            )
    
37.                     VALUES (v_new.omc_id, v_new.omc_int_id, v_new.cell_id,
    
38.                             v_old.related_id, v_new.related_id,
    
39.                             'related_id', v_new.TIMESTAMP
    
40.                            );
    
41. 
    
42.                COMMIT;
    
43.             END IF;
    
44. 
    
45.             IF v_new.tch <>; v_old.tch
    
46.             THEN
    
47.                INSERT INTO TEST_NE_CHANGE
    
48.                            (omc_id, omc_int_id, ne_id,
    
49.                             old_value, now_value, modify_item, modify_time
    
50.                            )
    
51.                     VALUES (v_new.omc_id, v_new.omc_int_id, v_new.cell_id,
    
52.                             v_old.tch, v_new.tch, 'TCH', v_new.TIMESTAMP
    
53.                            );
    
54. 
    
55.                COMMIT;
    
56.             END IF;
    
57.          END;
    
58.       END LOOP;
    
59.    END LOOP;
    
60. END;
    
61. /

復(fù)制代碼