一样的sql语句,查询出来即可。只不过二进制数据是个数据块,需要得到数据块的大小和数据指针。
bool CMySqlAccess::GetBinaryField(int nCol,char* &pDataOut,int&nDataLen)
{
if (m_ItemMySqlRow[nCol] != NULL)
{
unsigned long *FieldLength = mysql_fetch_lengths(m_pMySqlResult)
nDataLen = (int)FieldLength[nCol]
pDataOut = (char*)(m_ItemMySqlRow[nCol])
return true
}
else
{
return false
}
}
像通常一样查询后,得到结果集,然后得到第nCol列结果,返回二进制指针结果和二进制长度。返回后必须立马处理或者存储一份。否则mysql将数据销毁,指针所指数据则无效了。
存二进制数据:
mysql语句接受的sql语句都是string,以'\0'结尾的。如果冒然插入二进制数据到sql语句中,要么报错,要么存储错误。此处可以通过mysql提供的函数将数据转换一下即可。
char* CMySqlAccess::ConvertBinaryToString(char* pBinaryData,int nLen)
{
static char s_BinaryData[10240]
mysql_real_escape_string(m_pMySqlConn,s_BinaryData,pBinaryData,nLen)
return s_BinaryData
}
上面这个函数只能单线程使用啊,将一块二进制数据转换为mysql可识别的string数据。这样就直接可以通过mysql的sql语句insert,update来对blob数据进行更新和插入了,sql语句用法不变。
BLOB数据的保存BLOB类型的数据无法用普通的方式进行存储,我们需要使用AppendChunk函数,AppendChunk包含在Field对象中,原型如下:
HRESULT AppendChunk (const _variant_t &Data )
从函数原型中可以看到关键的问题是我们需把二进制数据赋值给VARIANT类型的变量,下面我们给出具体的代码并作简单的分析:
///假设m_pBMPBuffer指针指向一块长度为m_nFileLen的二进制数据,并且已经成功打开了记录集对象m_pRecordset///
char *pBuf = m_pBMPBuffer
VARIANT varBLOB
SAFEARRAY *psa
SAFEARRAYBOUND rgsabound[1]
m_pRecordset->AddNew()///添加新记录
m_pRecordset->PutCollect("username",_variant_t("小李")///为新记录填充username字段
m_pRecordset->PutCollect("old",_variant_t((long)28)///填充old字段
if(pBuf){
rgsabound[0].lLbound = 0
rgsabound[0].cElements = m_nFileLen
psa = SafeArrayCreate(VT_UI1, 1, rgsabound)///创建SAFEARRAY对象
for (long i = 0i <(long)m_nFileLeni++)
SafeArrayPutElement (psa, &i, pBuf++)///将pBuf指向的二进制数据保存到SAFEARRAY对象psa中
varBLOB.vt = VT_ARRAY | VT_UI1///将varBLOB的类型设置为BYTE类型的数组
varBLOB.parray = psa///为varBLOB变量赋值
m_pRecordset->GetFields()->GetItem("photo"->AppendChunk(varBLOB)///加入BLOB类型的数据
}
m_pRecordset->Update()///保存我们的数据到库中
至此我们的数据已经成功地保存到了数据库中,接下来我们所要做的工作便是将该数据提取出来,让我们继续吧!
BLOB数据的读取
对应于保存数据时我们所使用的AppendChunk函数,读取数据应该使用GetChunk函数,GetChunk的原型如下:
_variant_t GetChunk (long Length )
给出数据的长度后GetChunk将返回包含数据的VARIANT类型变量,然后我们可以利用SafeArrayAccessData函数得到VARIANT变量中指向数据的char *类型的指针,以方便我们的处理,具体代码如下:
long lDataSize = m_pRecordset->GetFields()->GetItem("photo")->ActualSize///得到数据的长度
if(lDataSize >0)
{
_variant_t varBLOB
varBLOB = m_pRecordset->GetFields()->GetItem("photo")->GetChunk(lDataSize)
if(varBLOB.vt == (VT_ARRAY | VT_UI1)) ///判断数据类型是否正确
{
char *pBuf = NULL
SafeArrayAccessData(varBLOB.parray,(void **)&pBuf)
///得到指向数据的指针
/*****在这里我们可以对pBuf中的数据进行处理*****/
SafeArrayUnaccessData (varBLOB.parray)
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)