Application: gvSIG desktop

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.sqlite.dal;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import java.sql.Statement;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.spi.DataTransactionServices;

import org.gvsig.fmap.dal.store.jdbc2.JDBCConnection;

import org.gvsig.fmap.dal.store.jdbc2.spi.ConnectionProvider;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCConnectionBase;

/**

 *

 * @author fdiaz

 */

public class SQLiteJDBCConnection extends JDBCConnectionBase {

    public static JDBCConnection create(SQLiteHelper helper) throws SQLException {

        SQLiteConnectionParameters connectionParameters = helper.getConnectionParameters();

        String key = helper.getConnectionProviderKey(connectionParameters);

        SQLiteJDBCConnection conn = new SQLiteJDBCConnection(

                helper.getTransaction(),

                helper.getConnectionProvider().getConnection(),

                key

        );

        return conn;

    }

    public SQLiteJDBCConnection(DataTransactionServices transaction, Connection conn, String id) {

        super(transaction, conn, id);

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] createConnection() "+isInDataTransaction());

    }

    public SQLiteJDBCConnection(DataTransactionServices transaction,Connection conn, String id, ConnectionProvider connectionProvider) {

        super(transaction, conn, id, connectionProvider);

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] createConnection() "+isInDataTransaction());

    }

    @Override

    public void close() throws SQLException {

//        if( this.transaction==null ) {

//            LOGGER.info("["+JDBCUtils.getConnId(conn)+"] closeConnection() "+isInDataTransaction());

//        }

        super.close();

    }

    @Override

    public synchronized void begin() throws SQLException {

//        if(!isInTransaction()){

//            LOGGER.info("["+JDBCUtils.getConnId(conn)+"] begin() "+isInDataTransaction());

//        }

        super.begin();

    }

    @Override

    public synchronized void commit() throws SQLException {

//        if( !(this.transaction!=null && this.transaction.isInProgress() )) {

//            LOGGER.info("["+JDBCUtils.getConnId(conn)+"] commit() "+isInDataTransaction());

//        }

        super.commit();

    }

    @Override

    public void abort() throws DataException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] abort() "+isInDataTransaction());

        super.abort();

    }

    @Override

    public void finish() throws DataException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] finish() "+isInDataTransaction());

        super.finish();

    }

    @Override

    public void execute(String sql) throws SQLException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] execute("+sql+") "+isInDataTransaction());

        super.execute(sql); 

    }

    @Override

    public PreparedStatement prepareStatement(String sql) throws SQLException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] prepareStatement("+sql+") "+isInDataTransaction());

        return super.prepareStatement(sql);

    }

    @Override

    public void rollback() throws SQLException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] rollback() "+isInDataTransaction());

        super.rollback();

    }

    @Override

    public Statement createStatement() throws SQLException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] createStatement() "+isInDataTransaction());

        return super.createStatement();

    }

    @Override

    public Statement createStatement(String sql) throws SQLException {

//        LOGGER.info("["+JDBCUtils.getConnId(conn)+"] createStatement("+sql+") "+isInDataTransaction());

        return super.createStatement(sql);

    }

}