package com.mchange.v2.c3p0.stmt;
import java.sql.Connection;
import java.sql.ResultSet;
import java.lang.reflect.Method;
import com.mchange.v2.coalesce.*;
import java.sql.Connection;
import java.sql.ResultSet;
import java.lang.reflect.Method;
import com.mchange.v2.coalesce.*;
final class ValueIdentityStatementCacheKey extends StatementCacheKey
{
final static Coalescer keyCoalescer;
static ValueIdentityStatementCacheKey spare = new ValueIdentityStatementCacheKey();
static
{
CoalesceChecker cc = new CoalesceChecker()
{
public boolean checkCoalesce( Object a, Object b )
{ return StatementCacheKey.equals( (StatementCacheKey) a, b ); }
public int coalesceHash( Object a )
{ return ((ValueIdentityStatementCacheKey) a).cached_hash; }
};
keyCoalescer = CoalescerFactory.createCoalescer( cc, true, false );
}
static StatementCacheKey _find( Connection pcon, Method stmtProducingMethod, Object[] args )
{
String stmtText = (String) args[0];
boolean is_callable = stmtProducingMethod.getName().equals("prepareCall");
int result_set_type;
int result_set_concurrency;
int[] columnIndexes;
String[] columnNames;
Integer autogeneratedKeys;
Integer resultSetHoldability;
if (args.length == 1)
{
result_set_type = ResultSet.TYPE_FORWARD_ONLY;
result_set_concurrency = ResultSet.CONCUR_READ_ONLY;
columnIndexes = null;
columnNames = null;
autogeneratedKeys = null;
resultSetHoldability = null;
}
else if (args.length == 2)
{
Class[] argTypes = stmtProducingMethod.getParameterTypes();
if (argTypes[1].isArray())
{
Class baseType = argTypes[1].getComponentType();
if (baseType == int.class)
{
result_set_type = ResultSet.TYPE_FORWARD_ONLY;
result_set_concurrency = ResultSet.CONCUR_READ_ONLY;
columnIndexes = (int[]) args[1];
columnNames = null;
autogeneratedKeys = null;
resultSetHoldability = null;
}
else if (baseType == String.class)
{
result_set_type = ResultSet.TYPE_FORWARD_ONLY;
result_set_concurrency = ResultSet.CONCUR_READ_ONLY;
columnIndexes = null;
columnNames = (String[]) args[1];
autogeneratedKeys = null;
resultSetHoldability = null;
}
else
throw new IllegalArgumentException("c3p0 probably needs to be updated for some new " +
"JDBC spec! As of JDBC3, we expect two arg statement " +
"producing methods where the second arg is either " +
"an int, int array, or String array.");
}
else
{
result_set_type = ResultSet.TYPE_FORWARD_ONLY;
result_set_concurrency = ResultSet.CONCUR_READ_ONLY;
columnIndexes = null;
columnNames = null;
autogeneratedKeys = (Integer) args[1];
resultSetHoldability = null;
}
}
else if (args.length == 3)
{
result_set_type = ((Integer) args[1]).intValue();
result_set_concurrency = ((Integer) args[2]).intValue();
columnIndexes = null;
columnNames = null;
autogeneratedKeys = null;
resultSetHoldability = null;
}
else if (args.length == 4)
{
result_set_type = ((Integer) args[1]).intValue();
result_set_concurrency = ((Integer) args[2]).intValue();
columnIndexes = null;
columnNames = null;
autogeneratedKeys = null;
resultSetHoldability = (Integer) args[3];
}
else
throw new IllegalArgumentException("Unexpected number of args to " +
stmtProducingMethod.getName() );
spare.init( pcon,
stmtText,
is_callable,
result_set_type,
result_set_concurrency,
columnIndexes,
columnNames,
autogeneratedKeys,
resultSetHoldability );
StatementCacheKey out = (StatementCacheKey) keyCoalescer.coalesce( spare );
if (out == spare)
spare = new ValueIdentityStatementCacheKey();
return out;
}
void init( Connection physicalConnection,
String stmtText,
boolean is_callable,
int result_set_type,
int result_set_concurrency,
int[] columnIndexes,
String[] columnNames,
Integer autogeneratedKeys,
Integer resultSetHoldability )
{
super.init( physicalConnection,
stmtText,
is_callable,
result_set_type,
result_set_concurrency,
columnIndexes,
columnNames,
autogeneratedKeys,
resultSetHoldability );
this.cached_hash = StatementCacheKey.hashCode( this );
}
int cached_hash;
}