FirebirdConnection.java

package database;
import java.io.File;
import java.sql.Connection;

/** êëàññ, êîòîðûé âîçâðàùàåò ñîåäèåíèå ñ áàçîé äàííûõ íà îñíîâàíèè ðàñøèðåíèÿ */
public class FirebirdConnection implements IConnector{
	/** UserName*/
	private String userName="SYSDBA";
	/** password*/
	private String password="masterkey";
	/** òåêóùèé Pool ñîåäèíåíèé ñ áàçîé äàííûõ */
	private ConnectorPool connectorPool;
	/** èìÿ äðàéâåðà JDBC Firebird */
	private static String driverName = "org.firebirdsql.jdbc.FBDriver";
	
	/** êîííåêòîð ê áàçå äàííûõ Firebird, 
	 * @param url - ïîëíûé ïóòü ê áàçå äàííûõ 
	 * @throws Exception - åñëè íå óäàëîñü ñîçäàòü ñîåäèíåíèå ñ áàçîé äàííûõ 
	 */
	public FirebirdConnection(String url) throws Exception {
		this.connectorPool=new ConnectorPool(driverName, this.getUrlFromFile(null, url, null), userName, password);
	}

	/** êîííåêòîð ê áàçå äàííûõ Firebird, 
	 * @param url - ïîëíûé ïóòü ê áàçå äàííûõ 
	 * @param userName - èìÿ ïîëüçîâàòåëÿ 
	 * @param userPassword - ïàðîëü ïîëüçîâàòåëÿ 
	 * @throws Exception - åñëè íå óäàëîñü ñîçäàòü ñîåäèíåíèå ñ áàçîé äàííûõ 
	 */
	public FirebirdConnection(String url, String userName, String userPassword) throws Exception {
		this.userName=userName;
		this.password=userPassword;
		this.connectorPool=new ConnectorPool(driverName, this.getUrlFromFile(null, url, null), userName, userPassword);
	}
	
	public FirebirdConnection(File file) throws Exception{
		this.connectorPool=new ConnectorPool(driverName, this.getUrlFromFile(null, file.getAbsolutePath().replace('\\', '/'),null), userName, password);
	}
	
	/** ïîëó÷èòü èç ôàéëà ïîëíûé URL äëÿ áàçû äàííûõ Firebird */
	private String getUrlFromFile(String path_to_server, String path,Integer port) {
        String database_protocol="jdbc:firebirdsql://";
        String database_dialect="?sql_dialect=3";
        String database_server=null;
        String database_port=null;
        if((path_to_server==null)||(path_to_server.equals(""))){
            database_server="localhost";
        }else{
            database_server=path_to_server;
        }
        if(port==null){
            database_port="3050";
        }else{
            database_port=Integer.toString(port);
        }
        String returnValue=database_protocol+database_server+":"+database_port+"/"+path+database_dialect;
        // System.out.println(returnValue);
        return returnValue;
	}

	@Override
	public Connection getConnection() {
		return this.connectorPool.getConnection();
	}

	@Override
	public Connection getConnection(String user, String password) {
		return this.connectorPool.getConnection(user,password);
	}
	
}