/*
* AbstractDataSource.java 2009-4-1
*
* Copyright 2005-2012 IJAVA Tech, Inc. All rights reserved.
*/
package org.ipos.sql;
import java.io.InputStream;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
/**
* A <i>AbstractDataSource</i>
* <p>
* Specification:
* </p>
*
* @sees
* @author Steven Chen
* @since 1.0
* @version 1.0 2009-4-1
*/
public abstract class AbstractDataSource implements DataSource {
protected DataSource internalDataSource;
protected ConfigInfo configInfo;
private InputStream config;
public AbstractDataSource() {
initDataSource();
}
public AbstractDataSource(InputStream config) {
this.config = config;
initDataSource();
}
/*
* (non-Javadoc)
*
* @see javax.sql.DataSource#getConnection()
*/
public Connection getConnection() throws SQLException {
return internalDataSource.getConnection();
}
/*
* (non-Javadoc)
*
* @see javax.sql.DataSource#getConnection(java.lang.String,
* java.lang.String)
*/
public Connection getConnection(String username, String password)
throws SQLException {
return internalDataSource.getConnection(username, password);
}
/*
* (non-Javadoc)
*
* @see javax.sql.CommonDataSource#getLogWriter()
*/
public PrintWriter getLogWriter() throws SQLException {
return internalDataSource.getLogWriter();
}
/*
* (non-Javadoc)
*
* @see javax.sql.CommonDataSource#getLoginTimeout()
*/
public int getLoginTimeout() throws SQLException {
return internalDataSource.getLoginTimeout();
}
/*
* (non-Javadoc)
*
* @see javax.sql.CommonDataSource#setLogWriter(java.io.PrintWriter)
*/
public void setLogWriter(PrintWriter out) throws SQLException {
internalDataSource.setLogWriter(out);
}
/*
* (non-Javadoc)
*
* @see javax.sql.CommonDataSource#setLoginTimeout(int)
*/
public void setLoginTimeout(int seconds) throws SQLException {
internalDataSource.setLoginTimeout(seconds);
}
/*
* (non-Javadoc)
*
* @see java.sql.Wrapper#isWrapperFor(java.lang.Class)
*/
public boolean isWrapperFor(Class<?> iface) throws SQLException {
return internalDataSource.isWrapperFor(iface);
}
/*
* (non-Javadoc)
*
* @see java.sql.Wrapper#unwrap(java.lang.Class)
*/
public <T> T unwrap(Class<T> iface) throws SQLException {
return internalDataSource.unwrap(iface);
}
abstract protected void initDataSource();
public static void main(String[] args) {
AbstractDataSource a = new JNDIDataSource();
a.initConfig();
}
protected void initConfig() {
try {
if (config == null)
config = AbstractDataSource.class
.getResourceAsStream("/dbconfig.properties");
Properties proper = new Properties();
proper.load(config);
String vendor = proper.getProperty("vendor");
String url = proper.getProperty(vendor + ".url");
String driverName = proper.getProperty(vendor + ".driverName");
String username = proper.getProperty(vendor + ".username");
String password = proper.getProperty(vendor + ".password");
configInfo = new ConfigInfo(vendor, url, driverName, username,
password);
} catch (Exception e) {
throw new IllegalStateException(e);
}
}
static class ConfigInfo {
String vendor;
String url;
String username;
String password;
String driverName;
ConfigInfo(String vendor, String url, String driverName,
String username, String password) {
this.driverName = driverName;
this.password = password;
this.url = url;
this.username = username;
this.vendor = vendor;
}
}
}
