oracle图片大于32k,运用ORACLE的OO4O类库函数解决调用存储过程向远程数据库上传超过32K图片失败的问题...

前段时间尝试用了ODBC和ADO连接并上传图片都没能超过32K限制，最近用了OO4O终于解决了这个问题。方法及代码如下：

1 下载客户端

ORACLE官方下载链接：http://download.oracle.com/otn/other/ole-oo4o/ODAC101040.exe

2 安装并配置：

解压后，双击/disk/setup.exe，一路下一步，直到出现如下界面，并按图的顺序一路配置：

图1 直接点下一步

图2  点下一步

图3 在文本内输入服务名

........................

实在贴不动了，依照顺序输入：协议，远程数据库IP，端口，用户名，口令然后点确定，完成 本地NET服务名配置(也可以直接跳过此配置，在以后通过开始->程序->Oracle - OraClient10g_home1->Configuration and Migration Tools->Net Configuration Assistant 工具配置)。

3. 代码：(该代码调试通过)

#include "stdafx.h"

#include

#include

#include

#include

// Example for OParameter, OParamArray Raw example

int main()

{

//Initialize oo4o, connect, execute sql

OStartup();

ODatabase odb("NLV", "NLV_GUEST", "GUEST");

if (!odb.IsOpen())

{

cout <

return 1;

}

else cout << "Connect DataBase OK!" << endl;

//Init Parameters

OParameterCollection params = odb.GetParameters();

OParameter hpzl = params.Add("hpzl", "5", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter hphm = params.Add("hphm", "粤C00009", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter wfsj = params.Add("wfsj", "2008-08-19 09:04:45", OPARAMETER_INVAR, OTYPE_DATE);

OParameter wfxw = params.Add("wfxw", "16037", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter wfdd = params.Add("wfdd", "60108", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter wfdz = params.Add("wfdz", "新增路口", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter cjjg = params.Add("cjjg", "3707860100", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter sjly = params.Add("sjly", "2", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter zplx = params.Add("zplx", "1", 1, OPARAMETER_INVAR, OTYPE_CHAR);

OParameter sbbh = params.Add("sbbh", "37078610045", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter cdbh = params.Add("cdbh", "", OPARAMETER_INVAR, OTYPE_VARCHAR2);

OParameter clsd = params.Add("clsd", 55, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter dcxs = params.Add("dcxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter kcxs = params.Add("kcxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter xcxs = params.Add("xcxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter dczfxs = params.Add("dczfxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter kczfxs = params.Add("kczfxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter xczfxs = params.Add("xczfxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

OParameter zdxs = params.Add("zdxs", 1, OPARAMETER_INVAR, OTYPE_NUMBER);

// write data to BLOB

fstream fs;

fs.open("c://more_than_32k.jpg", ios::in);

fs.setmode(filebuf::binary);

fs.seekg(0, ios::end);

unsigned long filesize = fs.tellg();

fs.seekg(0, ios::beg);

cout <

OBlob b_lob(odb);

unsigned long optchunk = b_lob.GetOptimumChunkSize();

unsigned int bufsize = ((int)(32768/optchunk)) *optchunk;

unsigned char * buffer;

buffer = (unsigned char *)malloc(bufsize);

unsigned long totalwritten = 0;

unsigned long amtread = 0;

int piecetype = OLOB_FIRST_PIECE;

if (filesize <= bufsize)

piecetype = OLOB_ONE_PIECE;

else

b_lob.EnableStreaming(filesize);

while(totalwritten != filesize)

{

fs.read(buffer, bufsize);

amtread = fs.gcount();

b_lob.Write(buffer, amtread, piecetype);

totalwritten = totalwritten + amtread;

if ((filesize - totalwritten)<=bufsize)

piecetype = OLOB_LAST_PIECE;

else

piecetype = OLOB_NEXT_PIECE;

}

b_lob.DisableStreaming();

fs.close();

OParameter zjwj1 = params.Add("zjwj1", b_lob, OPARAMETER_INVAR, OTYPE_BLOB);

OParameter zjwj2 = params.Add("zjwj2", b_lob, OPARAMETER_INVAR, OTYPE_BLOB);

OParameter zjwj3 = params.Add("zjwj3", b_lob, OPARAMETER_INVAR, OTYPE_BLOB);

OParameter zxjg = params.Add("zxjg", 19, OPARAMETER_INOUTVAR, OTYPE_UINT);

OValue oval;

oval.Clear();

zjwj2.SetValue(oval);

zjwj3.SetValue(oval);

unsigned long size = b_lob.GetSize();

printf("blob size = %d/n", size);

oresult r = odb.ExecuteSQL("BEGIN nlv_cache.nlv_package.pro_tgs(:hpzl, :hphm, :wfsj, :wfxw, :wfdd, :wfdz, :cjjg, :sjly, :zplx, :sbbh, :cdbh, :clsd, :dcxs, :kcxs, :xcxs, :dczfxs, :kczfxs, :xczfxs, :zdxs, :zjwj1, :zjwj2, :zjwj3, :zxjg);END;");

if (r == OFAILURE)

{

cout <

return 1;

}

int ret;

zxjg.GetValue(&ret);

printf("ZXJG = %d/n", ret);

odb.Close();

return 0;

}

4. 完成