OCI编程高级篇（八） LOB写操作

访问www.tomcoding.com网站，学习Oracle内部数据结构，详细文档说明，下载Oracle的exp/imp，DUL，logminer，ASM工具的源代码，学习高技术含量的内容。
上一节我们介绍了LOB定位符的绑定和定义操作，这里重点强调一下定义操作，这个行为一般用于LOB SELECT操作，LOB SELECT操作是所有LOB操作的基础，所有的关于LOB操作的OCI函数都是针对LOB定位符的，LOB SELECT的目的就是为了得到一个LOB定位符，一个LOB表的每行数据的每个LOB字段都对应一个LOB定位符，所以处理一行数据的多个LOB字段也要得到多个LOB定位符。下面看看LOB写操作的步骤。
1. 准备LOB SELECT语句，一般SQL语句文本为SELECT lob_column FROM lob_table WHERE XXXX=XXXX FOR UPDATE。
2. 定义输出的LOB定位符。这个定位符在之前要分配好，不用设置为空LOB。
3. 执行LOB SELECT语句。
4. 执行OCIStmtFetch()操作，把LOB定位符和LOB字段关联起来。
5. 打开LOB定位符，使用OCILobOpen()函数。
6. 写入LOB数据，可以循环写入多次LOB数据，使用OCILobWrite2()函数。
7. 关闭LOB定位符，使用OCILobClose()函数。
8. 提交数据库改变。
先看看用到的OCI函数原型和参数。
打开LOB函数。
sword OCILobOpen ( OCISvcCtx *svchp,
    OCIError           *errhp,
    OCILobLocator *locp,
    ub1                    mode );
svchp是一个输入参数，是OCI服务上下文句柄。
errhp是一个输入/输出参数，错误句柄，用于返回错误码和错误信息文本。
locp是一个输入/输出参数，需要打开的LOB定位符。
mode是一个输入参数，打开的方式，取值OCI_LOB_READONLY或OCI_LOB_READWRITE。
关闭LOB函数。
sword OCILobClose ( OCISvcCtx *svchp,
    OCIError           *errhp,
    OCILobLocator *locp );
svchp是一个输入参数，是OCI服务上下文句柄。
errhp是一个输入/输出参数，错误句柄，用于返回错误码和错误信息文本。
locp是一个输入/输出参数，需要关闭的LOB定位符。
写LOB函数。
sword OCILobWrite2 ( OCISvcCtx *svchp,
    OCIError           *errhp,
    OCILobLocator *locp,
    oraub8              *byte_amtp,
    oraub8              *char_amtp,
    oraub8              offset,
    void                   *bufp,
    oraub8               buflen,
    ub1                    piece,
    void                   *ctxp,
    OCICallbackLobWrite2 (cbfp)
    (
        void     *ctxp,
        void     *bufp,
        oraub8 *lenp,
        ub1      *piecep
        void      **changed_bufpp,
        oraub8 *changed_lenp
    )
    ub2                    csid,
    ub1                    csfrm );
svchp是一个输入/输出参数，是OCI服务上下文句柄。
errhp是一个输入/输出参数，错误句柄，用于返回错误码和错误信息文本。
locp是一个输入/输出参数，需要操作的LOB定位符，唯一引用一个LOB。
byte_amtp是一个输入/输出参数，写入LOB的字节数，在BLOB写入时使用。
char_amtp是一个输入/输出参数，写入LOB的字符个数，在CLOB写入时使用，BLOB写入时忽略这个参数。
offset是一个输入参数，写入LOB的绝对偏移量，从LOB头开始计算。对CLOB计算单位是字符，对BLOB计算单位是字节。offset的位置从1开始计算。如果使用流写入方式，只需要在第一次调用写函数时设置offset值，后续的写函数可以忽略offset，函数会自动判断。
bufp是一个输入参数，是写入的LOB数据的缓冲区指针。
buflen是一个输入参数，表示LOB数据缓冲区中数据的大小，以字节计算。
piece是一个输入参数，表示写入的是哪个数据片。取值为OCI_ONE_PIECE，流模式中为OCI_FIRST_PIECE，OCI_NEXT_PIECE和OCI_LAST_PIECE。
ctxp是一个输入参数，是回调函数的上下文指针，可以设置为NULL。
cbfp是一个输入参数，是回调函数的函数指针，不使用回调函数设置为NULL。
csid是一个输入参数，是缓冲区中数据的字符集ID，只对CLOB起作用。
csfrm是一个输入参数，是缓冲区数据的字符集形式，取值SQLCS_IMPLICIT表示与数据库字符集一致，取值SQLCS_NCHAR表示使用国际字符集。
我们使用上一节中创建的表test_clob_tab，里面已经插入一条空LOB数据，现在看看怎样写入LOB数据，我们向LOB中写入20次，每次写入4000字符，使用流模式写入。代码如下。
 
