package com.planet_ink.fakedb;
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.
*/
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=new Integer(0);
references.remove(path);
references.put(path,new Integer(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,new Integer(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 void setTypeMap(java.util.Map map) throws java.sql.SQLException
{}
// 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(); }
*/
}
