connectivity/source/drivers/postgresql/pq_array.cxx

   1 #include <rtl/ustrbuf.hxx>
   2
   3 #include <com/sun/star/sdbc/XArray.hpp>
   4 #include <com/sun/star/sdbc/DataType.hpp>
   5
   6
   7 #include "pq_array.hxx"
   8 #include "pq_statics.hxx"
   9 #include "pq_sequenceresultset.hxx"
  10
  11 using rtl::OUString;
  12
  13 using com::sun::star::sdbc::SQLException;
  14 using com::sun::star::uno::Any;
  15
  16 using com::sun::star::uno::Sequence;
  17 namespace pq_sdbc_driver
  18 {
  19
  20
  21 ::rtl::OUString Array::getBaseTypeName(  )
  22         throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  23 {
  24     return OUString( RTL_CONSTASCII_USTRINGPARAM( "varchar" ) );
  25 }
  26
  27 sal_Int32 Array::getBaseType(  )
  28         throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  29 {
  30     return  com::sun::star::sdbc::DataType::VARCHAR;
  31 }
  32
  33 ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Any > Array::getArray(
  34         const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap )
  35         throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  36 {
  37     return m_data;
  38 }
  39
  40 ::com::sun::star::uno::Sequence< ::com::sun::star::uno::Any > Array::getArrayAtIndex(
  41     sal_Int32 index,
  42     sal_Int32 count,
  43     const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap )
  44     throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  45 {
  46     checkRange( index, count );
  47     return Sequence< Any > ( &m_data[index-1], count );
  48 }
  49
  50 ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSet > Array::getResultSet(
  51     const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap )
  52         throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  53 {
  54     return getResultSetAtIndex( 0 , m_data.getLength() , typeMap );
  55 }
  56
  57 ::com::sun::star::uno::Reference< ::com::sun::star::sdbc::XResultSet > Array::getResultSetAtIndex(
  58     sal_Int32 index,
  59     sal_Int32 count,
  60         const ::com::sun::star::uno::Reference< ::com::sun::star::container::XNameAccess >& typeMap )
  61         throw (::com::sun::star::sdbc::SQLException, ::com::sun::star::uno::RuntimeException)
  62 {
  63     checkRange( index, count );
  64     Sequence< Sequence< Any > > ret( count );
  65
  66     for( int i = 0 ; i < count ; i ++ )
  67     {
  68         Sequence< Any > row( 2 );
  69         row[0] <<= (sal_Int32) ( i + index );
  70         row[1] = m_data[i+index-1];
  71         ret[i] = row;
  72     }
  73
  74     return new SequenceResultSet(
  75         m_refMutex, m_owner, getStatics().resultSetArrayColumnNames, ret, m_tc );
  76 }
  77
  78
  79 void Array::checkRange( sal_Int32 index, sal_Int32 count )
  80 {
  81     if( index >= 1 && index -1 + count <= m_data.getLength() )
  82         return;
  83     rtl::OUStringBuffer buf;
  84     buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "Array::getArrayAtIndex(): allowed range for index + count " ) );
  85     buf.append( m_data.getLength() );
  86     buf.appendAscii( ", got " );
  87     buf.append( index );
  88     buf.appendAscii( " + " );
  89     buf.append( count );
  90
  91     throw SQLException( buf.makeStringAndClear() , *this, rtl::OUString(), 1, Any());
  92
  93 }
  94
  95 }