Effizientes und schnelles Einfügen oder Verändern von Daten ist mittlerweile eine unverzichtbares Ziel von Datenbankanwendungen. Die entsprechende Performance kann beispielsweise durch zusätzliche Parallelisierung, Reduzierung von Table Scans oder durch Umgehung des Buffer Caches mit Direct Writes gewonnen werden. Im folgenden Beitrag werden einige interessante Aspekte zum Thema DML-Operationen erläutert, neue Features in 11g Release 2 aufgezeigt und speziell das Thema Umgang mit Parallel DML erläutert.

DML Operationen: einige Aspekte
Ob DML Operationen effizient durchgeführt werden, kann von einigen Faktoren abhängen. So hat der Umgang mit den zur Verfügung stehenden Ressourcen wichtige Auswirkungen. Folgende Faktoren können dabei eine Rolle spielen: Database Buffer Cache Nutzung, Parallelisierung von Operationen und Prozessen, Anzahl von Tabellenscans, die Menge an erzeugten Redo-Informationen wie auch der Einsatz von COMMIT Operationen.
Ein Blick in das Oracle SQL Language Reference Handbuch gibt einen ersten Eindruck über die Vielfalt der Möglichkeiten, DML- Statements abzusetzen. Sollen Daten über SQL geladen werden und ist man an keinen SQL Standard (z.B. SQL:2008) gebunden, lohnt sich auf jeden Fall der Einsatz von entsprechenden Erweiterungen. Mehr Performance, höhere Effizienz oder größere Funktionalität können dann das Ergebnis sein. Kenntnisse über folgende Syntax und Techniken sind auf jeden Fall hilfreich.

• Multi Table INSERT
• Direktes (DIRECT LOAD) oder konventionelles Ladeverfahren
• DML Error Logging
• Bulk Load bei PL/SQL Nutzung
• Einsatz von asynchronem COMMIT
• Parallelisierung

/* Ohne Hint */
SQL> INSERT INTO products SELECT * FROM products;
insert into products select * from products
*
ERROR at line 1:
ORA-00001: unique constraint (SH.PRODUCTS_PK) violated 

/* Mit Hint */
SQL> INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(products(prod_id))*/ INTO products SELECT * FROM products;
0 rows created.

-- optional: zusaetzliche Komprimierung einschalten
ALTER TABLE tab_comp COMPRESS BASIC;
-- bulk load mit Pl/SQL
DECLARE
type numlist IS TABLE OF NUMBER INDEX BY BINARY_INTEGER;
prod_ids NumList;
BEGIN
  FOR i IN 1..200000 LOOP 
       prod_ids(i) := i;
  END LOOP;
  FORALL j IN 100..200000 
INSERT /*+ append_values */ INTO tab_comp  VALUES (prod_ids(j),sysdate,'YYYYYYYYYYYYYYYYYYYYY');
END;
/

• Einschalten der Parallelisierung mit ALTER SESSION FORCE PARALLEL DML und
• Anzeigen der Parallelisierung - durch den PARALLEL Hint oder durch die Tabelleneigenschaft PARALLEL.

-- Tabelle ist nicht partitioniert
SQL> SELECT partitioned, degree FROM user_tables
  2  WHERE table_name='SALES';
PAR DEGREE
--- ----------
YES          1

SQL> ALTER SESSION FORCE PARALLEL DML;
Session altered.

SQL> INSERT /*+ parallel(sales,2) */ INTO sales SELECT * FROM sales;

• Keine weiteren seriellen oder parallelen Operationen können in der gleichen Transaktion auf der Tabelle durchgeführt werden. Die Transaktion muss vorher abgeschlossen werden.
• Einschränkungen: Keine Unterstützung von Integritätsconstraints, von Triggern, Clustertabellen usw..
• INSERT VALUES Operationen können nicht parallelisiert werden.
• Parallele Operationen auf Tabellen mit LOBs können nur auf partitionierten Tabellen erfolgen.
Wird gegen die Einschränkungen (in Bullet 2) verstossen, wird automatisch ohne Fehlermeldung in den konventionellen Modus umgeschaltet. Detaillierte Informationen zu den Einschränkungen finden sich im Handbuch Oracle Database VLDB and Partitioning Guide 11g Release 2 (11.2)

