794 lines
32 KiB
C++
794 lines
32 KiB
C++
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
/*
|
|
* This file is part of the LibreOffice project.
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
*
|
|
* This file incorporates work covered by the following license notice:
|
|
*
|
|
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
* contributor license agreements. See the NOTICE file distributed
|
|
* with this work for additional information regarding copyright
|
|
* ownership. The ASF licenses this file to you under the Apache
|
|
* License, Version 2.0 (the "License"); you may not use this file
|
|
* except in compliance with the License. You may obtain a copy of
|
|
* the License at http://www.apache.org/licenses/LICENSE-2.0 .
|
|
*/
|
|
|
|
#include "odbc/OTools.hxx"
|
|
#include "odbc/OFunctions.hxx"
|
|
#include <com/sun/star/sdbc/DataType.hpp>
|
|
#include <osl/diagnose.h>
|
|
#include "odbc/OConnection.hxx"
|
|
#include <rtl/ustrbuf.hxx>
|
|
|
|
#include <string.h>
|
|
#include <string>
|
|
#include <algorithm>
|
|
|
|
using namespace connectivity::odbc;
|
|
using namespace com::sun::star::uno;
|
|
using namespace com::sun::star::sdbc;
|
|
using namespace com::sun::star::util;
|
|
|
|
namespace {
|
|
size_t sqlTypeLen ( SQLSMALLINT _nType )
|
|
{
|
|
switch (_nType)
|
|
{
|
|
case SQL_C_SSHORT:
|
|
case SQL_C_SHORT:
|
|
return sizeof(SQLSMALLINT);
|
|
case SQL_C_USHORT:
|
|
return sizeof(SQLUSMALLINT);
|
|
case SQL_C_SLONG:
|
|
case SQL_C_LONG:
|
|
return sizeof(SQLINTEGER);
|
|
case SQL_C_ULONG:
|
|
return sizeof(SQLUINTEGER);
|
|
case SQL_C_FLOAT:
|
|
return sizeof(SQLREAL);
|
|
case SQL_C_DOUBLE:
|
|
OSL_ENSURE(sizeof(SQLDOUBLE) == sizeof(SQLFLOAT), "SQLDOUBLE/SQLFLOAT confusion");
|
|
return sizeof(SQLDOUBLE);
|
|
case SQL_C_BIT:
|
|
return sizeof(SQLCHAR);
|
|
case SQL_C_STINYINT:
|
|
case SQL_C_TINYINT:
|
|
return sizeof(SQLSCHAR);
|
|
case SQL_C_UTINYINT:
|
|
return sizeof(SQLCHAR);
|
|
case SQL_C_SBIGINT:
|
|
return sizeof(SQLBIGINT);
|
|
case SQL_C_UBIGINT:
|
|
return sizeof(SQLUBIGINT);
|
|
/* UnixODBC gives this the same value as SQL_C_UBIGINT
|
|
case SQL_C_BOOKMARK:
|
|
return sizeof(BOOKMARK); */
|
|
case SQL_C_TYPE_DATE:
|
|
case SQL_C_DATE:
|
|
return sizeof(SQL_DATE_STRUCT);
|
|
case SQL_C_TYPE_TIME:
|
|
case SQL_C_TIME:
|
|
return sizeof(SQL_TIME_STRUCT);
|
|
case SQL_C_TYPE_TIMESTAMP:
|
|
case SQL_C_TIMESTAMP:
|
|
return sizeof(SQL_TIMESTAMP_STRUCT);
|
|
case SQL_C_NUMERIC:
|
|
return sizeof(SQL_NUMERIC_STRUCT);
|
|
case SQL_C_GUID:
|
|
return sizeof(SQLGUID);
|
|
case SQL_C_INTERVAL_YEAR:
|
|
case SQL_C_INTERVAL_MONTH:
|
|
case SQL_C_INTERVAL_DAY:
|
|
case SQL_C_INTERVAL_HOUR:
|
|
case SQL_C_INTERVAL_MINUTE:
|
|
case SQL_C_INTERVAL_SECOND:
|
|
case SQL_C_INTERVAL_YEAR_TO_MONTH:
|
|
case SQL_C_INTERVAL_DAY_TO_HOUR:
|
|
case SQL_C_INTERVAL_DAY_TO_MINUTE:
|
|
case SQL_C_INTERVAL_DAY_TO_SECOND:
|
|
case SQL_C_INTERVAL_HOUR_TO_MINUTE:
|
|
case SQL_C_INTERVAL_HOUR_TO_SECOND:
|
|
case SQL_C_INTERVAL_MINUTE_TO_SECOND:
|
|
return sizeof(SQL_INTERVAL_STRUCT);
|
|
// ** Variable-sized datatypes -> cannot predict length
|
|
case SQL_C_CHAR:
|
|
case SQL_C_WCHAR:
|
|
case SQL_C_BINARY:
|
|
// UnixODBC gives this the same value as SQL_C_BINARY
|
|
//case SQL_C_VARBOOKMARK:
|
|
// Unknown datatype -> cannot predict length
|
|
default:
|
|
return static_cast<size_t>(-1);
|
|
}
|
|
}
|
|
|
|
void appendSQLWCHARs(OUStringBuffer & s, SQLWCHAR const * d, sal_Int32 n)
|
|
{
|
|
static_assert(
|
|
sizeof (SQLWCHAR) == sizeof (sal_Unicode) || sizeof (SQLWCHAR) == 4,
|
|
"bad SQLWCHAR");
|
|
if (sizeof (SQLWCHAR) == sizeof (sal_Unicode)) {
|
|
s.append(reinterpret_cast<sal_Unicode const *>(d), n);
|
|
} else {
|
|
for (sal_Int32 i = 0; i != n; ++i) {
|
|
s.appendUtf32(d[i]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
void OTools::getValue( OConnection* _pConnection,
|
|
SQLHANDLE _aStatementHandle,
|
|
sal_Int32 columnIndex,
|
|
SQLSMALLINT _nType,
|
|
bool &_bWasNull,
|
|
const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _xInterface,
|
|
void* _pValue,
|
|
SQLLEN _nSize) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
|
|
{
|
|
const size_t properSize = sqlTypeLen(_nType);
|
|
if ( properSize == static_cast<size_t>(-1) )
|
|
SAL_WARN( "connectivity.drivers", "connectivity::odbc::OTools::getValue: unknown SQL type - cannot check buffer size");
|
|
else
|
|
{
|
|
OSL_ENSURE(static_cast<size_t>(_nSize) == properSize, "connectivity::odbc::OTools::getValue got wrongly sized memory region to write result to");
|
|
if ( static_cast<size_t>(_nSize) > properSize )
|
|
{
|
|
SAL_WARN( "connectivity.drivers", "memory region is too big - trying to fudge it");
|
|
memset(_pValue, 0, _nSize);
|
|
#ifdef OSL_BIGENDIAN
|
|
// This is skewed in favour of integer types
|
|
_pValue += _nSize - properSize;
|
|
#endif
|
|
}
|
|
}
|
|
OSL_ENSURE(static_cast<size_t>(_nSize) >= properSize, "memory region is too small");
|
|
SQLLEN pcbValue = SQL_NULL_DATA;
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetData>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetData)))(_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
_nType,
|
|
_pValue,
|
|
_nSize,
|
|
&pcbValue),
|
|
_aStatementHandle,SQL_HANDLE_STMT,_xInterface,false);
|
|
_bWasNull = pcbValue == SQL_NULL_DATA;
|
|
}
|
|
|
|
void OTools::bindValue( OConnection* _pConnection,
|
|
SQLHANDLE _aStatementHandle,
|
|
sal_Int32 columnIndex,
|
|
SQLSMALLINT _nType,
|
|
SQLSMALLINT _nMaxLen,
|
|
const void* _pValue,
|
|
void* _pData,
|
|
SQLLEN * const pLen,
|
|
const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& _xInterface,
|
|
rtl_TextEncoding _nTextEncoding,
|
|
bool _bUseOldTimeDate) throw(::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
|
|
{
|
|
SQLRETURN nRetcode;
|
|
SQLSMALLINT fSqlType;
|
|
SQLSMALLINT fCType;
|
|
|
|
OTools::getBindTypes( false,
|
|
_bUseOldTimeDate,
|
|
_nType,
|
|
fCType,
|
|
fSqlType);
|
|
|
|
if (columnIndex != 0 && !_pValue)
|
|
{
|
|
*pLen = SQL_NULL_DATA;
|
|
nRetcode = (*reinterpret_cast<T3SQLBindCol>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::BindCol)))(_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
fCType,
|
|
_pData,
|
|
_nMaxLen,
|
|
pLen
|
|
);
|
|
}
|
|
else
|
|
{
|
|
try
|
|
{
|
|
switch (_nType)
|
|
{
|
|
case SQL_CHAR:
|
|
case SQL_VARCHAR:
|
|
{
|
|
OString aString(OUStringToOString(*static_cast<OUString const *>(_pValue),_nTextEncoding));
|
|
*pLen = SQL_NTS;
|
|
*static_cast<OString*>(_pData) = aString;
|
|
|
|
// Pointer on Char*
|
|
_pData = const_cast<char *>(aString.getStr());
|
|
} break;
|
|
case SQL_BIGINT:
|
|
*static_cast<sal_Int64*>(_pData) = *static_cast<sal_Int64 const *>(_pValue);
|
|
*pLen = sizeof(sal_Int64);
|
|
break;
|
|
case SQL_DECIMAL:
|
|
case SQL_NUMERIC:
|
|
{
|
|
OString aString = OString::number(*static_cast<double const *>(_pValue));
|
|
*pLen = (SQLSMALLINT)aString.getLength();
|
|
*static_cast<OString*>(_pData) = aString;
|
|
// Pointer on Char*
|
|
_pData = const_cast<char *>(static_cast<OString*>(_pData)->getStr());
|
|
} break;
|
|
case SQL_BIT:
|
|
case SQL_TINYINT:
|
|
*static_cast<sal_Int8*>(_pData) = *static_cast<sal_Int8 const *>(_pValue);
|
|
*pLen = sizeof(sal_Int8);
|
|
break;
|
|
|
|
case SQL_SMALLINT:
|
|
*static_cast<sal_Int16*>(_pData) = *static_cast<sal_Int16 const *>(_pValue);
|
|
*pLen = sizeof(sal_Int16);
|
|
break;
|
|
case SQL_INTEGER:
|
|
*static_cast<sal_Int32*>(_pData) = *static_cast<sal_Int32 const *>(_pValue);
|
|
*pLen = sizeof(sal_Int32);
|
|
break;
|
|
case SQL_FLOAT:
|
|
*static_cast<float*>(_pData) = *static_cast<float const *>(_pValue);
|
|
*pLen = sizeof(float);
|
|
break;
|
|
case SQL_REAL:
|
|
case SQL_DOUBLE:
|
|
*static_cast<double*>(_pData) = *static_cast<double const *>(_pValue);
|
|
*pLen = sizeof(double);
|
|
break;
|
|
case SQL_BINARY:
|
|
case SQL_VARBINARY:
|
|
{
|
|
_pData = const_cast<sal_Int8 *>(static_cast<const ::com::sun::star::uno::Sequence< sal_Int8 > *>(_pValue)->getConstArray());
|
|
*pLen = static_cast<const ::com::sun::star::uno::Sequence< sal_Int8 > *>(_pValue)->getLength();
|
|
} break;
|
|
case SQL_LONGVARBINARY:
|
|
{
|
|
_pData = reinterpret_cast<void*>(columnIndex);
|
|
sal_Int32 nLen = 0;
|
|
nLen = static_cast<const ::com::sun::star::uno::Sequence< sal_Int8 > *>(_pValue)->getLength();
|
|
*pLen = (SQLLEN)SQL_LEN_DATA_AT_EXEC(nLen);
|
|
}
|
|
break;
|
|
case SQL_LONGVARCHAR:
|
|
{
|
|
_pData = reinterpret_cast<void*>(columnIndex);
|
|
sal_Int32 nLen = 0;
|
|
nLen = static_cast<OUString const *>(_pValue)->getLength();
|
|
*pLen = (SQLLEN)SQL_LEN_DATA_AT_EXEC(nLen);
|
|
} break;
|
|
case SQL_DATE:
|
|
*pLen = sizeof(DATE_STRUCT);
|
|
*static_cast<DATE_STRUCT*>(_pData) = *static_cast<DATE_STRUCT const *>(_pValue);
|
|
break;
|
|
case SQL_TIME:
|
|
*pLen = sizeof(TIME_STRUCT);
|
|
*static_cast<TIME_STRUCT*>(_pData) = *static_cast<TIME_STRUCT const *>(_pValue);
|
|
break;
|
|
case SQL_TIMESTAMP:
|
|
*pLen = sizeof(TIMESTAMP_STRUCT);
|
|
*static_cast<TIMESTAMP_STRUCT*>(_pData) = *static_cast<TIMESTAMP_STRUCT const *>(_pValue);
|
|
break;
|
|
}
|
|
}
|
|
catch ( ... )
|
|
{
|
|
}
|
|
|
|
nRetcode = (*reinterpret_cast<T3SQLBindCol>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::BindCol)))(_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
fCType,
|
|
_pData,
|
|
_nMaxLen,
|
|
pLen
|
|
);
|
|
}
|
|
|
|
OTools::ThrowException(_pConnection,nRetcode,_aStatementHandle,SQL_HANDLE_STMT,_xInterface);
|
|
}
|
|
|
|
void OTools::ThrowException(const OConnection* _pConnection,
|
|
const SQLRETURN _rRetCode,
|
|
const SQLHANDLE _pContext,
|
|
const SQLSMALLINT _nHandleType,
|
|
const Reference< XInterface >& _xInterface,
|
|
const bool _bNoFound,
|
|
const rtl_TextEncoding _nTextEncoding) throw(SQLException)
|
|
{
|
|
switch(_rRetCode)
|
|
{
|
|
case SQL_NEED_DATA:
|
|
case SQL_STILL_EXECUTING:
|
|
case SQL_SUCCESS:
|
|
|
|
case SQL_SUCCESS_WITH_INFO:
|
|
return;
|
|
case SQL_NO_DATA_FOUND:
|
|
if(_bNoFound)
|
|
return; // no need to throw a exception
|
|
case SQL_ERROR: break;
|
|
|
|
|
|
case SQL_INVALID_HANDLE: SAL_WARN( "connectivity.drivers", "SdbODBC3_SetStatus: SQL_INVALID_HANDLE");
|
|
throw SQLException();
|
|
}
|
|
|
|
// Additional Information on the latest ODBC-functioncall available
|
|
// SQLError provides this Information.
|
|
|
|
SDB_ODBC_CHAR szSqlState[5];
|
|
SQLINTEGER pfNativeError;
|
|
SDB_ODBC_CHAR szErrorMessage[SQL_MAX_MESSAGE_LENGTH];
|
|
szErrorMessage[0] = '\0';
|
|
SQLSMALLINT pcbErrorMsg = 0;
|
|
|
|
// Information for latest operation:
|
|
// when hstmt != SQL_NULL_HSTMT is (Used from SetStatus in SdbCursor, SdbTable, ...),
|
|
// then the status of the latest statements will be fetched, without the Status of the last
|
|
// statements of this connection [what in this case will probably be the same, but the Reference
|
|
// Manual isn't totally clear in this...].
|
|
// corresponding for hdbc.
|
|
SQLRETURN n = (*reinterpret_cast<T3SQLGetDiagRec>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetDiagRec)))(_nHandleType,_pContext,1,
|
|
szSqlState,
|
|
&pfNativeError,
|
|
szErrorMessage,sizeof szErrorMessage - 1,&pcbErrorMsg);
|
|
OSL_ENSURE(n != SQL_INVALID_HANDLE,"SdbODBC3_SetStatus: SQLError returned SQL_INVALID_HANDLE");
|
|
OSL_ENSURE(n == SQL_SUCCESS || n == SQL_SUCCESS_WITH_INFO || n == SQL_NO_DATA_FOUND || n == SQL_ERROR,"SdbODBC3_SetStatus: SQLError failed");
|
|
|
|
// For the Return Code of SQLError see ODBC 2.0 Programmer's Reference Page 287ff
|
|
throw SQLException( OUString(reinterpret_cast<char *>(szErrorMessage), pcbErrorMsg, _nTextEncoding),
|
|
_xInterface,
|
|
OUString(reinterpret_cast<char *>(szSqlState), 5, _nTextEncoding),
|
|
pfNativeError,
|
|
Any()
|
|
);
|
|
|
|
}
|
|
|
|
Sequence<sal_Int8> OTools::getBytesValue(const OConnection* _pConnection,
|
|
const SQLHANDLE _aStatementHandle,
|
|
const sal_Int32 columnIndex,
|
|
const SQLSMALLINT _fSqlType,
|
|
bool &_bWasNull,
|
|
const Reference< XInterface >& _xInterface) throw(SQLException, RuntimeException)
|
|
{
|
|
sal_Int8 aCharArray[2048];
|
|
// First try to fetch the data with the little Buffer:
|
|
const SQLLEN nMaxLen = sizeof aCharArray;
|
|
SQLLEN pcbValue = SQL_NO_TOTAL;
|
|
Sequence<sal_Int8> aData;
|
|
|
|
OSL_ENSURE( _fSqlType != SQL_CHAR && _fSqlType != SQL_VARCHAR && _fSqlType != SQL_LONGVARCHAR &&
|
|
_fSqlType != SQL_WCHAR && _fSqlType != SQL_WVARCHAR && _fSqlType != SQL_WLONGVARCHAR,
|
|
"connectivity::odbc::OTools::getBytesValue called with character _fSqlType");
|
|
|
|
while (pcbValue == SQL_NO_TOTAL || pcbValue > nMaxLen)
|
|
{
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetData>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetData)))(
|
|
_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
_fSqlType,
|
|
static_cast<SQLPOINTER>(aCharArray),
|
|
nMaxLen,
|
|
&pcbValue),
|
|
_aStatementHandle,SQL_HANDLE_STMT,_xInterface);
|
|
|
|
_bWasNull = pcbValue == SQL_NULL_DATA;
|
|
if(_bWasNull)
|
|
return Sequence<sal_Int8>();
|
|
|
|
SQLLEN nReadBytes;
|
|
// After the SQLGetData that wrote out to aCharArray the last byte of the data,
|
|
// pcbValue will not be SQL_NO_TOTAL -> we have a reliable count
|
|
if ( (pcbValue == SQL_NO_TOTAL) || (pcbValue >= nMaxLen) )
|
|
{
|
|
// we filled the buffer
|
|
nReadBytes = nMaxLen;
|
|
}
|
|
else
|
|
{
|
|
nReadBytes = pcbValue;
|
|
}
|
|
const sal_Int32 nLen = aData.getLength();
|
|
aData.realloc(nLen + nReadBytes);
|
|
memcpy(aData.getArray() + nLen, aCharArray, nReadBytes);
|
|
}
|
|
return aData;
|
|
}
|
|
|
|
OUString OTools::getStringValue(OConnection* _pConnection,
|
|
SQLHANDLE _aStatementHandle,
|
|
sal_Int32 columnIndex,
|
|
SQLSMALLINT _fSqlType,
|
|
bool &_bWasNull,
|
|
const Reference< XInterface >& _xInterface,
|
|
const rtl_TextEncoding _nTextEncoding) throw(SQLException, RuntimeException)
|
|
{
|
|
OUStringBuffer aData;
|
|
switch(_fSqlType)
|
|
{
|
|
case SQL_WVARCHAR:
|
|
case SQL_WCHAR:
|
|
case SQL_WLONGVARCHAR:
|
|
{
|
|
SQLWCHAR waCharArray[2048];
|
|
static_assert(sizeof(waCharArray) % sizeof(SQLWCHAR) == 0, "must fit in evenly");
|
|
static_assert(sizeof(SQLWCHAR) == 2 || sizeof(SQLWCHAR) == 4, "must be 2 or 4");
|
|
// Size == number of bytes, Len == number of UTF-16 or UCS4 code units
|
|
const SQLLEN nMaxSize = sizeof(waCharArray);
|
|
const SQLLEN nMaxLen = sizeof(waCharArray) / sizeof(SQLWCHAR);
|
|
static_assert(nMaxLen * sizeof(SQLWCHAR) == nMaxSize, "sizes must match");
|
|
|
|
// read the unicode data
|
|
SQLLEN pcbValue = SQL_NO_TOTAL;
|
|
while ((pcbValue == SQL_NO_TOTAL ) || (pcbValue >= nMaxSize) )
|
|
{
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetData>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetData)))(
|
|
_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
SQL_C_WCHAR,
|
|
&waCharArray,
|
|
(SQLLEN)nMaxLen*sizeof(sal_Unicode),
|
|
&pcbValue),
|
|
_aStatementHandle,SQL_HANDLE_STMT,_xInterface);
|
|
_bWasNull = pcbValue == SQL_NULL_DATA;
|
|
if(_bWasNull)
|
|
return OUString();
|
|
|
|
SQLLEN nReadChars;
|
|
OSL_ENSURE( (pcbValue < 0) || (pcbValue % 2 == 0),
|
|
"ODBC: SQLGetData of SQL_C_WCHAR returned odd number of bytes");
|
|
if ( (pcbValue == SQL_NO_TOTAL) || (pcbValue >= nMaxSize) )
|
|
{
|
|
// we filled the buffer; remove the terminating null character
|
|
nReadChars = nMaxLen-1;
|
|
if ( waCharArray[nReadChars] != 0)
|
|
{
|
|
SAL_WARN( "connectivity.drivers", "Buggy ODBC driver? Did not null-terminate (variable length) data!");
|
|
++nReadChars;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
nReadChars = pcbValue/sizeof(SQLWCHAR);
|
|
}
|
|
|
|
appendSQLWCHARs(aData, waCharArray, nReadChars);
|
|
}
|
|
break;
|
|
}
|
|
default:
|
|
{
|
|
char aCharArray[2048];
|
|
// read the unicode data
|
|
const SQLLEN nMaxLen = sizeof(aCharArray);
|
|
SQLLEN pcbValue = SQL_NO_TOTAL;
|
|
|
|
while ((pcbValue == SQL_NO_TOTAL ) || (pcbValue >= nMaxLen) )
|
|
{
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetData>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetData)))(
|
|
_aStatementHandle,
|
|
(SQLUSMALLINT)columnIndex,
|
|
SQL_C_CHAR,
|
|
&aCharArray,
|
|
nMaxLen,
|
|
&pcbValue),
|
|
_aStatementHandle,SQL_HANDLE_STMT,_xInterface);
|
|
_bWasNull = pcbValue == SQL_NULL_DATA;
|
|
if(_bWasNull)
|
|
return OUString();
|
|
|
|
SQLLEN nReadChars;
|
|
if ( (pcbValue == SQL_NO_TOTAL) || (pcbValue >= nMaxLen) )
|
|
{
|
|
// we filled the buffer; remove the terminating null character
|
|
nReadChars = nMaxLen-1;
|
|
if ( aCharArray[nReadChars] != 0)
|
|
{
|
|
SAL_WARN( "connectivity.drivers", "Buggy ODBC driver? Did not null-terminate (variable length) data!");
|
|
++nReadChars;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
nReadChars = pcbValue;
|
|
}
|
|
|
|
aData.append(OUString(aCharArray, nReadChars, _nTextEncoding));
|
|
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
return aData.makeStringAndClear();
|
|
}
|
|
|
|
void OTools::GetInfo(OConnection* _pConnection,
|
|
SQLHANDLE _aConnectionHandle,
|
|
SQLUSMALLINT _nInfo,
|
|
OUString &_rValue,
|
|
const Reference< XInterface >& _xInterface,
|
|
rtl_TextEncoding _nTextEncoding) throw(SQLException, RuntimeException)
|
|
{
|
|
char aValue[512];
|
|
SQLSMALLINT nValueLen=0;
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetInfo>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetInfo)))(_aConnectionHandle,_nInfo,aValue,(sizeof aValue)-1,&nValueLen),
|
|
_aConnectionHandle,SQL_HANDLE_DBC,_xInterface);
|
|
|
|
_rValue = OUString(aValue,nValueLen,_nTextEncoding);
|
|
}
|
|
|
|
void OTools::GetInfo(OConnection* _pConnection,
|
|
SQLHANDLE _aConnectionHandle,
|
|
SQLUSMALLINT _nInfo,
|
|
sal_Int32 &_rValue,
|
|
const Reference< XInterface >& _xInterface) throw(SQLException, RuntimeException)
|
|
{
|
|
SQLSMALLINT nValueLen;
|
|
_rValue = 0; // in case the driver uses only 16 of the 32 bits (as it does, for example, for SQL_CATALOG_LOCATION)
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetInfo>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetInfo)))(_aConnectionHandle,_nInfo,&_rValue,sizeof _rValue,&nValueLen),
|
|
_aConnectionHandle,SQL_HANDLE_DBC,_xInterface);
|
|
}
|
|
|
|
void OTools::GetInfo(OConnection* _pConnection,
|
|
SQLHANDLE _aConnectionHandle,
|
|
SQLUSMALLINT _nInfo,
|
|
SQLUINTEGER &_rValue,
|
|
const Reference< XInterface >& _xInterface) throw(SQLException, RuntimeException)
|
|
{
|
|
SQLSMALLINT nValueLen;
|
|
_rValue = 0; // in case the driver uses only 16 of the 32 bits (as it does, for example, for SQL_CATALOG_LOCATION)
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetInfo>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetInfo)))(_aConnectionHandle,_nInfo,&_rValue,sizeof _rValue,&nValueLen),
|
|
_aConnectionHandle,SQL_HANDLE_DBC,_xInterface);
|
|
}
|
|
|
|
void OTools::GetInfo(OConnection* _pConnection,
|
|
SQLHANDLE _aConnectionHandle,
|
|
SQLUSMALLINT _nInfo,
|
|
SQLUSMALLINT &_rValue,
|
|
const Reference< XInterface >& _xInterface) throw(SQLException, RuntimeException)
|
|
{
|
|
SQLSMALLINT nValueLen;
|
|
_rValue = 0; // in case the driver uses only 16 of the 32 bits (as it does, for example, for SQL_CATALOG_LOCATION)
|
|
OTools::ThrowException(_pConnection,
|
|
(*reinterpret_cast<T3SQLGetInfo>(_pConnection->getOdbcFunction(ODBC3SQLFunctionId::GetInfo)))(_aConnectionHandle,_nInfo,&_rValue,sizeof _rValue,&nValueLen),
|
|
_aConnectionHandle,SQL_HANDLE_DBC,_xInterface);
|
|
}
|
|
|
|
sal_Int32 OTools::MapOdbcType2Jdbc(SQLSMALLINT _nType)
|
|
{
|
|
sal_Int32 nValue = DataType::VARCHAR;
|
|
switch(_nType)
|
|
{
|
|
case SQL_BIT:
|
|
nValue = DataType::BIT;
|
|
break;
|
|
case SQL_TINYINT:
|
|
nValue = DataType::TINYINT;
|
|
break;
|
|
case SQL_SMALLINT:
|
|
nValue = DataType::SMALLINT;
|
|
break;
|
|
case SQL_INTEGER:
|
|
nValue = DataType::INTEGER;
|
|
break;
|
|
case SQL_BIGINT:
|
|
nValue = DataType::BIGINT;
|
|
break;
|
|
case SQL_FLOAT:
|
|
nValue = DataType::FLOAT;
|
|
break;
|
|
case SQL_REAL:
|
|
nValue = DataType::REAL;
|
|
break;
|
|
case SQL_DOUBLE:
|
|
nValue = DataType::DOUBLE;
|
|
break;
|
|
case SQL_NUMERIC:
|
|
nValue = DataType::NUMERIC;
|
|
break;
|
|
case SQL_DECIMAL:
|
|
nValue = DataType::DECIMAL;
|
|
break;
|
|
case SQL_WCHAR:
|
|
case SQL_CHAR:
|
|
nValue = DataType::CHAR;
|
|
break;
|
|
case SQL_WVARCHAR:
|
|
case SQL_VARCHAR:
|
|
nValue = DataType::VARCHAR;
|
|
break;
|
|
case SQL_WLONGVARCHAR:
|
|
case SQL_LONGVARCHAR:
|
|
nValue = DataType::LONGVARCHAR;
|
|
break;
|
|
case SQL_TYPE_DATE:
|
|
case SQL_DATE:
|
|
nValue = DataType::DATE;
|
|
break;
|
|
case SQL_TYPE_TIME:
|
|
case SQL_TIME:
|
|
nValue = DataType::TIME;
|
|
break;
|
|
case SQL_TYPE_TIMESTAMP:
|
|
case SQL_TIMESTAMP:
|
|
nValue = DataType::TIMESTAMP;
|
|
break;
|
|
case SQL_BINARY:
|
|
nValue = DataType::BINARY;
|
|
break;
|
|
case SQL_VARBINARY:
|
|
case SQL_GUID:
|
|
nValue = DataType::VARBINARY;
|
|
break;
|
|
case SQL_LONGVARBINARY:
|
|
nValue = DataType::LONGVARBINARY;
|
|
break;
|
|
default:
|
|
OSL_FAIL("Invalid type");
|
|
}
|
|
return nValue;
|
|
}
|
|
|
|
// jdbcTypeToOdbc
|
|
// Convert the JDBC SQL type to the correct ODBC type
|
|
|
|
SQLSMALLINT OTools::jdbcTypeToOdbc(sal_Int32 jdbcType)
|
|
{
|
|
// For the most part, JDBC types match ODBC types. We'll
|
|
// just convert the ones that we know are different
|
|
|
|
sal_Int32 odbcType = jdbcType;
|
|
|
|
switch (jdbcType)
|
|
{
|
|
case DataType::DATE:
|
|
odbcType = SQL_DATE;
|
|
break;
|
|
case DataType::TIME:
|
|
odbcType = SQL_TIME;
|
|
break;
|
|
case DataType::TIMESTAMP:
|
|
odbcType = SQL_TIMESTAMP;
|
|
break;
|
|
// ODBC doesn't have any notion of CLOB or BLOB
|
|
case DataType::CLOB:
|
|
odbcType = SQL_LONGVARCHAR;
|
|
break;
|
|
case DataType::BLOB:
|
|
odbcType = SQL_LONGVARBINARY;
|
|
break;
|
|
}
|
|
|
|
return odbcType;
|
|
}
|
|
|
|
void OTools::getBindTypes(bool _bUseWChar,
|
|
bool _bUseOldTimeDate,
|
|
SQLSMALLINT _nOdbcType,
|
|
SQLSMALLINT& fCType,
|
|
SQLSMALLINT& fSqlType
|
|
)
|
|
{
|
|
switch(_nOdbcType)
|
|
{
|
|
case SQL_CHAR: if(_bUseWChar)
|
|
{
|
|
fCType = SQL_C_WCHAR;
|
|
fSqlType = SQL_WCHAR;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_CHAR;
|
|
fSqlType = SQL_CHAR;
|
|
}
|
|
break;
|
|
case SQL_VARCHAR: if(_bUseWChar)
|
|
{
|
|
fCType = SQL_C_WCHAR;
|
|
fSqlType = SQL_WVARCHAR;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_CHAR;
|
|
fSqlType = SQL_VARCHAR;
|
|
}
|
|
break;
|
|
case SQL_LONGVARCHAR: if(_bUseWChar)
|
|
{
|
|
fCType = SQL_C_WCHAR;
|
|
fSqlType = SQL_WLONGVARCHAR;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_CHAR;
|
|
fSqlType = SQL_LONGVARCHAR;
|
|
}
|
|
break;
|
|
case SQL_DECIMAL: fCType = _bUseWChar ? SQL_C_WCHAR : SQL_C_CHAR;
|
|
fSqlType = SQL_DECIMAL; break;
|
|
case SQL_NUMERIC: fCType = _bUseWChar ? SQL_C_WCHAR : SQL_C_CHAR;
|
|
fSqlType = SQL_NUMERIC; break;
|
|
case SQL_BIT: fCType = SQL_C_TINYINT;
|
|
fSqlType = SQL_INTEGER; break;
|
|
case SQL_TINYINT: fCType = SQL_C_TINYINT;
|
|
fSqlType = SQL_TINYINT; break;
|
|
case SQL_SMALLINT: fCType = SQL_C_SHORT;
|
|
fSqlType = SQL_SMALLINT; break;
|
|
case SQL_INTEGER: fCType = SQL_C_LONG;
|
|
fSqlType = SQL_INTEGER; break;
|
|
case SQL_BIGINT: fCType = SQL_C_SBIGINT;
|
|
fSqlType = SQL_BIGINT; break;
|
|
case SQL_FLOAT: fCType = SQL_C_FLOAT;
|
|
fSqlType = SQL_FLOAT; break;
|
|
case SQL_REAL: fCType = SQL_C_DOUBLE;
|
|
fSqlType = SQL_REAL; break;
|
|
case SQL_DOUBLE: fCType = SQL_C_DOUBLE;
|
|
fSqlType = SQL_DOUBLE; break;
|
|
case SQL_BINARY: fCType = SQL_C_BINARY;
|
|
fSqlType = SQL_BINARY; break;
|
|
case SQL_VARBINARY:
|
|
fCType = SQL_C_BINARY;
|
|
fSqlType = SQL_VARBINARY; break;
|
|
case SQL_LONGVARBINARY: fCType = SQL_C_BINARY;
|
|
fSqlType = SQL_LONGVARBINARY; break;
|
|
case SQL_DATE:
|
|
if(_bUseOldTimeDate)
|
|
{
|
|
fCType = SQL_C_DATE;
|
|
fSqlType = SQL_DATE;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_TYPE_DATE;
|
|
fSqlType = SQL_TYPE_DATE;
|
|
}
|
|
break;
|
|
case SQL_TIME:
|
|
if(_bUseOldTimeDate)
|
|
{
|
|
fCType = SQL_C_TIME;
|
|
fSqlType = SQL_TIME;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_TYPE_TIME;
|
|
fSqlType = SQL_TYPE_TIME;
|
|
}
|
|
break;
|
|
case SQL_TIMESTAMP:
|
|
if(_bUseOldTimeDate)
|
|
{
|
|
fCType = SQL_C_TIMESTAMP;
|
|
fSqlType = SQL_TIMESTAMP;
|
|
}
|
|
else
|
|
{
|
|
fCType = SQL_C_TYPE_TIMESTAMP;
|
|
fSqlType = SQL_TYPE_TIMESTAMP;
|
|
}
|
|
break;
|
|
default: fCType = SQL_C_BINARY;
|
|
fSqlType = SQL_LONGVARBINARY; break;
|
|
}
|
|
}
|
|
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|