package com.planet_ink.fakedb;
import java.sql.*;
import java.util.Map;
import java.util.Properties;
import java.lang.ref.WeakReference;
/*
Copyright 2001 Thomas Neumann
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
@SuppressWarnings("unchecked")
public class Connection implements java.sql.Connection
{
static private java.util.Map databases = new java.util.HashMap();
static private java.util.Map references = new java.util.HashMap();
private Backend backend;
private boolean closed=false;
private String oldPath="";
static private void log(String x) {
System.err.println("Connection: "+x);
}
Backend getBackend() { return backend; }
public Connection(String path) throws java.sql.SQLException
{
try {
path=(new java.io.File(path)).getCanonicalPath();
} catch (java.io.IOException e) {}
oldPath=path;
if(!closed)
{
synchronized(references)
{
Integer conCount=(Integer)references.get(path);
if(conCount==null)
conCount=Integer.valueOf(0);
references.remove(path);
references.put(path,Integer.valueOf(conCount.intValue()+1));
}
}
synchronized (databases)
{
WeakReference ref=(WeakReference)databases.get(path);
Backend backend=null;
if (ref!=null)
backend=(Backend)ref.get();
if (backend==null) {
backend=new Backend();
if (!backend.open(new java.io.File(path)))
throw new java.sql.SQLException("unable to open database");
databases.put(path,new WeakReference(backend));
}
this.backend=backend;
}
}
public java.sql.Statement createStatement() throws java.sql.SQLException
{
return new Statement(this);
}
public java.sql.Statement createStatement(int a,int b) throws java.sql.SQLException
{ return createStatement(); }
public java.sql.Statement createStatement(int a,int b,int c) throws java.sql.SQLException
{ return createStatement(); }
public java.sql.PreparedStatement prepareStatement(String sql) throws java.sql.SQLException
{
log("prepareStatement");
return null;
}
public java.sql.PreparedStatement prepareStatement(String sql,int a) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.PreparedStatement prepareStatement(String sql,int[] a) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.PreparedStatement prepareStatement(String sql,String[] a) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.PreparedStatement prepareStatement(String sql,int a,int b) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.PreparedStatement prepareStatement(String sql,int a,int[] b) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.PreparedStatement prepareStatement(String sql,int a,int b,int c) throws java.sql.SQLException
{ return prepareStatement(sql); }
public java.sql.CallableStatement prepareCall(String sql) throws java.sql.SQLException
{
log("prepareCall");
throw new java.sql.SQLException("Callable statments not suppoted.", "S1C00");
}
public java.sql.CallableStatement prepareCall(String sql,int a,int b) throws java.sql.SQLException
{ return prepareCall(sql); }
public java.sql.CallableStatement prepareCall(String sql,int a,int b,int c) throws java.sql.SQLException
{ return prepareCall(sql); }
public int getHoldability()
{ return ResultSet.HOLD_CURSORS_OVER_COMMIT; }
public java.sql.Savepoint setSavepoint()
throws java.sql.SQLException
{ throw new java.sql.SQLException("Savepoints not supported"); }
public java.sql.Savepoint setSavepoint(String S)
throws java.sql.SQLException
{ throw new java.sql.SQLException("Savepoints not supported"); }
public void rollback(java.sql.Savepoint saved)
throws java.sql.SQLException
{ throw new java.sql.SQLException("Savepoints not supported"); }
public void releaseSavepoint(java.sql.Savepoint saved)
throws java.sql.SQLException
{ throw new java.sql.SQLException("Savepoints not supported"); }
public String nativeSQL(String sql) throws java.sql.SQLException
{
return sql;
}
public void setAutoCommit(boolean autoCommit) throws java.sql.SQLException
{
log("setAutoCommit");
if (!autoCommit)
throw new java.sql.SQLException("Cannot disable AUTO_COMMIT", "08003");
return;
}
public boolean getAutoCommit() throws java.sql.SQLException
{
return true;
}
public void commit() throws java.sql.SQLException
{
//log("commit");
}
public void rollback() throws java.sql.SQLException
{
//log("rollback");
}
public void close() throws java.sql.SQLException
{
if(!closed)
{
closed=true;
synchronized(references)
{
Integer conCount=(Integer)references.get(oldPath);
if(conCount!=null)
{
if(conCount.intValue()==1)
{
if(backend!=null)
backend.clearRelations();
backend=null;
references.remove(oldPath);
databases.remove(oldPath);
}
else
{
references.remove(oldPath);
references.put(oldPath,Integer.valueOf(conCount.intValue()-1));
}
}
}
}
}
public boolean isClosed() throws java.sql.SQLException
{
return closed;
}
public java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
{
log("getMetaData");
return null;
}
public void setReadOnly (boolean readOnly) throws java.sql.SQLException
{
log("setReadOnly");
}
public boolean isReadOnly() throws java.sql.SQLException
{
return false;
}
public void setCatalog(String Catalog) throws java.sql.SQLException
{
log("setCatalog");
}
public String getCatalog() throws java.sql.SQLException
{ return "FAKEDB"; }
public void setTransactionIsolation(int level) throws java.sql.SQLException
{
log("setTransactionIsolation");
throw new java.sql.SQLException("Transaction Isolation Levels are not supported.", "S1C00");
}
public int getTransactionIsolation() throws java.sql.SQLException
{
return java.sql.Connection.TRANSACTION_NONE;
}
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
{
log("getWarnings");
return null;
}
public void clearWarnings() throws java.sql.SQLException
{
log("clearWarnings");
}
public void setHoldability(int holdability) throws java.sql.SQLException
{}
public java.util.Map getTypeMap() throws java.sql.SQLException
{ return new java.util.HashMap(); }
public Array createArrayOf(String arg0, Object[] arg1) throws SQLException { return null; }
public Blob createBlob() throws SQLException { return null; }
public Clob createClob() throws SQLException { return null; }
public NClob createNClob() throws SQLException { return null; }
public SQLXML createSQLXML() throws SQLException { return null; }
public Struct createStruct(String arg0, Object[] arg1) throws SQLException { return null; }
public Properties getClientInfo() throws SQLException { return null; }
public String getClientInfo(String arg0) throws SQLException { return null; }
public boolean isValid(int arg0) throws SQLException { return false; }
public void setClientInfo(Properties arg0) throws SQLClientInfoException { }
public void setClientInfo(String arg0, String arg1) throws SQLClientInfoException { }
//public void setTypeMap(Map arg0) throws SQLException { }
public void setTypeMap(Map<String, Class<?>> arg0) throws SQLException { }
public boolean isWrapperFor(Class<?> iface) throws SQLException { return false;}
public <T> T unwrap(Class<T> iface) throws SQLException { return null; }
// JDK 1.4 stuff
/*
public int getHoldability() throws java.sql.SQLException
{ return java.sql.ResultSet.CLOSE_CURSORS_AT_COMMIT; }
public void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
{}
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
{ return null; }
public java.sql.Savepoint setSavepoint(String name) throws java.sql.SQLException
{ return null; }
public void rollback(java.sql.Savepoint p) throws java.sql.SQLException
{ rollback(); }
*/
}
