在VC下采用ADO实现BLOB（Binary）数据的存储，读取，修改，删除

在VC下采用ADO实现BLOB（Binary）数据的存储，读取，修改，删除。

作者：邵盛松 2009-09-05

前言
1关于的BLOB（Binary）数据的存储和读取功能主要参考了MSDN上的一篇《AppendChunk and GetChunk Methods Example (VC++)》，原文地址是http://msdn.microsoft.com/en-us/library/ms807920.aspx。还有www.vckbase.com上有一篇文章《使用ADO实现BLOB数据的存取 --
ADO开发实践之二》，原文地址是http://www.vckbase.com/document/viewdoc/?id=252
我在这篇博文当中增加了对BLOB（Binary）数据的存储，读取代码的分析。
2关于BLOB（Binary）数据的修改，我试验过多种方法，这个问题也花了比较长的时间才得到解决，原来的方法是从文件读取的数据，将更改的数据转化为CString类型，然后采用SQL的UPDATE语句进行数据的更新。后来在CSDN论坛上得到了vieri_ch的帮助，问题得到了比较好的一种解决方案。

二 实现方法：
1 BLOB（Binary）数据的存储，将一个文件存储到数据库。
存储部分代码分析写的比较详细，因为这里面得一些COM 结构和API需要说明一下
m_pRs为_RecordsetPtr类型
CFile fileAdd;
if(fileAdd.Open(要存储文件的路径,CFile::modeRead)==0) //打开文件
return;
_variant_t varChunk;
long nLength = fileAdd.GetLength();
BYTE* pbuf;
pbuf = new BYTE[nLength];
if(pbuf==NULL)
return;
fileAdd.Read(pbuf,nLength);
BYTE *pBufEx;
pBufEx = pbuf;
SAFEARRAY* psa;
SAFEARRAYBOUND rgsabound[1];
rgsabound[0].lLbound = 0;
rgsabound[0].cElements = nLength;
psa = SafeArrayCreate(VT_UI1, 1, rgsabound);
for (long i = 0; i < nLength; i++)
SafeArrayPutElement(psa,&i, pBufEx++);
VARIANT varBLOB;
varBLOB.vt = VT_ARRAY | VT_UI1;
varBLOB.parray = psa;
m_pRs->ADOFields->GetItem(_variant_t("BLOB类型字段的名称"))->AppendChunk(varBLOB);
m_pRs->Update();
m_pRs->Close();

在代码中有一个SAFEARRAY和SAFEARRAYBOUND类型，该类型在头文件OAIdl.h中定义
typedef struct tagSAFEARRAY
{
USHORT cDims;
USHORT fFeatures;
ULONG cbElements;
ULONG cLocks;
SAFEARRAYBOUND rgsabound[ 1 ];
}SAFEARRAY;
SAFEARRAY结构体中包含了SAFEARRAYBOUND类型。
先说SAFEARRAYBOUND结构
cElements表示数组中元素的个数。
lLbound表示数组的下界。
代码中SAFEARRAYBOUND元素个数为读取文件的大小，下界是0
操作SAFEARRAY类型是由COM提供了一套API来处理的。oleauto.h 头文件中可以看到很多关于操作SAFEARRAY数据类型的API.以下少列出几个
WINOLEAUTAPI SafeArrayAllocDescriptor(UINT cDims, SAFEARRAY ** ppsaOut);
WINOLEAUTAPI SafeArrayAllocDescriptorEx(VARTYPE vt, UINT cDims, SAFEARRAY ** ppsaOut);
WINOLEAUTAPI SafeArrayAllocData(SAFEARRAY * psa);
WINOLEAUTAPI_(SAFEARRAY *) SafeArrayCreate(VARTYPE vt, UINT cDims, SAFEARRAYBOUND * rgsabound);

SAFEARRAY为什么会称为安全数组？
从名字上看是安全数组的意思。比如我们第一个数组，数组的大小为10，数组的下界是从0开始，这时我们访问下界为10的元素，这时就发生了错误，以为数组的下界最大为9。SAFEARRAY这样定义结构的作用是实现COM API函数可以限制我们访问下界为10的元素和其他一些安全操作数组的行为等
SAFEARRAY结构说明
成员 描述
cDims 数组的维数
fFeatures 标志
cbElements 数组元素的大小
cLocks 一个计数器，用来跟踪该数组被锁定的次数
pvData 指向数据缓冲的指针
标志表示是在堆上创建还是在栈上创建等还包括其他一些标志

