cvs commit: jakarta-avalon-cornerstone/src/java/org/apache/cornerstone/blocks/datasource DefaultDataSourceSelector.java DefaultDataSourceSelector.xinfo

[do...@apache.org]

donaldp     01/04/01 17:07:03

  Added:       src/java/org/apache/cornerstone/blocks/datasource
                        DefaultDataSourceSelector.java
                        DefaultDataSourceSelector.xinfo
  Log:
  Added in DataSourceSelector
  
  Submitted by: "Eung-ju Park" <co...@isoft.co.kr>
  
  Revision  Changes    Path
  1.1                  jakarta-avalon-cornerstone/src/java/org/apache/cornerstone/blocks/datasource/DefaultDataSourceSelector.java
  
  Index: DefaultDataSourceSelector.java
  ===================================================================
  /*
   * Copyright (C) The Apache Software Foundation. All rights reserved.
   *
   * This software is published under the terms of the Apache Software License
   * version 1.1, a copy of which has been included with this distribution in
   * the LICENSE file.
   */
  package org.apache.cornerstone.blocks.datasource;
  
  import java.util.HashMap;
  import java.util.Iterator;
  import java.util.Map;
  import org.apache.avalon.AbstractLoggable;
  import org.apache.avalon.Component;
  import org.apache.avalon.ComponentManagerException;
  import org.apache.avalon.ComponentNotFoundException;
  import org.apache.avalon.Disposable;
  import org.apache.avalon.Initializable;
  import org.apache.avalon.configuration.Configurable;
  import org.apache.avalon.configuration.Configuration;
  import org.apache.avalon.util.datasource.DataSourceComponent;
  import org.apache.cornerstone.services.datasource.DataSourceSelector;
  import org.apache.phoenix.Block;
  
  /**
   *
   * @author <a href="mailto:colus@isoft.co.kr">Eung-ju Park</a>
   */
  public class DefaultDataSourceSelector
      extends AbstractLoggable
      implements DataSourceSelector, Block, Configurable, Initializable, Disposable
  {
      private Configuration m_configuration;
      private Map           m_dataSources;
  
      public void configure( final Configuration configuration )
      {
          m_configuration = configuration;
      }
  
      public void init()
          throws Exception
      {
          m_dataSources = new HashMap();
  
          final Configuration[] dataSourceConfs = 
              m_configuration.getChild( "data-sources" ).getChildren( "data-source" );
  
          for ( int i = 0; i < dataSourceConfs.length; i++ )
          {
              final Configuration dataSourceConf = dataSourceConfs[ i ];
  
              final String name = dataSourceConf.getAttribute( "name" );
              final String clazz = dataSourceConf.getAttribute( "type" );
              final String driver = dataSourceConf.getChild( "driver" ).getValue();
  
              Class.forName( driver );
              final DataSourceComponent component = 
                  (DataSourceComponent)Class.forName( clazz ).newInstance();
              setupLogger( component, name );
              component.configure( dataSourceConf );
              m_dataSources.put( name, component );
  
              if( getLogger().isInfoEnabled() ) 
              {
                  getLogger().info( "DataSource " + name + " ready" );
              }
          }
      }
  
      public void dispose()
          throws Exception
      {
          final Iterator keys = m_dataSources.keySet().iterator();
          while ( keys.hasNext() )
          {
              final DataSourceComponent dsc = 
                  (DataSourceComponent)m_dataSources.get( keys.next() );
              if ( dsc instanceof Disposable )
              {
                  ((Disposable)dsc).dispose();
              }
          }
      }
  
      public DataSourceComponent selectDataSource( final Object hint )
          throws ComponentManagerException
      {
          return (DataSourceComponent)select( hint );
      }
  
      public Component select( final Object hint )
          throws ComponentManagerException
      {
          final Component component = (Component)m_dataSources.get( hint );
  
          if( null == component )
          {
              throw new ComponentNotFoundException( "Unable to provide implementation for "
                                                    + hint );
          }
          
          return component;
      }
  
      public void release( final Component component )
      {
          //do nothing
      }
  
  }
  
  
  
  1.1                  jakarta-avalon-cornerstone/src/java/org/apache/cornerstone/blocks/datasource/DefaultDataSourceSelector.xinfo
  
  Index: DefaultDataSourceSelector.xinfo
  ===================================================================
  <?xml version="1.0"?>
  
  <blockinfo>
  
    <meta>
      <contributors>
        <author name="Eung-ju Park" email="colus@isoft.co.kr"/>
      </contributors>
    </meta>
  
    <services>
      <service name="org.apache.cornerstone.services.datasource.DataSourceSelector" version="1.0"/>
    </services>
  
  </blockinfo>
  
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: avalon-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: avalon-dev-help@jakarta.apache.org