| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| import java.io.*; |
| |
| import com.sun.star.comp.helper.RegistryServiceFactory; |
| import com.sun.star.comp.servicemanager.ServiceManager; |
| import com.sun.star.lang.XMultiComponentFactory; |
| import com.sun.star.lang.XSingleServiceFactory; |
| import com.sun.star.lang.XServiceInfo; |
| import com.sun.star.lang.XComponent; |
| import com.sun.star.bridge.XUnoUrlResolver; |
| import com.sun.star.uno.UnoRuntime; |
| import com.sun.star.uno.XComponentContext; |
| import com.sun.star.beans.XPropertySet; |
| import com.sun.star.container.XNameAccess; |
| import com.sun.star.container.XNameContainer; |
| import com.sun.star.sdbc.*; |
| import com.sun.star.sdb.*; |
| import com.sun.star.sdbcx.*; |
| import com.sun.star.frame.*; |
| |
| public class CodeSamples |
| { |
| public static XComponentContext xContext; |
| public static XMultiComponentFactory xMCF; |
| |
| public static void main(String argv[]) throws java.lang.Exception |
| { |
| try { |
| // get the remote office component context |
| xContext = com.sun.star.comp.helper.Bootstrap.bootstrap(); |
| System.out.println("Connected to a running office ..."); |
| xMCF = xContext.getServiceManager(); |
| } |
| catch(Exception e) { |
| System.err.println("ERROR: can't get a component context from a running office ..."); |
| e.printStackTrace(); |
| System.exit(1); |
| } |
| |
| try{ |
| createQuerydefinition( ); |
| printQueryColumnNames( ); |
| |
| XConnection con = openConnectionWithDriverManager(); |
| if ( con != null ) { |
| { |
| SalesMan sm = new SalesMan( con ); |
| |
| try { |
| sm.dropSalesManTable( ); // doesn't matter here |
| } |
| catch(com.sun.star.uno.Exception e) |
| { |
| } |
| sm.createSalesManTable( ); |
| sm.insertDataIntoSalesMan( ); |
| sm.updateSalesMan( ); |
| sm.retrieveSalesManData( ); |
| } |
| |
| { |
| Sales sm = new Sales( con ); |
| |
| try { |
| sm.dropSalesTable( ); // doesn't matter here |
| } |
| catch(com.sun.star.uno.Exception e) |
| { |
| } |
| sm.createSalesTable( ); |
| sm.insertDataIntoSales( ); |
| sm.updateSales( ); |
| sm.retrieveSalesData( ); |
| sm.displayColumnNames( ); |
| } |
| displayTableStructure( con ); |
| } |
| // printDataSources(); |
| } |
| catch(Exception e) |
| { |
| System.err.println(e); |
| e.printStackTrace(); |
| } |
| System.exit(0); |
| } |
| |
| // check if the connection is not null aand dispose it later on. |
| public static void checkConnection(XConnection con) throws com.sun.star.uno.Exception |
| { |
| if(con != null) |
| { |
| System.out.println("Connection was created!"); |
| // now we dispose the connection to close it |
| XComponent xComponent = (XComponent)UnoRuntime.queryInterface(XComponent.class,con); |
| if(xComponent != null) |
| { |
| // connections must be disposed |
| xComponent.dispose(); |
| System.out.println("Connection disposed!"); |
| } |
| } |
| else |
| System.out.println("Connection could not be created!"); |
| } |
| |
| // uses the driver manager to create a new connection and dispose it. |
| public static XConnection openConnectionWithDriverManager() throws com.sun.star.uno.Exception |
| { |
| XConnection con = null; |
| // create the DriverManager |
| Object driverManager = |
| xMCF.createInstanceWithContext("com.sun.star.sdbc.DriverManager", |
| xContext); |
| // query for the interface |
| com.sun.star.sdbc.XDriverManager xDriverManager; |
| xDriverManager = (XDriverManager)UnoRuntime.queryInterface(XDriverManager.class,driverManager); |
| if(xDriverManager != null) |
| { |
| // first create the needed url |
| String url = "jdbc:mysql://localhost:3306/TestTables"; |
| // second create the necessary properties |
| com.sun.star.beans.PropertyValue [] props = new com.sun.star.beans.PropertyValue[] |
| { |
| new com.sun.star.beans.PropertyValue("user",0,"test1",com.sun.star.beans.PropertyState.DIRECT_VALUE), |
| new com.sun.star.beans.PropertyValue("password",0,"test1",com.sun.star.beans.PropertyState.DIRECT_VALUE), |
| new com.sun.star.beans.PropertyValue("JavaDriverClass",0,"org.gjt.mm.mysql.Driver",com.sun.star.beans.PropertyState.DIRECT_VALUE) |
| }; |
| // now create a connection to mysql |
| con = xDriverManager.getConnectionWithInfo(url,props); |
| } |
| return con; |
| } |
| |
| // uses the driver directly to create a new connection and dispose it. |
| public static XConnection openConnectionWithDriver() throws com.sun.star.uno.Exception |
| { |
| XConnection con = null; |
| // create the Driver with the implementation name |
| Object aDriver = |
| xMCF.createInstanceWithContext("org.openoffice.comp.drivers.MySQL.Driver", |
| xContext); |
| // query for the interface |
| com.sun.star.sdbc.XDriver xDriver; |
| xDriver = (XDriver)UnoRuntime.queryInterface(XDriver.class,aDriver); |
| if(xDriver != null) |
| { |
| // first create the needed url |
| String url = "jdbc:mysql://localhost:3306/TestTables"; |
| // second create the necessary properties |
| com.sun.star.beans.PropertyValue [] props = new com.sun.star.beans.PropertyValue[] |
| { |
| new com.sun.star.beans.PropertyValue("user",0,"test1",com.sun.star.beans.PropertyState.DIRECT_VALUE), |
| new com.sun.star.beans.PropertyValue("password",0,"test1",com.sun.star.beans.PropertyState.DIRECT_VALUE), |
| new com.sun.star.beans.PropertyValue("JavaDriverClass",0,"org.gjt.mm.mysql.Driver",com.sun.star.beans.PropertyState.DIRECT_VALUE) |
| }; |
| // now create a connection to mysql |
| con = xDriver.connect(url,props); |
| } |
| return con; |
| } |
| |
| // print all available datasources |
| public static void printDataSources() throws com.sun.star.uno.Exception |
| { |
| // create a DatabaseContext and print all DataSource names |
| XNameAccess xNameAccess = (XNameAccess)UnoRuntime.queryInterface( |
| XNameAccess.class, |
| xMCF.createInstanceWithContext("com.sun.star.sdb.DatabaseContext", |
| xContext)); |
| String aNames [] = xNameAccess.getElementNames(); |
| for(int i=0;i<aNames.length;++i) |
| System.out.println(aNames[i]); |
| } |
| |
| // displays the structure of the first table |
| public static void displayTableStructure(XConnection con) throws com.sun.star.uno.Exception |
| { |
| XDatabaseMetaData dm = con.getMetaData(); |
| XResultSet rsTables = dm.getTables(null,"%","SALES",null); |
| XRow rowTB = (XRow)UnoRuntime.queryInterface(XRow.class, rsTables); |
| while ( rsTables.next() ) |
| { |
| String catalog = rowTB.getString( 1 ); |
| if ( rowTB.wasNull() ) |
| catalog = null; |
| |
| String schema = rowTB.getString( 2 ); |
| if ( rowTB.wasNull() ) |
| schema = null; |
| |
| String table = rowTB.getString( 3 ); |
| String type = rowTB.getString( 4 ); |
| System.out.println("Catalog: " + catalog + " Schema: " + schema + " Table: " + table + " Type: " + type); |
| System.out.println("------------------ Columns ------------------"); |
| XResultSet rsColumns = dm.getColumns(catalog,schema,table,"%"); |
| XRow rowCL = (XRow)UnoRuntime.queryInterface(XRow.class, rsColumns); |
| while ( rsColumns.next() ) |
| { |
| System.out.println("Column: " + rowCL.getString( 4 ) + " Type: " + rowCL.getInt( 5 ) + " TypeName: " + rowCL.getString( 6 ) ); |
| } |
| |
| } |
| } |
| |
| // quote the given name |
| public static String quoteTableName(XConnection con, String sCatalog, String sSchema, String sTable) throws com.sun.star.uno.Exception |
| { |
| XDatabaseMetaData dbmd = con.getMetaData(); |
| String sQuoteString = dbmd.getIdentifierQuoteString(); |
| String sSeparator = "."; |
| String sComposedName = ""; |
| String sCatalogSep = dbmd.getCatalogSeparator(); |
| if (0 != sCatalog.length() && dbmd.isCatalogAtStart() && 0 != sCatalogSep.length()) |
| { |
| sComposedName += sCatalog; |
| sComposedName += dbmd.getCatalogSeparator(); |
| } |
| if (0 != sSchema.length()) |
| { |
| sComposedName += sSchema; |
| sComposedName += sSeparator; |
| sComposedName += sTable; |
| } |
| else |
| { |
| sComposedName += sTable; |
| } |
| if (0 != sCatalog.length() && !dbmd.isCatalogAtStart() && 0 != sCatalogSep.length()) |
| { |
| sComposedName += dbmd.getCatalogSeparator(); |
| sComposedName += sCatalog; |
| } |
| return sComposedName; |
| } |
| |
| // creates a new query definition |
| public static void createQuerydefinition() throws com.sun.star.uno.Exception |
| { |
| XNameAccess xNameAccess = (XNameAccess)UnoRuntime.queryInterface( |
| XNameAccess.class, |
| xMCF.createInstanceWithContext("com.sun.star.sdb.DatabaseContext", |
| xContext)); |
| // we use the first datasource |
| XQueryDefinitionsSupplier xQuerySup = (XQueryDefinitionsSupplier) |
| UnoRuntime.queryInterface(XQueryDefinitionsSupplier.class, |
| xNameAccess.getByName( "Bibliography" )); |
| XNameAccess xQDefs = xQuerySup.getQueryDefinitions(); |
| // create new query definition |
| XSingleServiceFactory xSingleFac = (XSingleServiceFactory) |
| UnoRuntime.queryInterface(XSingleServiceFactory.class, xQDefs); |
| |
| XPropertySet xProp = (XPropertySet) UnoRuntime.queryInterface( |
| XPropertySet.class,xSingleFac.createInstance()); |
| xProp.setPropertyValue("Command","SELECT * FROM biblio"); |
| xProp.setPropertyValue("EscapeProcessing",new Boolean(true)); |
| |
| XNameContainer xCont = (XNameContainer) UnoRuntime.queryInterface(XNameContainer.class, xQDefs); |
| try |
| { |
| if ( xCont.hasByName("Query1") ) |
| xCont.removeByName("Query1"); |
| } |
| catch(com.sun.star.uno.Exception e) |
| {} |
| xCont.insertByName("Query1",xProp); |
| XDocumentDataSource xDs = (XDocumentDataSource)UnoRuntime.queryInterface(XDocumentDataSource.class, xQuerySup); |
| |
| XStorable xStore = (XStorable)UnoRuntime.queryInterface(XStorable.class,xDs.getDatabaseDocument()); |
| xStore.store(); |
| } |
| |
| // prints all column names from Query1 |
| public static void printQueryColumnNames() throws com.sun.star.uno.Exception |
| { |
| XNameAccess xNameAccess = (XNameAccess)UnoRuntime.queryInterface( |
| XNameAccess.class, |
| xMCF.createInstanceWithContext("com.sun.star.sdb.DatabaseContext", |
| xContext)); |
| // we use the first datasource |
| XDataSource xDS = (XDataSource)UnoRuntime.queryInterface( |
| XDataSource.class, xNameAccess.getByName( "Bibliography" )); |
| XConnection con = xDS.getConnection("",""); |
| XQueriesSupplier xQuerySup = (XQueriesSupplier) |
| UnoRuntime.queryInterface(XQueriesSupplier.class, con); |
| |
| XNameAccess xQDefs = xQuerySup.getQueries(); |
| |
| XColumnsSupplier xColsSup = (XColumnsSupplier) UnoRuntime.queryInterface( |
| XColumnsSupplier.class,xQDefs.getByName("Query1")); |
| XNameAccess xCols = xColsSup.getColumns(); |
| String aNames [] = xCols.getElementNames(); |
| for(int i=0;i<aNames.length;++i) |
| System.out.println(aNames[i]); |
| } |
| } |
| |
