1*ae15d43aSAndrew Rist /**************************************************************
2cdf0e10cSrcweir  *
3*ae15d43aSAndrew Rist  * Licensed to the Apache Software Foundation (ASF) under one
4*ae15d43aSAndrew Rist  * or more contributor license agreements.  See the NOTICE file
5*ae15d43aSAndrew Rist  * distributed with this work for additional information
6*ae15d43aSAndrew Rist  * regarding copyright ownership.  The ASF licenses this file
7*ae15d43aSAndrew Rist  * to you under the Apache License, Version 2.0 (the
8*ae15d43aSAndrew Rist  * "License"); you may not use this file except in compliance
9*ae15d43aSAndrew Rist  * with the License.  You may obtain a copy of the License at
10*ae15d43aSAndrew Rist  *
11*ae15d43aSAndrew Rist  *   http://www.apache.org/licenses/LICENSE-2.0
12*ae15d43aSAndrew Rist  *
13*ae15d43aSAndrew Rist  * Unless required by applicable law or agreed to in writing,
14*ae15d43aSAndrew Rist  * software distributed under the License is distributed on an
15*ae15d43aSAndrew Rist  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*ae15d43aSAndrew Rist  * KIND, either express or implied.  See the License for the
17*ae15d43aSAndrew Rist  * specific language governing permissions and limitations
18*ae15d43aSAndrew Rist  * under the License.
19*ae15d43aSAndrew Rist  *
20*ae15d43aSAndrew Rist  *************************************************************/
21*ae15d43aSAndrew Rist 
22*ae15d43aSAndrew Rist 
23cdf0e10cSrcweir 
24cdf0e10cSrcweir import com.sun.star.beans.XPropertySet;
25cdf0e10cSrcweir import com.sun.star.container.XIndexAccess;
26cdf0e10cSrcweir import com.sun.star.container.XNameAccess;
27cdf0e10cSrcweir import com.sun.star.io.XInputStream;
28cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory;
29cdf0e10cSrcweir import com.sun.star.sdbc.SQLException;
30cdf0e10cSrcweir import com.sun.star.sdbc.XArray;
31cdf0e10cSrcweir import com.sun.star.sdbc.XBlob;
32cdf0e10cSrcweir import com.sun.star.sdbc.XClob;
33cdf0e10cSrcweir import com.sun.star.sdbc.XRef;
34cdf0e10cSrcweir import com.sun.star.sdbc.XRow;
35cdf0e10cSrcweir import com.sun.star.sdbc.XRowSet;
36cdf0e10cSrcweir import com.sun.star.sdbc.XRowSetListener;
37cdf0e10cSrcweir import com.sun.star.sdbcx.XColumnsSupplier;
38cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime;
39cdf0e10cSrcweir import com.sun.star.uno.XComponentContext;
40cdf0e10cSrcweir import com.sun.star.util.Date;
41cdf0e10cSrcweir import com.sun.star.util.DateTime;
42cdf0e10cSrcweir import com.sun.star.util.Time;
43cdf0e10cSrcweir 
44cdf0e10cSrcweir public class RowSet implements XRowSet, XRow
45cdf0e10cSrcweir {
46cdf0e10cSrcweir     private XRowSet                 m_rowSet;
47cdf0e10cSrcweir     private XRow                    m_row;
48cdf0e10cSrcweir     private XPropertySet            m_rowSetProps;
49cdf0e10cSrcweir 
RowSet( XComponentContext _context, String _dataSource, int _commandType, String _command )50cdf0e10cSrcweir     public RowSet( XComponentContext _context, String _dataSource, int _commandType, String _command )
51cdf0e10cSrcweir     {
52cdf0e10cSrcweir         try
53cdf0e10cSrcweir         {
54cdf0e10cSrcweir             m_rowSetProps = (XPropertySet)UnoRuntime.queryInterface(
55cdf0e10cSrcweir                 XPropertySet.class, _context.getServiceManager().createInstanceWithContext( "com.sun.star.sdb.RowSet", _context ) );
56cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "DataSourceName", _dataSource );
57cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "CommandType", new Integer( _commandType ) );
58cdf0e10cSrcweir             m_rowSetProps.setPropertyValue( "Command", _command );
59cdf0e10cSrcweir 
60cdf0e10cSrcweir             m_rowSet = (XRowSet)UnoRuntime.queryInterface( XRowSet.class, m_rowSetProps );
61cdf0e10cSrcweir             m_row = (XRow)UnoRuntime.queryInterface( XRow.class, m_rowSetProps );
62cdf0e10cSrcweir         }
63cdf0e10cSrcweir         catch ( Exception e )
64cdf0e10cSrcweir         {
65cdf0e10cSrcweir             e.printStackTrace(System.err);
66cdf0e10cSrcweir             throw new java.lang.InstantiationError();
67cdf0e10cSrcweir         }
68cdf0e10cSrcweir     }
69cdf0e10cSrcweir 
70cdf0e10cSrcweir     // misc
getColumnCount()71cdf0e10cSrcweir     public int getColumnCount()
72cdf0e10cSrcweir     {
73cdf0e10cSrcweir         XColumnsSupplier suppCols = (XColumnsSupplier)UnoRuntime.queryInterface(
74cdf0e10cSrcweir             XColumnsSupplier.class, m_rowSet );
75cdf0e10cSrcweir         XIndexAccess columns = (XIndexAccess)UnoRuntime.queryInterface(
76cdf0e10cSrcweir             XIndexAccess.class, suppCols.getColumns() );
77cdf0e10cSrcweir         return columns.getCount();
78cdf0e10cSrcweir     }
79cdf0e10cSrcweir 
80cdf0e10cSrcweir     // XRowSet
execute()81cdf0e10cSrcweir     public void execute() throws SQLException
82cdf0e10cSrcweir     {
83cdf0e10cSrcweir         m_rowSet.execute();
84cdf0e10cSrcweir     }
85cdf0e10cSrcweir 
addRowSetListener( XRowSetListener _listener )86cdf0e10cSrcweir     public void addRowSetListener( XRowSetListener _listener )
87cdf0e10cSrcweir     {
88cdf0e10cSrcweir         m_rowSet.addRowSetListener( _listener );
89cdf0e10cSrcweir     }
90cdf0e10cSrcweir 
removeRowSetListener( XRowSetListener _listener )91cdf0e10cSrcweir     public void removeRowSetListener( XRowSetListener _listener )
92cdf0e10cSrcweir     {
93cdf0e10cSrcweir         m_rowSet.removeRowSetListener( _listener );
94cdf0e10cSrcweir     }
95cdf0e10cSrcweir 
next()96cdf0e10cSrcweir     public boolean next() throws SQLException
97cdf0e10cSrcweir     {
98cdf0e10cSrcweir         return m_rowSet.next();
99cdf0e10cSrcweir     }
100cdf0e10cSrcweir 
isBeforeFirst()101cdf0e10cSrcweir     public boolean isBeforeFirst() throws SQLException
102cdf0e10cSrcweir     {
103cdf0e10cSrcweir         return m_rowSet.isBeforeFirst();
104cdf0e10cSrcweir     }
105cdf0e10cSrcweir 
isAfterLast()106cdf0e10cSrcweir     public boolean isAfterLast() throws SQLException
107cdf0e10cSrcweir     {
108cdf0e10cSrcweir         return m_rowSet.isAfterLast();
109cdf0e10cSrcweir     }
110cdf0e10cSrcweir 
isFirst()111cdf0e10cSrcweir     public boolean isFirst() throws SQLException
112cdf0e10cSrcweir     {
113cdf0e10cSrcweir         return m_rowSet.isFirst();
114cdf0e10cSrcweir     }
115cdf0e10cSrcweir 
isLast()116cdf0e10cSrcweir     public boolean isLast() throws SQLException
117cdf0e10cSrcweir     {
118cdf0e10cSrcweir         return m_rowSet.isLast();
119cdf0e10cSrcweir     }
120cdf0e10cSrcweir 
beforeFirst()121cdf0e10cSrcweir     public void beforeFirst() throws SQLException
122cdf0e10cSrcweir     {
123cdf0e10cSrcweir         m_rowSet.beforeFirst();
124cdf0e10cSrcweir     }
125cdf0e10cSrcweir 
afterLast()126cdf0e10cSrcweir     public void afterLast() throws SQLException
127cdf0e10cSrcweir     {
128cdf0e10cSrcweir         m_rowSet.afterLast();
129cdf0e10cSrcweir     }
130cdf0e10cSrcweir 
first()131cdf0e10cSrcweir     public boolean first() throws SQLException
132cdf0e10cSrcweir     {
133cdf0e10cSrcweir         return m_rowSet.first();
134cdf0e10cSrcweir     }
135cdf0e10cSrcweir 
last()136cdf0e10cSrcweir     public boolean last() throws SQLException
137cdf0e10cSrcweir     {
138cdf0e10cSrcweir         return m_rowSet.last();
139cdf0e10cSrcweir     }
140cdf0e10cSrcweir 
getRow()141cdf0e10cSrcweir     public int getRow() throws SQLException
142cdf0e10cSrcweir     {
143cdf0e10cSrcweir         return m_rowSet.getRow();
144cdf0e10cSrcweir     }
145cdf0e10cSrcweir 
absolute(int i)146cdf0e10cSrcweir     public boolean absolute(int i) throws SQLException
147cdf0e10cSrcweir     {
148cdf0e10cSrcweir         return m_rowSet.absolute(i);
149cdf0e10cSrcweir     }
150cdf0e10cSrcweir 
relative(int i)151cdf0e10cSrcweir     public boolean relative(int i) throws SQLException
152cdf0e10cSrcweir     {
153cdf0e10cSrcweir         return m_rowSet.relative(i);
154cdf0e10cSrcweir     }
155cdf0e10cSrcweir 
previous()156cdf0e10cSrcweir     public boolean previous() throws SQLException
157cdf0e10cSrcweir     {
158cdf0e10cSrcweir         return m_rowSet.previous();
159cdf0e10cSrcweir     }
160cdf0e10cSrcweir 
refreshRow()161cdf0e10cSrcweir     public void refreshRow() throws SQLException
162cdf0e10cSrcweir     {
163cdf0e10cSrcweir         m_rowSet.refreshRow();
164cdf0e10cSrcweir     }
165cdf0e10cSrcweir 
rowUpdated()166cdf0e10cSrcweir     public boolean rowUpdated() throws SQLException
167cdf0e10cSrcweir     {
168cdf0e10cSrcweir         return m_rowSet.rowUpdated();
169cdf0e10cSrcweir     }
170cdf0e10cSrcweir 
rowInserted()171cdf0e10cSrcweir     public boolean rowInserted() throws SQLException
172cdf0e10cSrcweir     {
173cdf0e10cSrcweir         return m_rowSet.rowInserted();
174cdf0e10cSrcweir     }
175cdf0e10cSrcweir 
rowDeleted()176cdf0e10cSrcweir     public boolean rowDeleted() throws SQLException
177cdf0e10cSrcweir     {
178cdf0e10cSrcweir         return m_rowSet.rowDeleted();
179cdf0e10cSrcweir     }
180cdf0e10cSrcweir 
181cdf0e10cSrcweir     // XRow
getStatement()182cdf0e10cSrcweir     public Object getStatement() throws SQLException
183cdf0e10cSrcweir     {
184cdf0e10cSrcweir         return m_rowSet.getStatement();
185cdf0e10cSrcweir     }
186cdf0e10cSrcweir 
wasNull()187cdf0e10cSrcweir     public boolean wasNull() throws SQLException
188cdf0e10cSrcweir     {
189cdf0e10cSrcweir         return m_row.wasNull();
190cdf0e10cSrcweir     }
191cdf0e10cSrcweir 
getString(int i)192cdf0e10cSrcweir     public String getString(int i) throws SQLException
193cdf0e10cSrcweir     {
194cdf0e10cSrcweir         return m_row.getString(i);
195cdf0e10cSrcweir     }
196cdf0e10cSrcweir 
getBoolean(int i)197cdf0e10cSrcweir     public boolean getBoolean(int i) throws SQLException
198cdf0e10cSrcweir     {
199cdf0e10cSrcweir         return m_row.getBoolean(i);
200cdf0e10cSrcweir     }
201cdf0e10cSrcweir 
getByte(int i)202cdf0e10cSrcweir     public byte getByte(int i) throws SQLException
203cdf0e10cSrcweir     {
204cdf0e10cSrcweir         return m_row.getByte(i);
205cdf0e10cSrcweir     }
206cdf0e10cSrcweir 
getShort(int i)207cdf0e10cSrcweir     public short getShort(int i) throws SQLException
208cdf0e10cSrcweir     {
209cdf0e10cSrcweir         return m_row.getShort(i);
210cdf0e10cSrcweir     }
211cdf0e10cSrcweir 
getInt(int i)212cdf0e10cSrcweir     public int getInt(int i) throws SQLException
213cdf0e10cSrcweir     {
214cdf0e10cSrcweir         return m_row.getInt(i);
215cdf0e10cSrcweir     }
216cdf0e10cSrcweir 
getLong(int i)217cdf0e10cSrcweir     public long getLong(int i) throws SQLException
218cdf0e10cSrcweir     {
219cdf0e10cSrcweir         return m_row.getLong(i);
220cdf0e10cSrcweir     }
221cdf0e10cSrcweir 
getFloat(int i)222cdf0e10cSrcweir     public float getFloat(int i) throws SQLException
223cdf0e10cSrcweir     {
224cdf0e10cSrcweir         return m_row.getFloat(i);
225cdf0e10cSrcweir     }
226cdf0e10cSrcweir 
getDouble(int i)227cdf0e10cSrcweir     public double getDouble(int i) throws SQLException
228cdf0e10cSrcweir     {
229cdf0e10cSrcweir         return m_row.getDouble(i);
230cdf0e10cSrcweir     }
231cdf0e10cSrcweir 
getBytes(int i)232cdf0e10cSrcweir     public byte[] getBytes(int i) throws SQLException
233cdf0e10cSrcweir     {
234cdf0e10cSrcweir         return m_row.getBytes(i);
235cdf0e10cSrcweir     }
236cdf0e10cSrcweir 
getDate(int i)237cdf0e10cSrcweir     public Date getDate(int i) throws SQLException
238cdf0e10cSrcweir     {
239cdf0e10cSrcweir         return m_row.getDate(i);
240cdf0e10cSrcweir     }
241cdf0e10cSrcweir 
getTime(int i)242cdf0e10cSrcweir     public Time getTime(int i) throws SQLException
243cdf0e10cSrcweir     {
244cdf0e10cSrcweir         return m_row.getTime(i);
245cdf0e10cSrcweir     }
246cdf0e10cSrcweir 
getTimestamp(int i)247cdf0e10cSrcweir     public DateTime getTimestamp(int i) throws SQLException
248cdf0e10cSrcweir     {
249cdf0e10cSrcweir         return m_row.getTimestamp(i);
250cdf0e10cSrcweir     }
251cdf0e10cSrcweir 
getBinaryStream(int i)252cdf0e10cSrcweir     public XInputStream getBinaryStream(int i) throws SQLException
253cdf0e10cSrcweir     {
254cdf0e10cSrcweir         return m_row.getBinaryStream(i);
255cdf0e10cSrcweir     }
256cdf0e10cSrcweir 
getCharacterStream(int i)257cdf0e10cSrcweir     public XInputStream getCharacterStream(int i) throws SQLException
258cdf0e10cSrcweir     {
259cdf0e10cSrcweir         return m_row.getCharacterStream(i);
260cdf0e10cSrcweir     }
261cdf0e10cSrcweir 
getObject(int i, XNameAccess xNameAccess)262cdf0e10cSrcweir     public Object getObject(int i, XNameAccess xNameAccess) throws SQLException
263cdf0e10cSrcweir     {
264cdf0e10cSrcweir         return m_row.getObject(i, xNameAccess);
265cdf0e10cSrcweir     }
266cdf0e10cSrcweir 
getRef(int i)267cdf0e10cSrcweir     public XRef getRef(int i) throws SQLException
268cdf0e10cSrcweir     {
269cdf0e10cSrcweir         return m_row.getRef(i);
270cdf0e10cSrcweir     }
271cdf0e10cSrcweir 
getBlob(int i)272cdf0e10cSrcweir     public XBlob getBlob(int i) throws SQLException
273cdf0e10cSrcweir     {
274cdf0e10cSrcweir         return m_row.getBlob(i);
275cdf0e10cSrcweir     }
276cdf0e10cSrcweir 
getClob(int i)277cdf0e10cSrcweir     public XClob getClob(int i) throws SQLException
278cdf0e10cSrcweir     {
279cdf0e10cSrcweir         return m_row.getClob(i);
280cdf0e10cSrcweir     }
281cdf0e10cSrcweir 
getArray(int i)282cdf0e10cSrcweir     public XArray getArray(int i) throws SQLException
283cdf0e10cSrcweir     {
284cdf0e10cSrcweir         return m_row.getArray(i);
285cdf0e10cSrcweir     }
286cdf0e10cSrcweir };
287