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" <[EMAIL PROTECTED]>
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:[EMAIL PROTECTED]">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="[EMAIL PROTECTED]"/>
</contributors>
</meta>
<services>
<service name="org.apache.cornerstone.services.datasource.DataSourceSelector"
version="1.0"/>
</services>
</blockinfo>
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