• Das Ausschalten der Redo Generierung wird möglich: Dazu muss die Tabelle mit der Eigenschaft NOLOGGING erzeugt werden.
• Daten können komprimiert eingefügt werden: Hierfür muss die Tabelle mit der Eigenschaft COMPRESS BASIC erzeugt werden.
• Der Platzbedarf erhöht sich.

1. Das Anlegen einer Aufgabe (auch Task) mit CREATE_TASK.
2. Die Aufteilung der Tabelle in Teilbereiche (auch Chunks) durch eine definierte Methode. Zur Verfügung steht die ROWID-, die Spaltenwert- oder die SELECT- Methode.
3. Der Ablauf des Statements mit RUN_TASK in den definierten Chunk-Bereichen.

 
DECLARE
  l_task     VARCHAR2(30) := 'test_task';
  l_sql_stmt VARCHAR2(32767);
  l_try      NUMBER;
  l_status   NUMBER;
BEGIN
  DBMS_PARALLEL_EXECUTE.create_task (task_name => l_task);
  DBMS_PARALLEL_EXECUTE.create_chunks_by_rowid(task_name   => l_task,
                                               table_owner => 'SCOTT',
                                               table_name  => 'TEST_TAB',
                                               by_row      => TRUE,
                                               chunk_size  => 10000);
  l_sql_stmt := 'UPDATE /*+ MONITOR */test_tab t SET t.num_col = t.num_col 
                 + 10 WHERE rowid BETWEEN :start_id AND :end_id';
  DBMS_PARALLEL_EXECUTE.run_task(task_name      => l_task,
                                 sql_stmt       => l_sql_stmt,
                                 language_flag  => DBMS_SQL.NATIVE,
                                 parallel_level => 10);
  DBMS_PARALLEL_EXECUTE.drop_task(l_task);
END;
/

SQL> SELECT job_name, start_rowid, end_rowid, status 
     FROM dba_parallel_execute_chunks ORDER BY 1;

JOB_NAME       START_ROWID        END_ROWID          STATUS
-------------- ------------------ ------------------ --------------------
TASK$_1300_1   AAAWkpAAFAAFTIAAAA AAAWkpAAFAAFTIxCcP ASSIGNED
TASK$_1300_1   AAAWkpAAFAAFS2yAAA AAAWkpAAFAAFS3jCcP PROCESSED
TASK$_1300_1   AAAWkpAAFAAFTAAAAA AAAWkpAAFAAFTAxCcP PROCESSED
TASK$_1300_1   AAAWkpAAFAAFStkAAA AAAWkpAAFAAFSt/CcP PROCESSED
TASK$_1300_10  AAAWkpAAFAAFS2AAAA AAAWkpAAFAAFS2xCcP PROCESSED
...
TASK$_1300_9   AAAWkpAAFAAFS3kAAA AAAWkpAAFAAFS3/CcP PROCESSED
TASK$_1300_9   AAAWkpAAFAAFS/kAAA AAAWkpAAFAAFS//CcP PROCESSED
TASK$_1300_9   AAAWkpAAFAAFTJkAAA AAAWkpAAFAAFTJ/CcP PROCESSED
               AAAWkpAAFAAFSbAAAA AAAWkpAAFAAFSbHCcP UNASSIGNED
               AAAWkpAAFAAFTQyAAA AAAWkpAAFAAFTRjCcP UNASSIGNED
               AAAWkpAAFAAFSbQAAA AAAWkpAAFAAFSbXCcP UNASSIGNED
...
73 rows selected.

Zurück zur Community-Seite