1 files changed, 0 insertions, 125 deletions
diff --git a/das-java/tags/1.0-incubating-beta1-rc3/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ConnectionImpl.java b/das-java/tags/1.0-incubating-beta1-rc3/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ConnectionImpl.java
deleted file mode 100644
index 76baa8ca0d..0000000000
--- a/das-java/tags/1.0-incubating-beta1-rc3/rdb/src/main/java/org/apache/tuscany/das/rdb/impl/ConnectionImpl.java
+++ /dev/null
@@ -1,125 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.
- */
-package org.apache.tuscany.das.rdb.impl;
-
-import java.sql.CallableStatement;
-import java.sql.Connection;
-import java.sql.DatabaseMetaData;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-
-import org.apache.log4j.Logger;
-
-public class ConnectionImpl {
-
-    private final Logger logger = Logger.getLogger(ConnectionImpl.class);
-
-    private Connection connection;
-
-    private boolean managingTransaction = true;
-
-    private final boolean useGetGeneratedKeys;
-
-    public ConnectionImpl(Connection connection) {
-        this.connection = connection;
-
-        try {
-            DatabaseMetaData dbmd = connection.getMetaData();
-
-            if (dbmd.getDatabaseProductName().contains("Oracle")) {
-                this.useGetGeneratedKeys = false;
-            } else {
-                this.useGetGeneratedKeys = true;
-            }
-            if (connection.getAutoCommit()) {
-                throw new RuntimeException("AutoCommit must be off");
-            }
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-
-    }
-
-    public Connection getJDBCConnection() {
-        return connection;
-    }
-
-    public void cleanUp() {
-        try {
-            if (managingTransaction) {
-                if (this.logger.isDebugEnabled()) {
-                    this.logger.debug("Committing Transaction");
-                }
-                connection.commit();
-            }
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    public void errorCleanUp() {
-        try {
-            if (managingTransaction) {
-                if (this.logger.isDebugEnabled()) {
-                    this.logger.debug("Rolling back Transaction");
-                }
-                connection.rollback();
-            }
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    public PreparedStatement prepareStatement(String queryString, String[] returnKeys) throws SQLException {
-        if (this.logger.isDebugEnabled()) {
-            this.logger.debug("Preparing Statement: " + queryString);
-        }
-
-        if (useGetGeneratedKeys) {
-            return connection.prepareStatement(queryString, Statement.RETURN_GENERATED_KEYS);
-        } else if (returnKeys.length > 0) {
-            return connection.prepareStatement(queryString, returnKeys);
-        }
-
-        return connection.prepareStatement(queryString);
-    }
-
-    public PreparedStatement preparePagedStatement(String queryString) throws SQLException {
-        if (this.logger.isDebugEnabled()) {
-            this.logger.debug("Preparing Statement: " + queryString);
-        }
-
-        return connection.prepareStatement(queryString, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-    }
-
-    public void setManageTransactions(boolean manageTransactions) {
-        managingTransaction = manageTransactions;
-
-    }
-
-    public CallableStatement prepareCall(String queryString) throws SQLException {
-        return connection.prepareCall(queryString);
-    }
-
-    public boolean useGetGeneratedKeys() {
-        return this.useGetGeneratedKeys;
-    }
-}