connectivity/workben/TT/StartTest.java

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: StartTest.java,v $
  10  * $Revision: 1.3 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30 package workben.tt;
  31
  32 import java.lang.Object;
  33 import java.io.*;
  34 import workben.odbc.*;
  35
  36 import com.sun.star.comp.servicemanager.ServiceManager;
  37 //      import java.io.IOException;
  38
  39 //import com.sun.star.beans.PropertyValue;
  40 //import com.sun.star.beans.PropertyState;
  41 import com.sun.star.connection.XConnector;
  42 import com.sun.star.connection.XConnection;
  43 import com.sun.star.bridge.XBridge;
  44
  45 //  import com.sun.star.comp.bootstrap.Bootstrap;
  46
  47 //      import com.sun.star.io.XInputStream;
  48 //      import com.sun.star.io.XOutputStream;
  49
  50 //      import com.sun.star.lang.XComponent;
  51 import com.sun.star.lang.XMultiServiceFactory;
  52 import com.sun.star.lang.XServiceInfo;
  53
  54 import com.sun.star.uno.IBridge;
  55 import com.sun.star.uno.UnoRuntime;
  56 import com.sun.star.uno.XInterface;
  57 import com.sun.star.uno.XNamingService;
  58
  59 import com.sun.star.sdbc.*;
  60 //      import com.sun.star.sdbc.XConnection;
  61 //      import com.sun.star.uno.Enum;
  62
  63 //      import com.sun.star.lib.uno.typeinfo.ParameterTypeInfo;
  64 //      import com.sun.star.lib.uno.typeinfo.TypeInfo;
  65
  66 public class StartTest
  67 {
  68   //###########################################################
  69   //#                   allgemeine Variablen                  #
  70   //###########################################################
  71   private static java.util.Hashtable ConfigItems = new java.util.Hashtable();
  72   //###########################################################
  73   //#                   ResultSetToStringBuffer               #
  74   //###########################################################
  75   static StringBuffer ResultSetToStringBuffer(com.sun.star.sdbc.XResultSet results)
  76   {
  77           com.sun.star.sdbc.XRow                           Row;
  78           com.sun.star.sdbc.XResultSetMetaDataSupplier     rsmds;
  79           com.sun.star.sdbc.XResultSetMetaData             rsmd;
  80
  81           StringBuffer buf = new StringBuffer();
  82
  83           try
  84           {
  85             rsmds = (com.sun.star.sdbc.XResultSetMetaDataSupplier)UnoRuntime.queryInterface(com.sun.star.sdbc.XResultSetMetaDataSupplier.class,results);
  86             rsmd = rsmds.getMetaData();
  87             int numCols = rsmd.getColumnCount();
  88             int i;
  89
  90             // get column header info
  91             for (i=1; i <= numCols; i++)
  92             {
  93                 if (i == 1) buf.append("\"");
  94                 if (i > 1) buf.append("\"\t\"");
  95                 buf.append(rsmd.getColumnLabel(i));
  96             }
  97             buf.append("\"\r\n");
  98
  99
 100
 101             while (results.next())
 102             {
 103                 Row = (com.sun.star.sdbc.XRow)UnoRuntime.queryInterface(com.sun.star.sdbc.XRow.class, results);
 104                 for (i=1; i <= numCols; i++)
 105                 {
 106                     if (i == 1) buf.append("\"");
 107                     if (i > 1) buf.append("\"\t\"");
 108                     buf.append(Row.getString(i));
 109                 }
 110                 buf.append("\"\r\n");
 111             }
 112             return(buf);
 113           }
 114           catch (Exception e)
 115           {
 116             System.out.println("Exception at ResultSetToStringBuffer : " + e);
 117             return(buf);
 118           }
 119   }
 120
 121   //###########################################################
 122   //#                   printStringBuffer                     #
 123   //###########################################################
 124
 125   static void printStringBuffer(StringBuffer buf)
 126   {
 127     FileWriter f1;
 128     try
 129     {
 130       f1 = new FileWriter("d:\\data\\sdbc\\test.log",true);
 131       int maxStrings = buf.length() - 1;
 132       //System.out.println(maxStrings);
 133       for(int i=0 ; i<=maxStrings ; i++)
 134       {
 135         f1.write(buf.charAt(i));
 136       }
 137       f1.close();
 138     }
 139     catch( IOException e )
 140     {
 141       System.out.println("Error: can't create logfile");
 142     }
 143   }
 144
 145   //###########################################################
 146   //#                   neededServices                        #
 147   //###########################################################
 148   static String neededServices[] = new String[] {
 149         "com.sun.star.comp.servicemanager.ServiceManager",
 150         "com.sun.star.comp.loader.JavaLoader",
 151         "com.sun.star.comp.connections.Connector",
 152           "com.sun.star.comp.connections.Acceptor"
 153     };
 154
 155   //###########################################################
 156   //#                   readConfigFile                        #
 157   //###########################################################
 158   static void readConfigFile(String sFileName)
 159   {
 160     BufferedReader confFile;
 161     try
 162     {
 163       confFile = new BufferedReader(new FileReader(sFileName));
 164       ConfigItems.put("ConnectString",confFile.readLine());
 165       ConfigItems.put("user",confFile.readLine());
 166       ConfigItems.put("password",confFile.readLine());
 167       ConfigItems.put("ToTest",confFile.readLine());
 168       ConfigItems.put("LogFile",confFile.readLine());
 169       confFile.close();
 170     }
 171     catch(Exception e)
 172     {
 173       System.out.println(e);
 174     }
 175   }
 176
 177   //###########################################################
 178   //#                   MAIN                                  #
 179   //###########################################################
 180
 181   public static void main(String argv[]) throws Exception
 182     {
 183
 184     //Die Parameter auslesen
 185
 186 //    if(argv.length == 0)
 187 //    {
 188 //      System.out.println("missing parameter");
 189 //      System.exit(0);
 190 //    }
 191
 192     //readConfigFile(argv[0]);
 193
 194     ////////////////////////
 195
 196     com.sun.star.comp.servicemanager.ServiceManager smgr = new com.sun.star.comp.servicemanager.ServiceManager();
 197         smgr.addFactories(neededServices);
 198
 199         XConnector  xConnector  = (XConnector)smgr.createInstance("com.sun.star.connection.Connector");
 200     if(xConnector == null) System.err.println("no connector!");
 201
 202         XConnection xConn               = xConnector.connect("socket,host=localhost,port=6001");
 203     if(xConn == null) System.err.println("no XConnection!");
 204
 205         IBridge iBridge = UnoRuntime.getBridgeByName("java", null, "remote", null, new Object[]{"iiop", xConn, null});
 206
 207         Object rInitialObject = iBridge.mapInterfaceFrom("classic_uno", XInterface.class);
 208
 209         if(rInitialObject != null)
 210         {
 211             System.err.println("got the remote object");
 212       System.out.println("before naming service !");
 213       try
 214       {
 215         XNamingService rName = (XNamingService)UnoRuntime.queryInterface(XNamingService.class, rInitialObject );
 216         try
 217         {
 218           if(rName != null)
 219           {
 220             System.err.println("got the remote naming service !");
 221             Object rXsmgr = rName.getRegisteredObject("StarOffice.ServiceManager");
 222             XMultiServiceFactory rSmgr = (XMultiServiceFactory)UnoRuntime.queryInterface(XMultiServiceFactory.class, rXsmgr);
 223             if(rSmgr != null)
 224             {
 225               System.out.println("got the remote service manager !");
 226               Object rDriver = rSmgr.createInstance("com.sun.star.sdbc.ADriver");
 227               if(rDriver != null)
 228               {
 229                 System.out.println("got a com.sun.star.sdbc.Driver !");
 230                 com.sun.star.sdbc.XDriver  xDriver  = (XDriver)UnoRuntime.queryInterface(com.sun.star.sdbc.XDriver.class,rDriver);
 231                 if(xDriver != null)
 232                 {
 233                   com.sun.star.sdbc.XConnection xConnection = null;
 234                   try
 235                   {
 236                     com.sun.star.beans.PropertyValue [] ConInfo = new com.sun.star.beans.PropertyValue[]
 237                     {
 238                       new com.sun.star.beans.PropertyValue("user",0,"qsuser",com.sun.star.beans.PropertyState.DIRECT_VALUE),
 239                       new com.sun.star.beans.PropertyValue("password",0,"qsuser",com.sun.star.beans.PropertyState.DIRECT_VALUE)
 240                     };
 241                     xConnection = xDriver.connect("sdbc:ado:PROVIDER=SQLOLEDB;DATA SOURCE=sqllab2",ConInfo);
 242
 243                     if(xConnection != null)
 244                     {
 245                       System.out.println("got a connection!");
 246                       com.sun.star.sdbc.XDatabaseMetaData dmd;
 247                       com.sun.star.sdbc.XStatement    stmt;
 248                       com.sun.star.sdbc.XResultSet   result;
 249                       com.sun.star.sdbc.XRow         row;
 250                       try
 251                       {
 252                         stmt = xConnection.createStatement();
 253                         stmt.executeUpdate("insert into testtab values(4,'vier')");
 254                         result = stmt.executeQuery("select * from testtab where int = 4");
 255                         com.sun.star.sdbc.XResultSetMetaDataSupplier     rsmds;
 256
 257                         rsmds = (com.sun.star.sdbc.XResultSetMetaDataSupplier)UnoRuntime.queryInterface(com.sun.star.sdbc.XResultSetMetaDataSupplier.class,result);
 258                         com.sun.star.sdbc.XResultSetMetaData  xMD = rsmds.getMetaData();
 259                         System.out.println("Anzahl Spalten = " + xMD.getColumnCount());
 260                         if(result.next())
 261                         {
 262                             row = (com.sun.star.sdbc.XRow)UnoRuntime.queryInterface(com.sun.star.sdbc.XRow.class,result);
 263                             String xx = row.getString(1);
 264                         }
 265                       }
 266                       catch (Exception e)
 267                       {
 268                       System.out.println("Exception beim Aufruf der Tests");
 269                       }
 270                     }
 271                   }
 272                   catch(Exception e)
 273                   {
 274                     System.out.println("exception while connecting!");
 275                     e.printStackTrace();
 276                   }
 277                   xConnection.close();
 278                 }
 279               }
 280             }
 281           }
 282         }
 283         catch(Exception t)
 284         {
 285         }
 286       }
 287       catch(Exception e1)
 288       {
 289         System.err.println("exception from getRegisteredObject!");
 290       }
 291     }
 292     System.out.println("FERTIG");
 293     System.exit(0);
 294   }
 295   }// die Klammer der ganzen Klasse
 296