/*
 * 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.avalon.excalibur.logger.factory;

import org.apache.avalon.excalibur.logger.LogTargetFactory;

import org.apache.log.LogTarget;
import org.apache.log.output.db.DefaultJDBCTarget;
import org.apache.log.output.db.NormalizedJDBCTarget;
import org.apache.log.output.db.ColumnInfo;
import org.apache.log.output.db.ColumnType;

import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.Configurable;
import org.apache.avalon.framework.configuration.ConfigurationException;

import javax.sql.DataSource;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

/**
 * Factory for JDBCLogTarget-s. The configuration looks like this:
 *
 * <pre>
 *  &lt;jdbc id="database"&gt;
 *      &lt;datasource&gt;java:/LogTargetDataSource&lt;/datasource&gt;
 *      &lt;normalized&gt;true&lt;/normalized&gt;
 *      &lt;table name="LOG"&gt;
 *         &lt;sequence&gt;ID&lt;/sequence&gt;
 *          &lt;category&gt;CATEGORY&lt;/category&gt;
 *          &lt;priority&gt;PRIORITY&lt;/priority&gt;
 *          &lt;message&gt;MESSAGE&lt;/message&gt;
 *          &lt;time&gt;TIME&lt;/time&gt;
 *          &lt;rtime&gt;RTIME&lt;/rtime&gt;
 *          &lt;throwable&gt;THROWABLE&lt;/throwable&gt;
 *          &lt;hostname&gt;HOSTNAME&lt;/hostname&gt;
 *          &lt;static aux="-"&gt;STATIC&lt;/static&gt;
 *          &lt;context aux="principal"&gt;PRINCIPAL&lt;/context&gt;
 *          &lt;context aux="ipaddress"&gt;IPADDRESS&lt;/context&gt;
 *          &lt;context aux="username"&gt;USERNAME&lt;/context&gt;
 *      &lt;/table&gt;
 *  &lt;/jdbc&gt;
 * </pre>
 *
 * @author <a href="mailto:mirceatoma@home.com">Mircea Toma</a>;
 * @version CVS $Revision$ $Date$
 */
public class JDBCTargetFactory implements LogTargetFactory
{
    
    public LogTarget createTarget(Configuration configuration)
    throws ConfigurationException
    {
        final String dataSourceName =
            configuration.getChild("datasource", true).getValue();
        
        final boolean normalized =
            configuration.getChild("normalized", true).getValueAsBoolean(false);
        
        final Configuration tableConfiguration =
            configuration.getChild("table");
        
        final String table = tableConfiguration.getAttribute("name");
        
        final Configuration[] conf = tableConfiguration.getChildren();
        final ColumnInfo[] columns = new ColumnInfo[conf.length];
        
        for (int i = 0; i < conf.length; i++)
        {
            final String name = conf[i].getValue();
            final int type = ColumnType.getTypeIdFor(conf[i].getName());
            final String aux = conf[i].getAttribute("aux", null);
            
            columns[i] = new ColumnInfo(name, type, aux);
        }
        
        final DataSource dataSource;
        final LogTarget logTarget;
        
        try
        {
            Context ctx = new InitialContext();
            dataSource = (DataSource) ctx.lookup(dataSourceName);
        }
        catch (NamingException ne)
        {
            throw new ConfigurationException("Cannot lookup data source", ne);
        }
        
        if (normalized)
        {
            logTarget = new NormalizedJDBCTarget(dataSource, table, columns);
        }
        else
        {
            logTarget = new DefaultJDBCTarget(dataSource, table, columns);
        }
        
        return logTarget;
    }
}