1*ef39d40dSAndrew Rist /**************************************************************
2cdf0e10cSrcweir  *
3*ef39d40dSAndrew Rist  * Licensed to the Apache Software Foundation (ASF) under one
4*ef39d40dSAndrew Rist  * or more contributor license agreements.  See the NOTICE file
5*ef39d40dSAndrew Rist  * distributed with this work for additional information
6*ef39d40dSAndrew Rist  * regarding copyright ownership.  The ASF licenses this file
7*ef39d40dSAndrew Rist  * to you under the Apache License, Version 2.0 (the
8*ef39d40dSAndrew Rist  * "License"); you may not use this file except in compliance
9*ef39d40dSAndrew Rist  * with the License.  You may obtain a copy of the License at
10*ef39d40dSAndrew Rist  *
11*ef39d40dSAndrew Rist  *   http://www.apache.org/licenses/LICENSE-2.0
12*ef39d40dSAndrew Rist  *
13*ef39d40dSAndrew Rist  * Unless required by applicable law or agreed to in writing,
14*ef39d40dSAndrew Rist  * software distributed under the License is distributed on an
15*ef39d40dSAndrew Rist  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*ef39d40dSAndrew Rist  * KIND, either express or implied.  See the License for the
17*ef39d40dSAndrew Rist  * specific language governing permissions and limitations
18*ef39d40dSAndrew Rist  * under the License.
19*ef39d40dSAndrew Rist  *
20*ef39d40dSAndrew Rist  *************************************************************/
21*ef39d40dSAndrew Rist 
22*ef39d40dSAndrew Rist 
23cdf0e10cSrcweir 
24cdf0e10cSrcweir package ifc.ucb;
25cdf0e10cSrcweir 
26cdf0e10cSrcweir import lib.MultiMethodTest;
27cdf0e10cSrcweir import lib.Status;
28cdf0e10cSrcweir import lib.StatusException;
29cdf0e10cSrcweir 
30cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory;
31cdf0e10cSrcweir import com.sun.star.sdbc.XResultSet;
32cdf0e10cSrcweir import com.sun.star.ucb.XCachedDynamicResultSetFactory;
33cdf0e10cSrcweir import com.sun.star.ucb.XCachedDynamicResultSetStubFactory;
34cdf0e10cSrcweir import com.sun.star.ucb.XDynamicResultSet;
35cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime;
36cdf0e10cSrcweir 
37cdf0e10cSrcweir /**
38cdf0e10cSrcweir * Testing <code>com.sun.star.ucb.XCachedDynamicResultSetStubFactory</code>
39cdf0e10cSrcweir * interface methods :
40cdf0e10cSrcweir * <ul>
41cdf0e10cSrcweir *  <li><code> createCachedDynamicResultSetStub()</code></li>
42cdf0e10cSrcweir *  <li><code> connectToCache()</code></li>
43cdf0e10cSrcweir * </ul> <p>
44cdf0e10cSrcweir * This test needs the following object relations :
45cdf0e10cSrcweir * <ul>
46cdf0e10cSrcweir *  <li> <code>'DynamicResultSet'</code> (of type
47cdf0e10cSrcweir *   <code>com.sun.star.sdbc.XDynamicResultSet</code>):
48cdf0e10cSrcweir *   this must be an imlementation of <code>
49cdf0e10cSrcweir *   com.sun.star.ucb.DynamicResultSet</code> service.</li>
50cdf0e10cSrcweir * <ul> <p>
51cdf0e10cSrcweir * Test is <b> NOT </b> multithread compilant. <p>
52cdf0e10cSrcweir * @see com.sun.star.ucb.XCachedDynamicResultSetStubFactory
53cdf0e10cSrcweir */
54cdf0e10cSrcweir public class _XCachedDynamicResultSetStubFactory extends MultiMethodTest {
55cdf0e10cSrcweir 
56cdf0e10cSrcweir     /**
57cdf0e10cSrcweir      * Conatins the tested object.
58cdf0e10cSrcweir      */
59cdf0e10cSrcweir     public XCachedDynamicResultSetStubFactory oObj;
60cdf0e10cSrcweir     private XDynamicResultSet resSet = null ;
61cdf0e10cSrcweir     private XDynamicResultSet resSetStub = null ;
62cdf0e10cSrcweir 
63cdf0e10cSrcweir     /**
64cdf0e10cSrcweir     * Retrieves object relation.
65cdf0e10cSrcweir     * @throws StatusException If relation not found.
66cdf0e10cSrcweir     */
before()67cdf0e10cSrcweir     public void before() {
68cdf0e10cSrcweir         resSet = (XDynamicResultSet) tEnv.getObjRelation("DynamicResultSet") ;
69cdf0e10cSrcweir         if (resSet == null) {
70cdf0e10cSrcweir             log.println("!!! Relation not found !!!") ;
71cdf0e10cSrcweir             throw new StatusException(Status.failed("!!! Relation not found !!!")) ;
72cdf0e10cSrcweir         }
73cdf0e10cSrcweir     }
74cdf0e10cSrcweir 
75cdf0e10cSrcweir     /**
76cdf0e10cSrcweir     * Creates result set stub from result set. After that number
77cdf0e10cSrcweir     * of rows from result set stub created and its source set are retrieved
78cdf0e10cSrcweir     * using their static representations and compared. <p>
79cdf0e10cSrcweir     * Has <b>OK</b> status if numbers of rows are equal and they are
80cdf0e10cSrcweir     * greater then 0 (because JAR file contains at least one entry).
81cdf0e10cSrcweir     */
_createCachedDynamicResultSetStub()82cdf0e10cSrcweir     public void _createCachedDynamicResultSetStub() {
83cdf0e10cSrcweir         boolean result = true ;
84cdf0e10cSrcweir 
85cdf0e10cSrcweir         resSetStub = oObj.createCachedDynamicResultSetStub(resSet) ;
86cdf0e10cSrcweir 
87cdf0e10cSrcweir         if (resSetStub == null) {
88cdf0e10cSrcweir             log.println("!!! Method returned null !!!") ;
89cdf0e10cSrcweir             result = false ;
90cdf0e10cSrcweir         } else {
91cdf0e10cSrcweir             try {
92cdf0e10cSrcweir                 XResultSet resSetS = resSet.getStaticResultSet() ;
93cdf0e10cSrcweir                 XResultSet resSetStubS = resSetStub.getStaticResultSet() ;
94cdf0e10cSrcweir 
95cdf0e10cSrcweir                 resSetStubS.last() ;
96cdf0e10cSrcweir                 int stubRowNum = resSetStubS.getRow() ;
97cdf0e10cSrcweir 
98cdf0e10cSrcweir                 resSetS.last() ;
99cdf0e10cSrcweir                 int setRowNum = resSetS.getRow() ;
100cdf0e10cSrcweir 
101cdf0e10cSrcweir                 result = stubRowNum == setRowNum && setRowNum > 0 ;
102cdf0e10cSrcweir 
103cdf0e10cSrcweir                 log.println("Number of rows : stub=" + stubRowNum +
104cdf0e10cSrcweir                     " set=" + setRowNum) ;
105cdf0e10cSrcweir             } catch (com.sun.star.sdbc.SQLException e) {
106cdf0e10cSrcweir                 log.println("!!! Something wrong with result sets :") ;
107cdf0e10cSrcweir                 e.printStackTrace(log) ;
108cdf0e10cSrcweir                 result = false ;
109cdf0e10cSrcweir             } catch (com.sun.star.ucb.ListenerAlreadySetException e) {
110cdf0e10cSrcweir                 log.println("!!! Can't get static result sets :") ;
111cdf0e10cSrcweir                 e.printStackTrace(log) ;
112cdf0e10cSrcweir                 result = false ;
113cdf0e10cSrcweir             }
114cdf0e10cSrcweir         }
115cdf0e10cSrcweir 
116cdf0e10cSrcweir         tRes.tested("createCachedDynamicResultSetStub()", result) ;
117cdf0e10cSrcweir     }
118cdf0e10cSrcweir 
119cdf0e10cSrcweir     /**
120cdf0e10cSrcweir     * Creates an instance of <code>CachedDynamicResultSet</code> service
121cdf0e10cSrcweir     * which is not connected to any stub. Then tries to connect it to
122cdf0e10cSrcweir     * <code>DynaminResultSet</code> created and passed as relation.
123cdf0e10cSrcweir     * Connection is checked by retrieving and comparing of row numbers
124cdf0e10cSrcweir     * of connected set and its source set. <p>
125cdf0e10cSrcweir     * Has <b>OK</b> status if row numbers are equal and they are
126cdf0e10cSrcweir     * greater then 0 (because JAR file contains at least one entry).
127cdf0e10cSrcweir     */
_connectToCache()128cdf0e10cSrcweir     public void _connectToCache() {
129cdf0e10cSrcweir         boolean result = true ;
130cdf0e10cSrcweir 
131cdf0e10cSrcweir         XCachedDynamicResultSetFactory setFac = null ;
132cdf0e10cSrcweir 
133cdf0e10cSrcweir         try {
134cdf0e10cSrcweir             Object fac = ((XMultiServiceFactory)tParam.getMSF()).createInstance
135cdf0e10cSrcweir                 ("com.sun.star.ucb.CachedDynamicResultSetFactory") ;
136cdf0e10cSrcweir 
137cdf0e10cSrcweir             setFac = (XCachedDynamicResultSetFactory) UnoRuntime.queryInterface
138cdf0e10cSrcweir                 (XCachedDynamicResultSetFactory.class, fac) ;
139cdf0e10cSrcweir         } catch (com.sun.star.uno.Exception e) {
140cdf0e10cSrcweir             log.println("Cant instantiate a service") ;
141cdf0e10cSrcweir             e.printStackTrace(log) ;
142cdf0e10cSrcweir             result = false ;
143cdf0e10cSrcweir         }
144cdf0e10cSrcweir 
145cdf0e10cSrcweir         XDynamicResultSet rmtSet = setFac.createCachedDynamicResultSet(null, null) ;
146cdf0e10cSrcweir 
147cdf0e10cSrcweir         try {
148cdf0e10cSrcweir             oObj.connectToCache(resSet, rmtSet, null, null) ;
149cdf0e10cSrcweir         } catch (com.sun.star.ucb.ListenerAlreadySetException e) {
150cdf0e10cSrcweir             log.println("!!! Unexpected exception :" + e) ;
151cdf0e10cSrcweir             result = false ;
152cdf0e10cSrcweir         } catch (com.sun.star.ucb.AlreadyInitializedException e) {
153cdf0e10cSrcweir             log.println("!!! Unexpected exception :" + e) ;
154cdf0e10cSrcweir             result = false ;
155cdf0e10cSrcweir         }
156cdf0e10cSrcweir 
157cdf0e10cSrcweir         if (result) {
158cdf0e10cSrcweir             // checking connection to the source
159cdf0e10cSrcweir             try {
160cdf0e10cSrcweir                 XResultSet statRmtSet = rmtSet.getStaticResultSet() ;
161cdf0e10cSrcweir                 XResultSet statResSet = resSet.getStaticResultSet() ;
162cdf0e10cSrcweir 
163cdf0e10cSrcweir                 statRmtSet.last() ;
164cdf0e10cSrcweir                 int rmtRowNum = statRmtSet.getRow() ;
165cdf0e10cSrcweir 
166cdf0e10cSrcweir                 statResSet.last() ;
167cdf0e10cSrcweir                 int resRowNum = statResSet.getRow() ;
168cdf0e10cSrcweir 
169cdf0e10cSrcweir                 result = rmtRowNum == resRowNum && resRowNum > 0 ;
170cdf0e10cSrcweir 
171cdf0e10cSrcweir                 log.println("Number of rows : destination=" + rmtRowNum +
172cdf0e10cSrcweir                     " source=" + resRowNum) ;
173cdf0e10cSrcweir             } catch (com.sun.star.sdbc.SQLException e) {
174cdf0e10cSrcweir                 log.println("!!! Something wrong with result sets :") ;
175cdf0e10cSrcweir                 e.printStackTrace(log) ;
176cdf0e10cSrcweir                 result = false ;
177cdf0e10cSrcweir             } catch (com.sun.star.ucb.ListenerAlreadySetException e) {
178cdf0e10cSrcweir                 log.println("!!! Something wrong with result sets :") ;
179cdf0e10cSrcweir                 e.printStackTrace(log) ;
180cdf0e10cSrcweir                 result = false ;
181cdf0e10cSrcweir             }
182cdf0e10cSrcweir         }
183cdf0e10cSrcweir 
184cdf0e10cSrcweir         tRes.tested("connectToCache()", result) ;
185cdf0e10cSrcweir     }
186cdf0e10cSrcweir 
187cdf0e10cSrcweir }
188cdf0e10cSrcweir 
189