FADF_AUTO 0x0001
在栈上创建数组
FADF_STATIC 0x0002
在堆上创建数组
FADF_EMBEDDED 0x0004
在结构中创建
FADF_FIXEDSIZE 0x0010
不能改变数组大小
FADF_RECORD 0x0020
记录容器
FADF_HAVEIID 0x0040
有IID 身份标记 数组
FADF_HAVEVARTYPE 0x0080
VT 类型数组
FADF_BSTR 0x0100
BSTR数组
FADF_UNKNOWN 0x0200
IUnknown* 数组
FADF_DISPATCH 0x0400
IDispatch* 数组
FADF_VARIANT 0x0800
VARIANTs数组
FADF_RESERVED 0xF0E8
余留，将来使用
COM API函数说明SafeArrayCreate创建数组。参数VT_UI1是表示unsigned int 1字节整数(BYTE)数组
vt是数组类型、lLbound是数组下界值（最小下标）和数组长度

SafeArrayPutElement函数是向一个安全数组中添加一个值，代码中采用循环一个一个得添加

ADO方法
AppendChunk将数据追加到大型文本、二进制数据 Field 或 Parameter 对象。
语法
object.AppendChunk Data
参数
object Field 或 Parameter 对象
Data 变体型，包含追加到对象中的数据。

2 BLOB（Binary）数据的读取
将数据库中的数据读出并写入文件。
long lDataLength = m_pRs->GetFields()->GetItem(_variant_t("BLOB类型的字段"))->ActualSize;
if (lDataLength>0)
{
_variant_t varBLOB;
varBLOB=m_pRs->GetFields()->GetItem(_variant_t("BLOB类型的字段"))->GetChunk(lDataLength);
if(varBLOB.vt== (VT_ARRAY|VT_UI1) && varBLOB.vt!=VT_EMPTY && varBLOB.vt!=VT_NULL )
{
BYTE *pBuf = NULL;
pBuf = (BYTE*)GlobalAlloc(GMEM_FIXED,lDataLength);
SafeArrayAccessData(varBLOB.parray,(void **)&pBuf);

strFileName表示生成包含文件名的路径
CFile outFile(strFileName,CFile::modeCreate|CFile::modeWrite); //构造新文件，如果文件存在，则长度变为0
outFile.Write(pBuf,lDataLength);
outFile.Close();
SafeArrayUnaccessData (varBLOB.parray);
}
}
m_pRs->Close();

3 BLOB（Binary）数据的修改

CFileException eFile;
CFile fileSave;
strPath表示需要修改文件的路径
fileSave.Open(strPath,CFile::modeReadWrite|CFile::shareDenyWrite|CFile::shareDenyRead|CFile::typeBinary,&eFile);
_variant_t varChunk;
long nLength = fileSave.GetLength();
BYTE* pbuf;
pbuf = new BYTE[nLength];
if(pbuf == NULL) return;
fileSave.Read(pbuf,nLength);
fileSave.Close();
BYTE *pBufEx;
pBufEx = pbuf;
SAFEARRAY* psa;
SAFEARRAYBOUND rgsabound[1];
rgsabound[0].lLbound = 0;
rgsabound[0].cElements = nLength;
psa = SafeArrayCreate(VT_UI1, 1, rgsabound);
for (long i = 0; i < nLength; i++)
SafeArrayPutElement(psa,&i, pBufEx++);
VARIANT varBLOB;
varBLOB.vt = VT_ARRAY | VT_UI1;
varBLOB.parray = psa;
CString strSQL;
strSQL.Format(_T("UPDATE 表名 SET BLOB字段名=? WHERE ID='1'");
m_pCom.CreateInstance(__uuidof(Command));
m_pCom->ActiveConnection = m_pCon;
m_pCom->CommandText = _bstr_t(strSQL);
m_pCom->CommandType = adCmdText;
m_pCom->Parameters->Append(m_pCom->CreateParameter(_T("@参数名"),adVarBinary, adParamInput, -1, varBLOB));
m_pCom->Execute(NULL,NULL,adCmdText);

4 BLOB（Binary）数据的修改

删除比较简单一点，同时表定义该字段允许为空
执行一个SQL语句就可以了
UPDATE 表名 SET BLOB字段名 = NULL WHERE ID=1

以上程序已经在Visual C++2005 Unicode下调试通过