From b5db9b865ad1ef45831233b33f670ace623209ce Mon Sep 17 00:00:00 2001
From: Oliver Bolte <obo@openoffice.org>
Date: Fri, 4 Jan 2008 15:31:11 +0000
Subject: INTEGRATION: CWS fwk77 (1.1.2); FILE ADDED 2007/10/18 12:04:37 mav
 1.1.2.1: #i75848# OLESimpleStorage service tests

---
 sot/qa/complex/olesimplestorage/Test01.java | 126 ++++++++++++++++++++++++++++
 1 file changed, 126 insertions(+)
 create mode 100644 sot/qa/complex/olesimplestorage/Test01.java

(limited to 'sot/qa')

diff --git a/sot/qa/complex/olesimplestorage/Test01.java b/sot/qa/complex/olesimplestorage/Test01.java
new file mode 100644
index 000000000000..c9010e61231a
--- /dev/null
+++ b/sot/qa/complex/olesimplestorage/Test01.java
@@ -0,0 +1,126 @@
+package complex.olesimplestorage;
+
+import complexlib.ComplexTestCase;
+
+import com.sun.star.lang.XMultiServiceFactory;
+import com.sun.star.io.XInputStream;
+import com.sun.star.io.XOutputStream;
+import com.sun.star.io.XTempFile;
+import com.sun.star.embed.XOLESimpleStorage;
+import com.sun.star.uno.UnoRuntime;
+
+import java.util.Random;
+import share.LogWriter;
+
+public class Test01 implements OLESimpleStorageTest
+{
+    XMultiServiceFactory m_xMSF = null;
+    TestHelper m_aTestHelper = null;
+    final int pStreamCnt = 5;
+    final int pBytesCnt = 10;
+
+    public Test01 ( XMultiServiceFactory xMSF, LogWriter aLogWriter )
+    {
+        m_xMSF = xMSF;
+        m_aTestHelper = new TestHelper (aLogWriter, "Test01: ");
+    }
+
+    public boolean test ()
+    {
+        try
+        {
+            //create a new temporary stream
+            Object oTempFile = m_xMSF.createInstance ( "com.sun.star.io.TempFile" );
+            XTempFile xTempFile = (XTempFile) UnoRuntime.queryInterface ( XTempFile.class, oTempFile );
+            m_aTestHelper.Message ( "A new temporary stream created." );
+
+            //create OLESimpleStorage based on it
+            Object pArgs[] = new Object[2];
+            pArgs[0] = (Object) xTempFile;
+            pArgs[1] = new Boolean( true );
+            Object oOLESimpleStorage = m_xMSF.createInstanceWithArguments ( "com.sun.star.embed.OLESimpleStorage", pArgs );
+            XOLESimpleStorage xOLESimpleStorage = (XOLESimpleStorage) UnoRuntime.queryInterface ( XOLESimpleStorage.class, oOLESimpleStorage );
+            m_aTestHelper.Message ( "OLESimpleStorage based on XStream created." );
+
+            //fill it with some streams
+            Object oStream[] = new Object[pStreamCnt];
+            byte pBytesIn[][][] = new byte [pStreamCnt][1][pBytesCnt];
+            byte pBytesOut[][] = new byte [pStreamCnt][pBytesCnt];
+            XTempFile xTempStream[] = new XTempFile[pStreamCnt];
+            Random oRandom = new Random ();
+            final String sSubStreamPrefix = "SubStream";
+            for ( int i = 0; i < pStreamCnt; i++ )
+            {
+                oRandom.nextBytes (pBytesOut[i]);
+                oStream[i] = m_xMSF.createInstance ( "com.sun.star.io.TempFile" );
+                xTempStream[i] = (XTempFile) UnoRuntime.queryInterface ( XTempFile.class, oStream[i] );
+                xTempStream[i].getOutputStream ().writeBytes (pBytesOut[i]);
+                xTempStream[i].seek (0);
+                m_aTestHelper.Message ( "Substream " + i + " initialized." );
+                if (xOLESimpleStorage.hasByName (sSubStreamPrefix + i))
+                {
+                    xOLESimpleStorage.replaceByName ( sSubStreamPrefix + i, xTempStream[i] );
+                }
+                else
+                {
+                    xOLESimpleStorage.insertByName ( sSubStreamPrefix + i, xTempStream[i] );
+                    m_aTestHelper.Message ( "Substream " + i + " inserted." );
+                }
+            }
+
+            //commit the storage and close it
+            xOLESimpleStorage.commit ();
+            m_aTestHelper.Message ( "Storage commited." );
+            xOLESimpleStorage.dispose ();
+            for ( int i = 0; i < pStreamCnt; ++i )
+            {
+                xTempStream[i].setRemoveFile ( true );
+                xTempStream[i].getInputStream ().closeInput ();
+                xTempStream[i].getOutputStream ().closeOutput ();
+            }
+            m_aTestHelper.Message ( "Storage closed." );
+
+            //open the same stream with the constructor for inputstream
+            pArgs[0] = (Object)xTempFile.getInputStream ();
+            oOLESimpleStorage = m_xMSF.createInstanceWithArguments ( "com.sun.star.embed.OLESimpleStorage", pArgs );
+            xOLESimpleStorage = (XOLESimpleStorage)UnoRuntime.queryInterface ( XOLESimpleStorage.class, oOLESimpleStorage );
+            m_aTestHelper.Message ( "Storage reopened, based on XInputStream." );
+
+            //check that all the streams contain correct information
+            m_aTestHelper.Message ( "Checking data contained in all the substreams..." );
+            for ( int i = 0; i < pStreamCnt; ++i )
+            {
+                if ( xOLESimpleStorage.hasByName (sSubStreamPrefix + i) )
+                {
+                    xTempStream[i] = (XTempFile)UnoRuntime.queryInterface (
+                    XTempFile.class, xOLESimpleStorage.getByName (sSubStreamPrefix + i) );
+                    xTempStream[i].seek (0);
+                    xTempStream[i].getInputStream ().readBytes (pBytesIn[i], pBytesIn[i][0].length + 1 );
+                    for ( int j = 0; j < pBytesCnt; ++j )
+                    {
+                        if ( pBytesIn[i][0][j] != pBytesOut[i][j] )
+                        {
+                            m_aTestHelper.Error ( "Stream " + i + " byte " + j + ": INCORRECT DATA!");
+                            return false;
+                        }
+                        else
+                        {
+                            m_aTestHelper.Message ( "Stream " + i + " byte " + j + ":  CORRECT." );
+                        }
+                    }
+                }
+                else
+                {
+                    m_aTestHelper.Error( "Stream " + i + " is lost!");
+                    return false;
+                }
+            }
+            m_aTestHelper.Message ( "All substreams contain correct data. SUCCESS." );
+        }
+        catch ( Exception e )
+        {
+            m_aTestHelper.Error ( "Exception: " + e );
+        }
+        return true;
+    }
+}
-- 
cgit v1.2.3