#include // for printf
#include // main SQLAPI++ header
// forwards
SAString ReadWholeFile(const char *sFilename);
size_t FromFileWriter(
SAPieceType_t &ePieceType,
void *pBuf, size_t nLen, void *pAddlData);
int main(int argc, char* argv[])
{
SAConnection con; // connection object
// command object
// update fblob field of our test table
SACommand cmd(&con,
_TSA("Update test_tbl set fblob = :fblob where fid =:1"));
try
{
// connect to database (Oracle in our example)
con.Connect(_TSA("test"), _TSA("tester"), _TSA("tester"), SA_Oracle_Client);
// use first method of Long(Lob) binding - as a whole
cmd.Param(1).setAsLong() = 1; // fid
cmd.Param(_TSA("fblob")).setAsBLob() = ReadWholeFile("test.doc");
// update first row
cmd.Execute();
// use second method of binding - user defined callbacks
cmd.Param(1).setAsLong() = 2;
cmd.Param(_TSA("fblob")).setAsBLob(
FromFileWriter, // our callback to provide blob data from file
10*1024, // desired size of each piece
(void*)"test.doc"); // additional param, file name in our case
// update second row
cmd.Execute(); // at that moment Library will call user callback when needed
// commit changes on success
con.Commit();
printf("Blob parameter bound, rows updated!\n");
}
catch(SAException &x)
{
// SAConnection::Rollback()
// can also throw an exception
// (if a network error for example),
// we will be ready
try
{
// on error rollback changes
con.Rollback();
}
catch(SAException &)
{
}
// print error message
printf("%s\n", x.ErrText().GetMultiByteChars());
}
return 0;
}
SAString ReadWholeFile(const char *sFilename)
{
SAString s;
char sBuf[32*1024];
FILE *pFile = fopen(sFilename, "rb");
if (!pFile)
{
SAString sName(sFilename);
SAException::throwUserException(-1,
_TSA("Error opening file '%s'\n"), (const SAChar*)sName);
}
do
{
size_t nRead = fread(sBuf, 1, sizeof(sBuf), pFile);
s += SAString(sBuf, nRead);
}
while(!feof(pFile));
fclose(pFile);
return s;
}
static FILE *pFile = NULL;
size_t nTotalBound;
size_t FromFileWriter(
SAPieceType_t &ePieceType,
void *pBuf, size_t nLen, void *pAddlData)
{
if(ePieceType == SA_FirstPiece)
{
const char *sFilename = (const char *)pAddlData;
pFile = fopen(sFilename, "rb");
if (!pFile)
{
SAString sName(sFilename);
SAException::throwUserException(-1, _TSA("Can not open file '%s'"), (const SAChar*)sName);
}
nTotalBound = 0;
}
size_t nRead = fread(pBuf, 1, nLen, pFile);
nTotalBound += nRead;
// show progress
printf("%d bytes of file bound\n", nTotalBound);
if(feof(pFile))
{
ePieceType = SA_LastPiece;
fclose(pFile);
pFile = NULL;
}
return nRead;
}