Oracle导出CSV文件

-- 建立存储过程
CREATE OR REPLACE PROCEDURE SQL_TO_CSV

    (

        P_QUERY IN VARCHAR2,                        -- PLSQL文

        P_DIR IN VARCHAR2,                          -- 导出的文件放置目录

        P_FILENAME IN VARCHAR2                      -- CSV名

)

IS

        L_OUTPUT UTL_FILE.FILE_TYPE;

        L_THECURSOR INTEGER DEFAULT DBMS_SQL.OPEN_CURSOR;

        L_COLUMNVALUE VARCHAR2(4000);

        L_STATUS INTEGER;

        L_COLCNT NUMBER := 0;

        L_SEPARATOR VARCHAR2(1);

        L_DESCTBL DBMS_SQL.DESC_TAB;

        P_MAX_LINESIZE NUMBER := 32000;

BEGIN

        --OPEN FILE

        L_OUTPUT := UTL_FILE.FOPEN(P_DIR, P_FILENAME, 'W', P_MAX_LINESIZE);

 

        --DEFINE DATE FORMAT

        EXECUTE IMMEDIATE 'ALTER SESSION SET NLS_DATE_FORMAT=''YYYY-MM-DD HH24:MI:SS''';

 

        --OPEN CURSOR

        DBMS_SQL.PARSE( L_THECURSOR, P_QUERY, DBMS_SQL.NATIVE );

        DBMS_SQL.DESCRIBE_COLUMNS( L_THECURSOR, L_COLCNT, L_DESCTBL );

 

        --DUMP TABLE COLUMN NAME

        FOR I IN 1 .. L_COLCNT LOOP

            UTL_FILE.PUT( L_OUTPUT, L_SEPARATOR || '”' || L_DESCTBL(I).COL_NAME || '”' );

            DBMS_SQL.DEFINE_COLUMN( L_THECURSOR, I, L_COLUMNVALUE, 4000 );

            L_SEPARATOR := ',';

        END LOOP;

        UTL_FILE.NEW_LINE( L_OUTPUT );

 

        --EXECUTE THE QUERY STATEMENT

        L_STATUS := DBMS_SQL.EXECUTE(L_THECURSOR);

 

        --DUMP TABLE COLUMN VALUE

        WHILE ( DBMS_SQL.FETCH_ROWS(L_THECURSOR) > 0 ) LOOP

            L_SEPARATOR := '';

            FOR I IN 1 .. L_COLCNT LOOP

                DBMS_SQL.COLUMN_VALUE( L_THECURSOR, I, L_COLUMNVALUE );

                UTL_FILE.PUT( L_OUTPUT, L_SEPARATOR || '”' ||

                TRIM(BOTH ' ' FROM REPLACE(L_COLUMNVALUE,'”','””')) || '”');

                L_SEPARATOR := ',';

            END LOOP;

            UTL_FILE.NEW_LINE( L_OUTPUT );

        END LOOP;

 

        --CLOSE CURSOR

        DBMS_SQL.CLOSE_CURSOR(L_THECURSOR);

 

        --CLOSE FILE

        UTL_FILE.FCLOSE( L_OUTPUT );

EXCEPTION

        WHEN OTHERS THEN

        RAISE;

END;
/

-- 创建存放文件的目录
CREATE OR REPLACE DIRECTORY MYDIR AS 'C:';


-- 执行块
 begin

    sql_to_csv('select * from au_jxs ','MYDIR','EXAMPLE.CSV');

 end;
/