/*
 * This software is released under a licence similar to the Apache Software Licence.
 * See org.logicalcobwebs.proxool.package.html for details.
 * The latest version is available at http://proxool.sourceforge.net
 */
package org.logicalcobwebs.proxool.admin;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.logicalcobwebs.proxool.AbstractProxoolTest;
import org.logicalcobwebs.proxool.ConnectionInfoIF;
import org.logicalcobwebs.proxool.ProxoolConstants;
import org.logicalcobwebs.proxool.ProxoolFacade;
import org.logicalcobwebs.proxool.TestConstants;
import org.logicalcobwebs.proxool.TestHelper;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.Properties;

/**
 * Test {@link SnapshotIF}
 *
 * @version $Revision: 1.14 $, $Date: 2006/01/18 14:40:05 $
 * @author Bill Horsman (bill@logicalcobwebs.co.uk)
 * @author $Author: billhorsman $ (current maintainer)
 * @since Proxool 0.7
 */
public class SnapshotTest extends AbstractProxoolTest {

    private static final Log LOG = LogFactory.getLog(SnapshotTest.class);

    /**
     * @see junit.framework.TestCase#TestCase
     */
    public SnapshotTest(String s) {
        super(s);
    }

    /**
     * Test whether the statistics we get back are roughly right.
     */
    public void testSnapshot() throws Exception {

        String testName = "snapshot";
        final String alias = testName;
        String url = TestHelper.buildProxoolUrl(alias,
                TestConstants.HYPERSONIC_DRIVER,
                TestConstants.HYPERSONIC_TEST_URL);
        Properties info = new Properties();
        info.setProperty(ProxoolConstants.USER_PROPERTY, TestConstants.HYPERSONIC_USER);
        info.setProperty(ProxoolConstants.PASSWORD_PROPERTY, TestConstants.HYPERSONIC_PASSWORD);
        info.setProperty(ProxoolConstants.STATISTICS_PROPERTY, "10s,15s");
        info.setProperty(ProxoolConstants.MINIMUM_CONNECTION_COUNT_PROPERTY, "1");
        info.setProperty(ProxoolConstants.TRACE_PROPERTY, "true");

        // We don't test whether anything is logged, but this line should make something appear
        info.setProperty(ProxoolConstants.STATISTICS_LOG_LEVEL_PROPERTY, ProxoolConstants.STATISTICS_LOG_LEVEL_DEBUG);

        // Register pool
        ProxoolFacade.registerConnectionPool(url, info);

        {
            Connection connection = DriverManager.getConnection(url);
            connection.createStatement().execute(TestConstants.HYPERSONIC_TEST_SQL);
            connection.close();

            SnapshotIF snapshot = ProxoolFacade.getSnapshot(alias, true);

            assertEquals("servedCount", 1L, snapshot.getServedCount());
            assertEquals("refusedCount", 0L, snapshot.getRefusedCount());
            assertEquals("activeConnectionCount", 0, snapshot.getActiveConnectionCount());

            ConnectionInfoIF[] connectionInfos = snapshot.getConnectionInfos();
            assertTrue("connectionInfos.length != 0",  connectionInfos.length != 0);
            assertEquals("connectionInfos activeCount", 0, getCount(connectionInfos, ConnectionInfoIF.STATUS_ACTIVE));
            assertEquals("connectionInfos sql count", 1, connectionInfos[0].getSqlCalls().length);
            assertEquals("connectionInfos lastSql", TestConstants.HYPERSONIC_TEST_SQL, connectionInfos[0].getSqlCalls()[0].replace(';', ' ').trim());
        }

        {
            Connection connection = DriverManager.getConnection(url);
            connection.createStatement().execute(TestConstants.HYPERSONIC_TEST_SQL);
            connection.createStatement().execute(TestConstants.HYPERSONIC_TEST_SQL_2);

            SnapshotIF snapshot = ProxoolFacade.getSnapshot(alias, true);

            assertEquals("servedCount", 2L, snapshot.getServedCount());
            assertEquals("refusedCount", 0L, snapshot.getRefusedCount());
            assertEquals("activeConnectionCount", 1, snapshot.getActiveConnectionCount());

            ConnectionInfoIF[] connectionInfos = snapshot.getConnectionInfos();
            assertTrue("connectionInfos.length != 0",  connectionInfos.length != 0);
            assertEquals("connectionInfos activeCount", 1, getCount(connectionInfos, ConnectionInfoIF.STATUS_ACTIVE));
            assertEquals("connectionInfos sql count", 2, connectionInfos[0].getSqlCalls().length);
            assertEquals("connectionInfos lastSql", TestConstants.HYPERSONIC_TEST_SQL, connectionInfos[0].getSqlCalls()[0].replace(';', ' ').trim());
            assertEquals("connectionInfos lastSql", TestConstants.HYPERSONIC_TEST_SQL_2, connectionInfos[0].getSqlCalls()[1].replace(';', ' ').trim());

            connection.close();
        }

    }

    private int getCount(ConnectionInfoIF[] connectionInfos, int status) {
        int count = 0;
        for (int i = 0; i < connectionInfos.length; i++) {
            if (connectionInfos[i].getStatus() == status) {
                count++;
            }
        }
        return count;
    }

}

/*
 Revision history:
 $Log: SnapshotTest.java,v $
 Revision 1.14  2006/01/18 14:40:05  billhorsman
 Unbundled Jakarta's Commons Logging.

 Revision 1.13  2005/10/07 08:13:46  billhorsman
 Test new sqlCalls property of snapshot

 Revision 1.12  2003/03/10 23:46:43  billhorsman
 checkstyle

 Revision 1.11  2003/03/06 14:25:53  billhorsman
 fix for threading

 Revision 1.10  2003/03/06 11:31:17  billhorsman
 fix for unlikely prototyper situation

 Revision 1.8  2003/03/04 10:58:44  billhorsman
 checkstyle

 Revision 1.7  2003/03/04 10:24:40  billhorsman
 removed try blocks around each test

 Revision 1.6  2003/03/03 17:09:08  billhorsman
 all tests now extend AbstractProxoolTest

 Revision 1.5  2003/03/03 11:12:05  billhorsman
 fixed licence

 Revision 1.4  2003/03/01 15:27:25  billhorsman
 checkstyle

 Revision 1.3  2003/02/27 18:01:48  billhorsman
 completely rethought the test structure. it's now
 more obvious. no new tests yet though.

 Revision 1.2  2003/02/26 16:05:51  billhorsman
 widespread changes caused by refactoring the way we
 update and redefine pool definitions.

 Revision 1.1  2003/02/20 00:33:15  billhorsman
 renamed monitor package -> admin

 Revision 1.3  2003/02/19 23:36:50  billhorsman
 renamed monitor package to admin

 Revision 1.2  2003/02/19 15:14:29  billhorsman
 fixed copyright (copy and paste error,
 not copyright change)

 Revision 1.1  2003/02/07 17:28:36  billhorsman
 *** empty log message ***

 */