[code]OCIEnv        *envhp = NULL;OCIError    *errhp = NULL;OCIServer    *svrhp = NULL;OCISession    *usrhp = NULL;OCISvcCtx    *svchp = NULL;OCIStmt        *smthp = NULL;​​int write_to_lob(void){    int              i;    sword            rc;    sb4              ec;    ub1              piece;    int              slen;    oraub8           amt;    OCIDefine        *defp;    OCILobLocator    *locp;    char             sqltxt[1024];    text             errbuf[512];    char             buf[4096];    /* 分配LOB定位符 */    rc = OCIDescriptorAlloc((const void *)envhp, (void **)&locp,        OCI_DTYPE_LOB, 0, (void **)NULL);    if (rc != OCI_SUCCESS) {        OCIErrorGet(envhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCIDescriptorAlloc() - [%d] %s\n", ec, errbuf);        return (-1);    }    /* 下面执行LOB SELECT操作 */    strcpy(sqltxt, "SELECT MESSAGE FROM test_clob_tab WHERE ID=1 FOR UPDATE");    slen = strlen(sqltxt);    rc = OCIStmtPrepare(smthp, errhp, (const OraText *)sqltxt, slen,          OCI_NTV_SYNTAX, OCI_DEFAULT);    if (rc != OCI_SUCCESS) {        OCIErrorGet(errhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCIStmtPrepare() - [%d] %s\n", ec, errbuf);        return (-1);    }    /* 定义LOB定位符输出 */    rc = OCIDefineByPos((OCIStmt *)smthp,        (OCIDefine **)&defp,        (OCIError *)errhp,        (ub4)1,        (void *)&locp,        (sb4)sizeof(OCILobLocator *),        (ub2)SQLT_CLOB,        (void *)NULL,        (ub2 *)NULL,        (ub2 *)NULL,        (ub4)OCI_DEFAULT);    if (rc != OCI_SUCCESS) {        OCIErrorGet(errhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCIDefineByPos() - [%d] %s\n", ec, errbuf);        return (-1);    }    /* 执行语句 */    rc = OCIStmtExecute(svchp,           smthp,           /* stmthp */           errhp,           /* errhp */           0,               /* iters */           0,               /* rowoff */           NULL,            /* snap_in */           NULL,            /* snap_out */           OCI_DEFAULT);    /* mode */    if (rc != OCI_SUCCESS) {        OCIErrorGet(errhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCIExecute() - [%d] %s\n", ec, errbuf);        return (-1);    }    /* 执行fetch操作 */    rc = OCIStmtFetch(smthp, errhp, 1, OCI_FETCH_NEXT, OCI_DEFAULT);    if (rc != OCI_SUCCESS) {        OCIErrorGet(errhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCIStmtFetch() - [%d] %s\n", ec, errbuf);        return (-1);    }    /* 打开LOB */    rc = OCILobOpen(svchp, errhp, locp, OCI_LOB_READWRITE);    if (rc != OCI_SUCCESS) {        OCIErrorGet(errhp, 1, NULL, &ec, errbuf, 512, OCI_HTYPE_ERROR);        fprintf(stderr, "OCILobOpen() - [%d] %s\n", ec, errbuf);        return (-1);    }    for (i=0; i