aries-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From z..@apache.org
Subject svn commit: r1075106 [5/18] - in /aries/tags/samples-0.1-incubating: ./ ariestrader/ ariestrader/assemblies/ ariestrader/assemblies/ariestrader-all-eba/ ariestrader/assemblies/ariestrader-jdbc-eba/ ariestrader/assemblies/equinox-test-harness/ ariestrad...
Date Sun, 27 Feb 2011 18:28:41 GMT
Added: aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/java/org/apache/aries/samples/ariestrader/persist/jdbc/TradeJdbc.java
URL: http://svn.apache.org/viewvc/aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/java/org/apache/aries/samples/ariestrader/persist/jdbc/TradeJdbc.java?rev=1075106&view=auto
==============================================================================
--- aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/java/org/apache/aries/samples/ariestrader/persist/jdbc/TradeJdbc.java (added)
+++ aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/java/org/apache/aries/samples/ariestrader/persist/jdbc/TradeJdbc.java Sun Feb 27 18:28:26 2011
@@ -0,0 +1,1610 @@
+/**
+ *  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.aries.samples.ariestrader.persist.jdbc;
+
+import java.math.BigDecimal;
+import java.util.Collection;
+import java.util.ArrayList;
+import javax.sql.DataSource;
+
+import org.apache.aries.samples.ariestrader.api.TradeServices;
+import org.apache.aries.samples.ariestrader.beans.AccountDataBeanImpl;
+import org.apache.aries.samples.ariestrader.beans.AccountProfileDataBeanImpl;
+import org.apache.aries.samples.ariestrader.beans.HoldingDataBeanImpl;
+import org.apache.aries.samples.ariestrader.beans.OrderDataBeanImpl;
+import org.apache.aries.samples.ariestrader.beans.QuoteDataBeanImpl;
+import org.apache.aries.samples.ariestrader.api.persistence.AccountDataBean;
+import org.apache.aries.samples.ariestrader.api.persistence.AccountProfileDataBean;
+import org.apache.aries.samples.ariestrader.api.persistence.HoldingDataBean;
+import org.apache.aries.samples.ariestrader.api.persistence.MarketSummaryDataBean;
+import org.apache.aries.samples.ariestrader.api.persistence.OrderDataBean;
+import org.apache.aries.samples.ariestrader.api.persistence.QuoteDataBean;
+import org.apache.aries.samples.ariestrader.util.FinancialUtils;
+import org.apache.aries.samples.ariestrader.util.Log;
+import org.apache.aries.samples.ariestrader.util.ServiceUtilities;
+import org.apache.aries.samples.ariestrader.util.TradeConfig;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.Timestamp;
+
+
+/**
+ * TradeJdbc uses direct JDBC access to a
+ * <code>javax.sql.DataSource</code> to implement the business methods of the
+ * Trade online broker application. These business methods represent the
+ * features and operations that can be performed by customers of the brokerage
+ * such as login, logout, get a stock quote, buy or sell a stock, etc. and are
+ * specified in the {@link org.apache.aries.samples.ariestrader.TradeServices}
+ * interface
+ * 
+ * Note: In order for this class to be thread-safe, a new TradeJDBC must be
+ * created for each call to a method from the TradeInterface interface.
+ * Otherwise, pooled connections may not be released.
+ * 
+ * @see org.apache.aries.samples.ariestrader.TradeServices
+ * 
+ */
+
+public class TradeJdbc implements TradeServices {
+
+    private DataSource dataSource= null;
+
+    private static BigDecimal ZERO = new BigDecimal(0.0);
+
+    private boolean inGlobalTxn = false;
+
+    private boolean inSession = false;
+
+    private static int connCount = 0;
+
+    private static Integer lock = new Integer(0);
+
+    private static boolean initialized = false;
+
+    /**
+     * Zero arg constructor for TradeJdbc
+     */
+    public TradeJdbc() {
+    }
+
+    public TradeJdbc(boolean inSession) {
+        this.inSession = inSession;
+    }
+
+    /**
+     * set data source
+     */
+    public void setDataSource(DataSource dataSource) {
+            this.dataSource = dataSource;
+    }
+
+    /**
+     * setInSession
+     */
+    public void setInSession(boolean inSession) {
+        this.inSession = inSession;
+    }
+
+    /**
+     * @see TradeServices#getMarketSummary()
+     */
+    public MarketSummaryDataBean getMarketSummary() throws Exception {
+        MarketSummaryDataBean marketSummaryData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getMarketSummary - inSession(" + this.inSession + ")");
+
+            conn = getConn();
+            PreparedStatement stmt =
+                getStatement(conn, getTSIAQuotesOrderByChangeSQL, ResultSet.TYPE_SCROLL_INSENSITIVE,
+                    ResultSet.CONCUR_READ_ONLY);
+
+            ArrayList topGainersData = new ArrayList(5);
+            ArrayList topLosersData = new ArrayList(5);
+
+            ResultSet rs = stmt.executeQuery();
+
+            int count = 0;
+            while (rs.next() && (count++ < 5)) {
+                QuoteDataBean quoteData = getQuoteDataFromResultSet(rs);
+                topLosersData.add(quoteData);
+            }
+
+            stmt.close();
+            stmt =
+                getStatement(conn, "select * from quoteejb q where q.symbol like 's:1__' order by q.change1 DESC",
+                    ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+            rs = stmt.executeQuery();
+
+            count = 0;
+            while (rs.next() && (count++ < 5)) {
+                QuoteDataBean quoteData = getQuoteDataFromResultSet(rs);
+                topGainersData.add(quoteData);
+            }
+
+            stmt.close();
+
+            BigDecimal TSIA = ZERO;
+            BigDecimal openTSIA = ZERO;
+            double volume = 0.0;
+
+            if ((topGainersData.size() > 0) || (topLosersData.size() > 0)) {
+
+                stmt = getStatement(conn, getTSIASQL);
+                rs = stmt.executeQuery();
+
+                if (!rs.next())
+                    Log.error("TradeJdbc:getMarketSummary -- error w/ getTSIASQL -- no results");
+                else
+                    TSIA = rs.getBigDecimal("TSIA");
+                stmt.close();
+
+                stmt = getStatement(conn, getOpenTSIASQL);
+                rs = stmt.executeQuery();
+
+                if (!rs.next())
+                    Log.error("TradeJdbc:getMarketSummary -- error w/ getOpenTSIASQL -- no results");
+                else
+                    openTSIA = rs.getBigDecimal("openTSIA");
+                stmt.close();
+
+                stmt = getStatement(conn, getTSIATotalVolumeSQL);
+                rs = stmt.executeQuery();
+
+                if (!rs.next())
+                    Log.error("TradeJdbc:getMarketSummary -- error w/ getTSIATotalVolumeSQL -- no results");
+                else
+                    volume = rs.getDouble("totalVolume");
+                stmt.close();
+            }
+            commit(conn);
+
+            marketSummaryData = new MarketSummaryDataBean(TSIA, openTSIA, volume, topGainersData, topLosersData);
+
+        }
+
+        catch (Exception e) {
+            Log.error("TradeJdbc:getMarketSummary -- error getting summary", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return marketSummaryData;
+
+    }
+
+    /**
+     * @see TradeServices#buy(String, String, double)
+     */
+    public OrderDataBean buy(String userID, String symbol, double quantity, int orderProcessingMode) throws Exception {
+
+        Connection conn = null;
+        OrderDataBean orderData = null;
+
+        /*
+         * total = (quantity * purchasePrice) + orderFee
+         */
+        BigDecimal total;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:buy - inSession(" + this.inSession + ")", userID, symbol, new Double(quantity));
+
+            conn = getConn();
+
+            AccountDataBean accountData = getAccountData(conn, userID);
+            QuoteDataBean quoteData = getQuoteData(conn, symbol);
+            HoldingDataBean holdingData = null; // the buy operation will create
+            // the holding
+
+            orderData = createOrder(conn, accountData, quoteData, holdingData, "buy", quantity);
+
+            // Update -- account should be credited during completeOrder
+            BigDecimal price = quoteData.getPrice();
+            BigDecimal orderFee = orderData.getOrderFee();
+            total = (new BigDecimal(quantity).multiply(price)).add(orderFee);
+            // subtract total from account balance
+            creditAccountBalance(conn, accountData, total.negate());
+
+            completeOrder(conn, orderData.getOrderID());
+
+            orderData = getOrderData(conn, orderData.getOrderID().intValue());
+
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:buy error - rolling back", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+
+        //after the purchase or sale of a stock, update the stocks volume and
+        // price
+        updateQuotePriceVolume(symbol, TradeConfig.getRandomPriceChangeFactor(), quantity);
+
+        return orderData;
+    }
+
+    /**
+     * @see TradeServices#sell(String, Integer)
+     */
+    public OrderDataBean sell(String userID, Integer holdingID, int orderProcessingMode) throws Exception {
+
+        Connection conn = null;
+        OrderDataBean orderData = null;
+
+        /*
+         * total = (quantity * purchasePrice) + orderFee
+         */
+        BigDecimal total;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:sell - inSession(" + this.inSession + ")", userID, holdingID);
+
+            conn = getConn();
+
+            AccountDataBean accountData = getAccountData(conn, userID);
+            HoldingDataBean holdingData = getHoldingData(conn, holdingID.intValue());
+            QuoteDataBean quoteData = null;
+            if (holdingData != null)
+                quoteData = getQuoteData(conn, holdingData.getQuoteID());
+
+            if ((accountData == null) || (holdingData == null) || (quoteData == null)) {
+                String error =
+                    "TradeJdbc:sell -- error selling stock -- unable to find:  \n\taccount=" + accountData
+                        + "\n\tholding=" + holdingData + "\n\tquote=" + quoteData + "\nfor user: " + userID
+                        + " and holdingID: " + holdingID;
+                Log.error(error);
+                rollBack(conn, new Exception(error));
+
+                return orderData;
+            }
+
+            double quantity = holdingData.getQuantity();
+
+            orderData = createOrder(conn, accountData, quoteData, holdingData, "sell", quantity);
+
+            // Set the holdingSymbol purchaseDate to selling to signify the sell
+            // is "inflight"
+            updateHoldingStatus(conn, holdingData.getHoldingID(), holdingData.getQuoteID());
+
+            // UPDATE -- account should be credited during completeOrder
+            BigDecimal price = quoteData.getPrice();
+            BigDecimal orderFee = orderData.getOrderFee();
+            total = (new BigDecimal(quantity).multiply(price)).subtract(orderFee);
+            creditAccountBalance(conn, accountData, total);
+
+            completeOrder(conn, orderData.getOrderID());
+
+            orderData = getOrderData(conn, orderData.getOrderID().intValue());
+
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:sell error", e);
+            rollBack(conn, e);
+
+        } finally {
+            releaseConn(conn);
+        }
+
+        if (!(orderData.getOrderStatus().equalsIgnoreCase("cancelled")))
+            //after the purchase or sell of a stock, update the stocks volume
+            // and price
+            updateQuotePriceVolume(orderData.getSymbol(), TradeConfig.getRandomPriceChangeFactor(), orderData.getQuantity());
+
+        return orderData;
+    }
+
+    /**
+     * @see TradeServices#queueOrder(Integer)
+     */
+    public void queueOrder(Integer orderID, boolean twoPhase) throws Exception {
+        throw new RuntimeException("TradeServices#queueOrder(Integer) is not supported in this runtime mode");
+    }
+
+    /**
+     * @see TradeServices#completeOrder(Integer)
+     */
+    public OrderDataBean completeOrder(Integer orderID, boolean twoPhase) throws Exception {
+        OrderDataBean orderData = null;
+        Connection conn = null;
+
+        try { // twoPhase
+
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:completeOrder - inSession(" + this.inSession + ")", orderID);
+            setInGlobalTxn(!inSession && twoPhase);
+            conn = getConn();
+            orderData = completeOrder(conn, orderID);
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:completeOrder -- error completing order", e);
+            rollBack(conn, e);
+            cancelOrder(orderID, twoPhase);
+        } finally {
+            releaseConn(conn);
+        }
+
+        return orderData;
+
+    }
+
+    private OrderDataBean completeOrder(Connection conn, Integer orderID) throws Exception {
+
+        OrderDataBean orderData = null;
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:completeOrderInternal - inSession(" + this.inSession + ")", orderID);
+
+        PreparedStatement stmt = getStatement(conn, getOrderSQL);
+        stmt.setInt(1, orderID.intValue());
+
+        ResultSet rs = stmt.executeQuery();
+
+        if (!rs.next()) {
+            Log.error("TradeJdbc:completeOrder -- unable to find order: " + orderID);
+            stmt.close();
+            return orderData;
+        }
+        orderData = getOrderDataFromResultSet(rs);
+
+        String orderType = orderData.getOrderType();
+        String orderStatus = orderData.getOrderStatus();
+
+        // if (order.isCompleted())
+        if ((orderStatus.compareToIgnoreCase("completed") == 0)
+            || (orderStatus.compareToIgnoreCase("alertcompleted") == 0)
+            || (orderStatus.compareToIgnoreCase("cancelled") == 0))
+            throw new Exception("TradeJdbc:completeOrder -- attempt to complete Order that is already completed");
+
+        int accountID = rs.getInt("account_accountID");
+        String quoteID = rs.getString("quote_symbol");
+        int holdingID = rs.getInt("holding_holdingID");
+
+        BigDecimal price = orderData.getPrice();
+        double quantity = orderData.getQuantity();
+        BigDecimal orderFee = orderData.getOrderFee();
+
+        // get the data for the account and quote
+        // the holding will be created for a buy or extracted for a sell
+
+        /*
+         * Use the AccountID and Quote Symbol from the Order AccountDataBean accountData = getAccountData(accountID,
+         * conn); QuoteDataBean quoteData = getQuoteData(conn, quoteID);
+         */
+        String userID = getAccountProfileData(conn, new Integer(accountID)).getUserID();
+
+        HoldingDataBean holdingData = null;
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:completeOrder--> Completing Order " + orderData.getOrderID() + "\n\t Order info: "
+                + orderData + "\n\t Account info: " + accountID + "\n\t Quote info: " + quoteID);
+
+        // if (order.isBuy())
+        if (orderType.compareToIgnoreCase("buy") == 0) {
+            /*
+             * Complete a Buy operation - create a new Holding for the Account - deduct the Order cost from the Account
+             * balance
+             */
+
+            holdingData = createHolding(conn, accountID, quoteID, quantity, price);
+            updateOrderHolding(conn, orderID.intValue(), holdingData.getHoldingID().intValue());
+        }
+
+        // if (order.isSell()) {
+        if (orderType.compareToIgnoreCase("sell") == 0) {
+            /*
+             * Complete a Sell operation - remove the Holding from the Account - deposit the Order proceeds to the
+             * Account balance
+             */
+            holdingData = getHoldingData(conn, holdingID);
+            if (holdingData == null)
+                Log.debug("TradeJdbc:completeOrder:sell -- user: " + userID + " already sold holding: " + holdingID);
+            else
+                removeHolding(conn, holdingID, orderID.intValue());
+
+        }
+
+        updateOrderStatus(conn, orderData.getOrderID(), "closed");
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:completeOrder--> Completed Order " + orderData.getOrderID() + "\n\t Order info: "
+                + orderData + "\n\t Account info: " + accountID + "\n\t Quote info: " + quoteID + "\n\t Holding info: "
+                + holdingData);
+
+        stmt.close();
+
+        commit(conn);
+
+        // signify this order for user userID is complete
+        orderCompleted(userID, orderID);
+
+        return orderData;
+    }
+
+    /**
+     * @see TradeServices#cancelOrder(Integer, boolean)
+     */
+    public void cancelOrder(Integer orderID, boolean twoPhase) throws Exception {
+        Connection conn = null;
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:cancelOrder - inSession(" + this.inSession + ")", orderID);
+            setInGlobalTxn(!inSession && twoPhase);
+            conn = getConn();
+            cancelOrder(conn, orderID);
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:cancelOrder -- error cancelling order: " + orderID, e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+    }
+
+    private void cancelOrder(Connection conn, Integer orderID) throws Exception {
+        updateOrderStatus(conn, orderID, "cancelled");
+    }
+
+    public void orderCompleted(String userID, Integer orderID) throws Exception {
+//        throw new UnsupportedOperationException("TradeJdbc:orderCompleted method not supported");
+        if (Log.doTrace())
+            Log.trace("OrderCompleted", userID, orderID);
+    }
+
+    private HoldingDataBean createHolding(Connection conn, int accountID, String symbol, double quantity,
+        BigDecimal purchasePrice) throws Exception {
+
+        Timestamp purchaseDate = new Timestamp(System.currentTimeMillis());
+        PreparedStatement stmt = getStatement(conn, createHoldingSQL);
+
+        Integer holdingID = KeySequenceDirect.getNextID(conn, "holding", inSession, getInGlobalTxn());
+        stmt.setInt(1, holdingID.intValue());
+        stmt.setTimestamp(2, purchaseDate);
+        stmt.setBigDecimal(3, purchasePrice);
+        stmt.setDouble(4, quantity);
+        stmt.setString(5, symbol);
+        stmt.setInt(6, accountID);
+        stmt.executeUpdate();
+
+        stmt.close();
+
+        return getHoldingData(conn, holdingID.intValue());
+    }
+
+    private void removeHolding(Connection conn, int holdingID, int orderID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, removeHoldingSQL);
+
+        stmt.setInt(1, holdingID);
+        stmt.executeUpdate();
+        stmt.close();
+
+        // set the HoldingID to NULL for the purchase and sell order now that
+        // the holding as been removed
+        stmt = getStatement(conn, removeHoldingFromOrderSQL);
+
+        stmt.setInt(1, holdingID);
+        stmt.executeUpdate();
+        stmt.close();
+
+    }
+
+    private OrderDataBean createOrder(Connection conn, AccountDataBean accountData, QuoteDataBean quoteData,
+        HoldingDataBean holdingData, String orderType, double quantity) throws Exception {
+        Timestamp currentDate = new Timestamp(System.currentTimeMillis());
+
+        PreparedStatement stmt = getStatement(conn, createOrderSQL);
+
+        Integer orderID = KeySequenceDirect.getNextID(conn, "order", inSession, getInGlobalTxn());
+        stmt.setInt(1, orderID.intValue());
+        stmt.setString(2, orderType);
+        stmt.setString(3, "open");
+        stmt.setTimestamp(4, currentDate);
+        stmt.setDouble(5, quantity);
+        stmt.setBigDecimal(6, quoteData.getPrice().setScale(FinancialUtils.SCALE, FinancialUtils.ROUND));
+        stmt.setBigDecimal(7, TradeConfig.getOrderFee(orderType));
+        stmt.setInt(8, accountData.getAccountID().intValue());
+        if (holdingData == null)
+            stmt.setNull(9, java.sql.Types.INTEGER);
+        else
+            stmt.setInt(9, holdingData.getHoldingID().intValue());
+        stmt.setString(10, quoteData.getSymbol());
+        stmt.executeUpdate();
+
+        stmt.close();
+
+        return getOrderData(conn, orderID.intValue());
+    }
+
+    /**
+     * @see TradeServices#getOrders(String)
+     */
+    public Collection getOrders(String userID) throws Exception {
+
+        Collection orderDataBeans = new ArrayList();
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getOrders - inSession(" + this.inSession + ")", userID);
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, getOrdersByUserSQL);
+            stmt.setString(1, userID);
+
+            ResultSet rs = stmt.executeQuery();
+
+            // TODO: return top 5 orders for now -- next version will add a
+            // getAllOrders method
+            // also need to get orders sorted by order id descending
+            int i = 0;
+            while ((rs.next()) && (i++ < 5)) {
+                OrderDataBean orderData = getOrderDataFromResultSet(rs);
+                orderDataBeans.add(orderData);
+            }
+
+            stmt.close();
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getOrders -- error getting user orders", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return orderDataBeans;
+    }
+
+    /**
+     * @see TradeServices#getClosedOrders(String)
+     */
+    public Collection getClosedOrders(String userID) throws Exception {
+
+        Collection orderDataBeans = new ArrayList();
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getClosedOrders - inSession(" + this.inSession + ")", userID);
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, getClosedOrdersSQL);
+            stmt.setString(1, userID);
+
+            ResultSet rs = stmt.executeQuery();
+
+            while (rs.next()) {
+                OrderDataBean orderData = getOrderDataFromResultSet(rs);
+                orderData.setOrderStatus("completed");
+                updateOrderStatus(conn, orderData.getOrderID(), orderData.getOrderStatus());
+                orderDataBeans.add(orderData);
+
+            }
+
+            stmt.close();
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getOrders -- error getting user orders", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return orderDataBeans;
+    }
+
+    /**
+     * @see TradeServices#createQuote(String, String, BigDecimal)
+     */
+    public QuoteDataBean createQuote(String symbol, String companyName, BigDecimal price) throws Exception {
+
+        QuoteDataBean quoteData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.traceEnter("TradeJdbc:createQuote - inSession(" + this.inSession + ")");
+
+            price = price.setScale(FinancialUtils.SCALE, FinancialUtils.ROUND);
+            double volume = 0.0, change = 0.0;
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, createQuoteSQL);
+            stmt.setString(1, symbol); // symbol
+            stmt.setString(2, companyName); // companyName
+            stmt.setDouble(3, volume); // volume
+            stmt.setBigDecimal(4, price); // price
+            stmt.setBigDecimal(5, price); // open
+            stmt.setBigDecimal(6, price); // low
+            stmt.setBigDecimal(7, price); // high
+            stmt.setDouble(8, change); // change
+
+            stmt.executeUpdate();
+            stmt.close();
+            commit(conn);
+
+            quoteData = new QuoteDataBeanImpl(symbol, companyName, volume, price, price, price, price, change);
+            if (Log.doTrace())
+                Log.traceExit("TradeJdbc:createQuote");
+        } catch (Exception e) {
+            Log.error("TradeJdbc:createQuote -- error creating quote", e);
+        } finally {
+            releaseConn(conn);
+        }
+        return quoteData;
+    }
+
+    /**
+     * @see TradeServices#getQuote(String)
+     */
+
+    public QuoteDataBean getQuote(String symbol) throws Exception {
+
+        QuoteDataBean quoteData = null;
+        Connection conn = null;
+
+        if ((symbol == null) || (symbol.length() == 0) || (symbol.length() > 10)) {
+            if (Log.doTrace()) {
+                Log.trace("TradeJdbc:getQuote   ---  primitive workload");
+            }
+            return new QuoteDataBeanImpl("Invalid symbol", "", 0.0, FinancialUtils.ZERO, FinancialUtils.ZERO, FinancialUtils.ZERO, FinancialUtils.ZERO, 0.0);
+        }
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getQuote - inSession(" + this.inSession + ")", symbol);
+
+            conn = getConn();
+            quoteData = getQuote(conn, symbol);
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getQuote -- error getting quote", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return quoteData;
+    }
+
+    private QuoteDataBean getQuote(Connection conn, String symbol) throws Exception {
+        QuoteDataBean quoteData = null;
+        PreparedStatement stmt = getStatement(conn, getQuoteSQL);
+        stmt.setString(1, symbol); // symbol
+
+        ResultSet rs = stmt.executeQuery();
+
+        if (!rs.next())
+            Log.error("TradeJdbc:getQuote -- failure no result.next() for symbol: " + symbol);
+
+        else
+            quoteData = getQuoteDataFromResultSet(rs);
+
+        stmt.close();
+
+        return quoteData;
+    }
+
+    private QuoteDataBean getQuoteForUpdate(Connection conn, String symbol) throws Exception {
+        QuoteDataBean quoteData = null;
+        PreparedStatement stmt = getStatement(conn, getQuoteForUpdateSQL);
+        stmt.setString(1, symbol); // symbol
+
+        ResultSet rs = stmt.executeQuery();
+
+        if (!rs.next())
+            Log.error("TradeJdbc:getQuote -- failure no result.next()");
+
+        else
+            quoteData = getQuoteDataFromResultSet(rs);
+
+        stmt.close();
+
+        return quoteData;
+    }
+
+    /**
+     * @see TradeServices#getAllQuotes(String)
+     */
+    public Collection getAllQuotes() throws Exception {
+
+        Collection quotes = new ArrayList();
+        QuoteDataBean quoteData = null;
+        Connection conn = null;
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:getAllQuotes");
+
+        try {
+            conn = getConn();
+
+            PreparedStatement stmt = getStatement(conn, getAllQuotesSQL);
+
+            ResultSet rs = stmt.executeQuery();
+
+            while (!rs.next()) {
+                quoteData = getQuoteDataFromResultSet(rs);
+                quotes.add(quoteData);
+            }
+
+            stmt.close();
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getAllQuotes", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+
+        return quotes;
+    }
+
+    /**
+     * @see TradeServices#getHoldings(String)
+     */
+    public Collection getHoldings(String userID) throws Exception {
+
+        Collection holdingDataBeans = new ArrayList();
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getHoldings - inSession(" + this.inSession + ")", userID);
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, getHoldingsForUserSQL);
+            stmt.setString(1, userID);
+
+            ResultSet rs = stmt.executeQuery();
+
+            while (rs.next()) {
+                HoldingDataBean holdingData = getHoldingDataFromResultSet(rs);
+                holdingDataBeans.add(holdingData);
+            }
+
+            stmt.close();
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getHoldings -- error getting user holings", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return holdingDataBeans;
+    }
+
+    /**
+     * @see TradeServices#getHolding(Integer)
+     */
+    public HoldingDataBean getHolding(Integer holdingID) throws Exception {
+
+        HoldingDataBean holdingData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getHolding - inSession(" + this.inSession + ")", holdingID);
+
+            conn = getConn();
+            holdingData = getHoldingData(holdingID.intValue());
+
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getHolding -- error getting holding " + holdingID + "", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return holdingData;
+    }
+
+    /**
+     * @see TradeServices#getAccountData(String)
+     */
+    public AccountDataBean getAccountData(String userID) throws Exception {
+
+        try {
+            AccountDataBean accountData = null;
+            Connection conn = null;
+            try {
+                if (Log.doTrace())
+                    Log.trace("TradeJdbc:getAccountData - inSession(" + this.inSession + ")", userID);
+
+                conn = getConn();
+                accountData = getAccountData(conn, userID);
+                commit(conn);
+
+            } catch (Exception e) {
+                Log.error("TradeJdbc:getAccountData -- error getting account data", e);
+                rollBack(conn, e);
+            } finally {
+                releaseConn(conn);
+            }
+            return accountData;
+        } catch (Exception e) {
+            throw new Exception(e.getMessage(), e);
+        }
+    }
+
+    private AccountDataBean getAccountData(Connection conn, String userID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, getAccountForUserSQL);
+        stmt.setString(1, userID);
+        ResultSet rs = stmt.executeQuery();
+        AccountDataBean accountData = getAccountDataFromResultSet(rs);
+        stmt.close();
+        return accountData;
+    }
+
+    private AccountDataBean getAccountDataForUpdate(Connection conn, String userID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, getAccountForUserForUpdateSQL);
+        stmt.setString(1, userID);
+        ResultSet rs = stmt.executeQuery();
+        AccountDataBean accountData = getAccountDataFromResultSet(rs);
+        stmt.close();
+        return accountData;
+    }
+
+    /**
+     * @see TradeServices#getAccountData(String)
+     */
+    public AccountDataBean getAccountData(int accountID) throws Exception {
+        AccountDataBean accountData = null;
+        Connection conn = null;
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getAccountData - inSession(" + this.inSession + ")", new Integer(accountID));
+
+            conn = getConn();
+            accountData = getAccountData(accountID, conn);
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getAccountData -- error getting account data", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return accountData;
+    }
+
+    private AccountDataBean getAccountData(int accountID, Connection conn) throws Exception {
+        PreparedStatement stmt = getStatement(conn, getAccountSQL);
+        stmt.setInt(1, accountID);
+        ResultSet rs = stmt.executeQuery();
+        AccountDataBean accountData = getAccountDataFromResultSet(rs);
+        stmt.close();
+        return accountData;
+    }
+
+    private QuoteDataBean getQuoteData(Connection conn, String symbol) throws Exception {
+        QuoteDataBean quoteData = null;
+        PreparedStatement stmt = getStatement(conn, getQuoteSQL);
+        stmt.setString(1, symbol);
+        ResultSet rs = stmt.executeQuery();
+        if (!rs.next())
+            Log.error("TradeJdbc:getQuoteData -- could not find quote for symbol=" + symbol);
+        else
+            quoteData = getQuoteDataFromResultSet(rs);
+        stmt.close();
+        return quoteData;
+    }
+
+    private HoldingDataBean getHoldingData(int holdingID) throws Exception {
+        HoldingDataBean holdingData = null;
+        Connection conn = null;
+        try {
+            conn = getConn();
+            holdingData = getHoldingData(conn, holdingID);
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getHoldingData -- error getting data", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return holdingData;
+    }
+
+    private HoldingDataBean getHoldingData(Connection conn, int holdingID) throws Exception {
+        HoldingDataBean holdingData = null;
+        PreparedStatement stmt = getStatement(conn, getHoldingSQL);
+        stmt.setInt(1, holdingID);
+        ResultSet rs = stmt.executeQuery();
+        if (!rs.next())
+            Log.error("TradeJdbc:getHoldingData -- no results -- holdingID=" + holdingID);
+        else
+            holdingData = getHoldingDataFromResultSet(rs);
+
+        stmt.close();
+        return holdingData;
+    }
+
+    private OrderDataBean getOrderData(Connection conn, int orderID) throws Exception {
+        OrderDataBean orderData = null;
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:getOrderData(conn, " + orderID + ")");
+        PreparedStatement stmt = getStatement(conn, getOrderSQL);
+        stmt.setInt(1, orderID);
+        ResultSet rs = stmt.executeQuery();
+        if (!rs.next())
+            Log.error("TradeJdbc:getOrderData -- no results for orderID:" + orderID);
+        else
+            orderData = getOrderDataFromResultSet(rs);
+        stmt.close();
+        return orderData;
+    }
+
+    /**
+     * @see TradeServices#getAccountProfileData(String)
+     */
+    public AccountProfileDataBean getAccountProfileData(String userID) throws Exception {
+
+        AccountProfileDataBean accountProfileData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:getAccountProfileData - inSession(" + this.inSession + ")", userID);
+
+            conn = getConn();
+            accountProfileData = getAccountProfileData(conn, userID);
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getAccountProfileData -- error getting profile data", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return accountProfileData;
+    }
+
+    private AccountProfileDataBean getAccountProfileData(Connection conn, String userID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, getAccountProfileSQL);
+        stmt.setString(1, userID);
+
+        ResultSet rs = stmt.executeQuery();
+
+        AccountProfileDataBean accountProfileData = getAccountProfileDataFromResultSet(rs);
+        stmt.close();
+        return accountProfileData;
+    }
+
+    private AccountProfileDataBean getAccountProfileData(Connection conn, Integer accountID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, getAccountProfileForAccountSQL);
+        stmt.setInt(1, accountID.intValue());
+
+        ResultSet rs = stmt.executeQuery();
+
+        AccountProfileDataBean accountProfileData = getAccountProfileDataFromResultSet(rs);
+        stmt.close();
+        return accountProfileData;
+    }
+
+    /**
+     * @see TradeServices#updateAccountProfile(AccountProfileDataBean)
+     */
+    public AccountProfileDataBean updateAccountProfile(String userID, String password, String fullName, String address, String email, String creditcard) throws Exception {                              
+
+        AccountProfileDataBean accountProfileData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:updateAccountProfileData - inSession(" + this.inSession + ")", userID);
+
+            conn = getConn();
+            updateAccountProfile(conn, userID, password, fullName, address, email, creditcard);
+
+            accountProfileData = getAccountProfileData(conn, userID);
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:getAccountProfileData -- error getting profile data", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return accountProfileData;
+    }
+
+    private void creditAccountBalance(Connection conn, AccountDataBean accountData, BigDecimal credit) throws Exception {
+        PreparedStatement stmt = getStatement(conn, creditAccountBalanceSQL);
+
+        stmt.setBigDecimal(1, credit);
+        stmt.setInt(2, accountData.getAccountID().intValue());
+
+        stmt.executeUpdate();
+        stmt.close();
+
+    }
+
+    // Set Timestamp to zero to denote sell is inflight
+    // UPDATE -- could add a "status" attribute to holding
+    private void updateHoldingStatus(Connection conn, Integer holdingID, String symbol) throws Exception {
+        Timestamp ts = new Timestamp(0);
+        PreparedStatement stmt = getStatement(conn, "update holdingejb set purchasedate= ? where holdingid = ?");
+
+        stmt.setTimestamp(1, ts);
+        stmt.setInt(2, holdingID.intValue());
+        stmt.executeUpdate();
+        stmt.close();
+    }
+
+    private void updateOrderStatus(Connection conn, Integer orderID, String status) throws Exception {
+        PreparedStatement stmt = getStatement(conn, updateOrderStatusSQL);
+
+        stmt.setString(1, status);
+        stmt.setTimestamp(2, new Timestamp(System.currentTimeMillis()));
+        stmt.setInt(3, orderID.intValue());
+        stmt.executeUpdate();
+        stmt.close();
+    }
+
+    private void updateOrderHolding(Connection conn, int orderID, int holdingID) throws Exception {
+        PreparedStatement stmt = getStatement(conn, updateOrderHoldingSQL);
+
+        stmt.setInt(1, holdingID);
+        stmt.setInt(2, orderID);
+        stmt.executeUpdate();
+        stmt.close();
+    }
+
+    private void updateAccountProfile(Connection conn, String userID, String password, String fullName, String address, String email, String creditcard) throws Exception {
+        PreparedStatement stmt = getStatement(conn, updateAccountProfileSQL);
+
+        stmt.setString(1, password);
+        stmt.setString(2, fullName);
+        stmt.setString(3, address);
+        stmt.setString(4, email);
+        stmt.setString(5, creditcard);
+        stmt.setString(6, userID);
+
+        stmt.executeUpdate();
+        stmt.close();
+    }
+
+    public QuoteDataBean updateQuotePriceVolume(String symbol, BigDecimal changeFactor, double sharesTraded)
+        throws Exception {
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:updateQuotePriceVolume", symbol, changeFactor, new Double(sharesTraded));
+
+        return updateQuotePriceVolumeInt(symbol, changeFactor, sharesTraded, TradeConfig.getPublishQuotePriceChange());
+    }
+
+    /**
+     * Update a quote's price and volume
+     * 
+     * @param symbol
+     *            The PK of the quote
+     * @param changeFactor
+     *            the percent to change the old price by (between 50% and 150%)
+     * @param sharedTraded
+     *            the ammount to add to the current volume
+     * @param publishQuotePriceChange
+     *            used by the PingJDBCWrite Primitive to ensure no JMS is used, should be true for all normal calls to
+     *            this API
+     */
+    public QuoteDataBean updateQuotePriceVolumeInt(String symbol, BigDecimal changeFactor, double sharesTraded,
+        boolean publishQuotePriceChange) throws Exception {
+
+        if (TradeConfig.getUpdateQuotePrices() == false)
+            return new QuoteDataBeanImpl();
+
+        QuoteDataBean quoteData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:updateQuotePriceVolume - inSession(" + this.inSession + ")", symbol,
+                    changeFactor, new Double(sharesTraded));
+
+            conn = getConn();
+
+            quoteData = getQuoteForUpdate(conn, symbol);
+            BigDecimal oldPrice = quoteData.getPrice();
+            double newVolume = quoteData.getVolume() + sharesTraded;
+
+            if (oldPrice.equals(TradeConfig.PENNY_STOCK_PRICE)) {
+                changeFactor = TradeConfig.PENNY_STOCK_RECOVERY_MIRACLE_MULTIPLIER;
+            } else if (oldPrice.compareTo(TradeConfig.MAXIMUM_STOCK_PRICE) > 0) {
+                changeFactor = TradeConfig.MAXIMUM_STOCK_SPLIT_MULTIPLIER;
+            }
+
+            BigDecimal newPrice = changeFactor.multiply(oldPrice).setScale(2, BigDecimal.ROUND_HALF_UP);
+            BigDecimal low = quoteData.getLow();
+            BigDecimal high= quoteData.getHigh();
+            if (newPrice.compareTo(high) == 1) high = newPrice;
+            else if (newPrice.compareTo(low) == -1) low = newPrice;
+
+            updateQuotePriceVolume(conn, quoteData.getSymbol(), newPrice, newVolume, low, high);
+            quoteData = getQuote(conn, symbol);
+
+            commit(conn);
+
+        } catch (Exception e) {
+            Log.error("TradeJdbc:updateQuotePriceVolume -- error updating quote price/volume for symbol:" + symbol);
+            rollBack(conn, e);
+            throw e;
+        } finally {
+            releaseConn(conn);
+        }
+        return quoteData;
+    }
+
+    private void updateQuotePriceVolume(Connection conn, String symbol, BigDecimal newPrice, double newVolume, BigDecimal low, BigDecimal high)
+        throws Exception {
+
+        PreparedStatement stmt = getStatement(conn, updateQuotePriceVolumeSQL);
+
+        stmt.setBigDecimal(1, newPrice);
+        stmt.setBigDecimal(2, newPrice);
+        stmt.setDouble(3, newVolume);
+        stmt.setBigDecimal(4, low);
+        stmt.setBigDecimal(5, high);
+        stmt.setString(6, symbol);
+
+        stmt.executeUpdate();
+        stmt.close();
+    }
+
+    /**
+     * @see TradeServices#login(String, String)
+     */
+
+    public AccountDataBean login(String userID, String password) throws Exception {
+
+        AccountDataBean accountData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.trace("TradeJdbc:login - inSession(" + this.inSession + ")", userID, password);
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, getAccountProfileSQL);
+            stmt.setString(1, userID);
+
+            ResultSet rs = stmt.executeQuery();
+            if (!rs.next()) {
+                Log.error("TradeJdbc:login -- failure to find account for" + userID);
+                throw new RuntimeException("Cannot find account for" + userID);
+            }
+
+            String pw = rs.getString("passwd");
+            stmt.close();
+            if ((pw == null) || (pw.equals(password) == false)) {
+                String error =
+                    "TradeJdbc:Login failure for user: " + userID + "\n\tIncorrect password-->" + userID + ":"
+                        + password;
+                Log.error(error);
+                throw new Exception(error);
+            }
+
+            stmt = getStatement(conn, loginSQL);
+            stmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
+            stmt.setString(2, userID);
+
+            stmt.executeUpdate();
+            stmt.close();
+
+            stmt = getStatement(conn, getAccountForUserSQL);
+            stmt.setString(1, userID);
+            rs = stmt.executeQuery();
+
+            accountData = getAccountDataFromResultSet(rs);
+
+            stmt.close();
+
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:login -- error logging in user", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+        return accountData;
+
+        /*
+         * setLastLogin( new Timestamp(System.currentTimeMillis()) ); setLoginCount( getLoginCount() + 1 );
+         */
+    }
+
+    /**
+     * @see TradeServices#logout(String)
+     */
+    public void logout(String userID) throws Exception {
+
+        Connection conn = null;
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:logout - inSession(" + this.inSession + ")", userID);
+        try {
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, logoutSQL);
+            stmt.setString(1, userID);
+            stmt.executeUpdate();
+            stmt.close();
+
+            commit(conn);
+        } catch (Exception e) {
+            Log.error("TradeJdbc:logout -- error logging out user", e);
+            rollBack(conn, e);
+        } finally {
+            releaseConn(conn);
+        }
+    }
+
+    /**
+     * @see TradeServices#register(String, String, String, String, String, String, BigDecimal, boolean)
+     */
+
+    public AccountDataBean register(String userID, String password, String fullname, String address, String email,
+        String creditCard, BigDecimal openBalance) throws Exception {
+
+        AccountDataBean accountData = null;
+        Connection conn = null;
+
+        try {
+            if (Log.doTrace())
+                Log.traceEnter("TradeJdbc:register - inSession(" + this.inSession + ")");
+
+            conn = getConn();
+            PreparedStatement stmt = getStatement(conn, createAccountSQL);
+
+            Integer accountID = KeySequenceDirect.getNextID(conn, "account", inSession, getInGlobalTxn());
+            BigDecimal balance = openBalance;
+            Timestamp creationDate = new Timestamp(System.currentTimeMillis());
+            Timestamp lastLogin = creationDate;
+            int loginCount = 0;
+            int logoutCount = 0;
+
+            stmt.setInt(1, accountID.intValue());
+            stmt.setTimestamp(2, creationDate);
+            stmt.setBigDecimal(3, openBalance);
+            stmt.setBigDecimal(4, balance);
+            stmt.setTimestamp(5, lastLogin);
+            stmt.setInt(6, loginCount);
+            stmt.setInt(7, logoutCount);
+            stmt.setString(8, userID);
+            stmt.executeUpdate();
+            stmt.close();
+
+            stmt = getStatement(conn, createAccountProfileSQL);
+            stmt.setString(1, userID);
+            stmt.setString(2, password);
+            stmt.setString(3, fullname);
+            stmt.setString(4, address);
+            stmt.setString(5, email);
+            stmt.setString(6, creditCard);
+            stmt.executeUpdate();
+            stmt.close();
+
+            commit(conn);
+
+            accountData =
+                new AccountDataBeanImpl(accountID, loginCount, logoutCount, lastLogin, creationDate, balance, openBalance,
+                    userID);
+            if (Log.doTrace())
+                Log.traceExit("TradeJdbc:register");
+        } catch (Exception e) {
+            Log.error("TradeJdbc:register -- error registering new user", e);
+        } finally {
+            releaseConn(conn);
+        }
+        return accountData;
+    }
+
+    private AccountDataBean getAccountDataFromResultSet(ResultSet rs) throws Exception {
+        AccountDataBean accountData = null;
+
+        if (!rs.next())
+            Log.error("TradeJdbc:getAccountDataFromResultSet -- cannot find account data");
+
+        else
+            accountData =
+                new AccountDataBeanImpl(new Integer(rs.getInt("accountID")), rs.getInt("loginCount"), rs
+                    .getInt("logoutCount"), rs.getTimestamp("lastLogin"), rs.getTimestamp("creationDate"), rs
+                    .getBigDecimal("balance"), rs.getBigDecimal("openBalance"), rs.getString("profile_userID"));
+        return accountData;
+    }
+
+    private AccountProfileDataBean getAccountProfileDataFromResultSet(ResultSet rs) throws Exception {
+        AccountProfileDataBean accountProfileData = null;
+
+        if (!rs.next())
+            Log.error("TradeJdbc:getAccountProfileDataFromResultSet -- cannot find accountprofile data");
+        else
+            accountProfileData =
+                new AccountProfileDataBeanImpl(rs.getString("userID"), rs.getString("passwd"), rs.getString("fullName"), rs
+                    .getString("address"), rs.getString("email"), rs.getString("creditCard"));
+
+        return accountProfileData;
+    }
+
+    private HoldingDataBean getHoldingDataFromResultSet(ResultSet rs) throws Exception {
+        HoldingDataBean holdingData = null;
+
+        holdingData =
+            new HoldingDataBeanImpl(new Integer(rs.getInt("holdingID")), rs.getDouble("quantity"), rs
+                .getBigDecimal("purchasePrice"), rs.getTimestamp("purchaseDate"), rs.getString("quote_symbol"));
+        return holdingData;
+    }
+
+    private QuoteDataBean getQuoteDataFromResultSet(ResultSet rs) throws Exception {
+        QuoteDataBean quoteData = null;
+
+        quoteData =
+            new QuoteDataBeanImpl(rs.getString("symbol"), rs.getString("companyName"), rs.getDouble("volume"), rs
+                .getBigDecimal("price"), rs.getBigDecimal("open1"), rs.getBigDecimal("low"), rs.getBigDecimal("high"),
+                rs.getDouble("change1"));
+        return quoteData;
+    }
+
+    private OrderDataBean getOrderDataFromResultSet(ResultSet rs) throws Exception {
+        OrderDataBean orderData = null;
+
+        orderData =
+            new OrderDataBeanImpl(new Integer(rs.getInt("orderID")), rs.getString("orderType"),
+                rs.getString("orderStatus"), rs.getTimestamp("openDate"), rs.getTimestamp("completionDate"), rs
+                    .getDouble("quantity"), rs.getBigDecimal("price"), rs.getBigDecimal("orderFee"), rs
+                    .getString("quote_symbol"));
+        return orderData;
+    }
+
+
+    private void releaseConn(Connection conn) throws Exception {
+        try {
+            if (conn != null) {
+                conn.close();
+                if (Log.doTrace()) {
+                    synchronized (lock) {
+                        connCount--;
+                    }
+                    Log.trace("TradeJdbc:releaseConn -- connection closed, connCount=" + connCount);
+                }
+            }
+        } catch (Exception e) {
+            Log.error("TradeJdbc:releaseConnection -- failed to close connection", e);
+        }
+    }
+
+    /*
+     * Lookup the TradeData DataSource
+     */
+    private void lookupDataSource() throws Exception {
+        if (dataSource == null) {
+            dataSource = (DataSource) ServiceUtilities.getOSGIService(DataSource.class.getName(),TradeConfig.OSGI_DS_NAME_FILTER);
+        }
+    }
+
+    /*
+     * Allocate a new connection to the datasource
+     */
+    private Connection getConn() throws Exception {
+
+        Connection conn = null;
+        lookupDataSource();
+        conn = dataSource.getConnection();
+        conn.setAutoCommit(false);
+        if (Log.doTrace()) {
+            synchronized (lock) {
+                connCount++;
+            }
+            Log.trace("TradeJdbc:getConn -- new connection allocated, IsolationLevel="
+                + conn.getTransactionIsolation() + " connectionCount = " + connCount);
+        }
+
+        return conn;
+    }
+
+    /*
+     * Commit the provided connection if not under Global Transaction scope - conn.commit() is not allowed in a global
+     * transaction. the txn manager will perform the commit
+     */
+    private void commit(Connection conn) throws Exception {
+        if (!inSession) {
+            if ((getInGlobalTxn() == false) && (conn != null))
+                conn.commit();
+        }
+    }
+
+    /*
+     * Rollback the statement for the given connection
+     */
+    private void rollBack(Connection conn, Exception e) throws Exception {
+        if (!inSession) {
+            Log.log("TradeJdbc:rollBack -- rolling back conn due to previously caught exception -- inGlobalTxn="
+                + getInGlobalTxn());
+            if ((getInGlobalTxn() == false) && (conn != null))
+                conn.rollback();
+            else
+                throw e; // Throw the exception
+            // so the Global txn manager will rollBack
+        }
+    }
+
+    /*
+     * Allocate a new prepared statment for this connection
+     */
+    private PreparedStatement getStatement(Connection conn, String sql) throws Exception {
+        return conn.prepareStatement(sql);
+    }
+
+    private PreparedStatement getStatement(Connection conn, String sql, int type, int concurrency) throws Exception {
+        return conn.prepareStatement(sql, type, concurrency);
+    }
+
+    private static final String createQuoteSQL =
+        "insert into quoteejb " + "( symbol, companyName, volume, price, open1, low, high, change1 ) "
+            + "VALUES (  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  )";
+
+    private static final String createAccountSQL =
+        "insert into accountejb "
+            + "( accountid, creationDate, openBalance, balance, lastLogin, loginCount, logoutCount, profile_userid) "
+            + "VALUES (  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  )";
+
+    private static final String createAccountProfileSQL =
+        "insert into accountprofileejb " + "( userid, passwd, fullname, address, email, creditcard ) "
+            + "VALUES (  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  )";
+
+    private static final String createHoldingSQL =
+        "insert into holdingejb "
+            + "( holdingid, purchaseDate, purchasePrice, quantity, quote_symbol, account_accountid ) "
+            + "VALUES (  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ? )";
+
+    private static final String createOrderSQL =
+        "insert into orderejb "
+            + "( orderid, ordertype, orderstatus, opendate, quantity, price, orderfee, account_accountid,  holding_holdingid, quote_symbol) "
+            + "VALUES (  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  ,  ?  , ? , ? , ?)";
+
+    private static final String removeHoldingSQL = "delete from holdingejb where holdingid = ?";
+
+    private static final String removeHoldingFromOrderSQL =
+        "update orderejb set holding_holdingid=null where holding_holdingid = ?";
+
+    private final static String updateAccountProfileSQL =
+        "update accountprofileejb set " + "passwd = ?, fullname = ?, address = ?, email = ?, creditcard = ? "
+            + "where userid = (select profile_userid from accountejb a " + "where a.profile_userid=?)";
+
+    private final static String loginSQL =
+        "update accountejb set lastLogin=?, logincount=logincount+1 " + "where profile_userid=?";
+
+    private static final String logoutSQL =
+        "update accountejb set logoutcount=logoutcount+1 " + "where profile_userid=?";
+
+    private static final String getAccountSQL = "select * from accountejb a where a.accountid = ?";
+
+    private final static String getAccountProfileSQL =
+        "select * from accountprofileejb ap where ap.userid = "
+            + "(select profile_userid from accountejb a where a.profile_userid=?)";
+
+    private final static String getAccountProfileForAccountSQL =
+        "select * from accountprofileejb ap where ap.userid = "
+            + "(select profile_userid from accountejb a where a.accountid=?)";
+
+    private static final String getAccountForUserSQL =
+        "select * from accountejb a where a.profile_userid = "
+            + "( select userid from accountprofileejb ap where ap.userid = ?)";
+
+    private static final String getAccountForUserForUpdateSQL =
+        "select * from accountejb a where a.profile_userid = "
+            + "( select userid from accountprofileejb ap where ap.userid = ?) for update";
+
+    private static final String getHoldingSQL = "select * from holdingejb h where h.holdingid = ?";
+
+    private static final String getHoldingsForUserSQL =
+        "select * from holdingejb h where h.account_accountid = "
+            + "(select a.accountid from accountejb a where a.profile_userid = ?)";
+
+    private static final String getOrderSQL = "select * from orderejb o where o.orderid = ?";
+
+    private static final String getOrdersByUserSQL =
+        "select * from orderejb o where o.account_accountid = "
+            + "(select a.accountid from accountejb a where a.profile_userid = ?)";
+
+    private static final String getClosedOrdersSQL =
+        "select * from orderejb o " + "where o.orderstatus = 'closed' AND o.account_accountid = "
+            + "(select a.accountid from accountejb a where a.profile_userid = ?)";
+
+    private static final String getQuoteSQL = "select * from quoteejb q where q.symbol=?";
+
+    private static final String getAllQuotesSQL = "select * from quoteejb q";
+
+    private static final String getQuoteForUpdateSQL = "select * from quoteejb q where q.symbol=? For Update";
+
+    private static final String getTSIAQuotesOrderByChangeSQL =
+        "select * from quoteejb q " + "where q.symbol like 's:1__' order by q.change1";
+
+    private static final String getTSIASQL =
+        "select SUM(price)/count(*) as TSIA from quoteejb q " + "where q.symbol like 's:1__'";
+
+    private static final String getOpenTSIASQL =
+        "select SUM(open1)/count(*) as openTSIA from quoteejb q " + "where q.symbol like 's:1__'";
+
+    private static final String getTSIATotalVolumeSQL =
+        "select SUM(volume) as totalVolume from quoteejb q " + "where q.symbol like 's:1__'";
+
+    private static final String creditAccountBalanceSQL =
+        "update accountejb set " + "balance = balance + ? " + "where accountid = ?";
+
+    private static final String updateOrderStatusSQL =
+        "update orderejb set " + "orderstatus = ?, completiondate = ? " + "where orderid = ?";
+
+    private static final String updateOrderHoldingSQL =
+        "update orderejb set " + "holding_holdingID = ? " + "where orderid = ?";
+
+    private static final String updateQuotePriceVolumeSQL =
+        "update quoteejb set " + "price = ?, change1 = ? - open1, volume = ?, low = ?, high = ? " + "where symbol = ?";
+
+    public void init() {
+        if (initialized)
+            return;
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:init -- *** initializing");
+
+        if (Log.doTrace())
+            Log.trace("TradeJdbc:init -- +++ initialized");
+
+        initialized = true;
+    }
+
+    public void destroy() {
+        try {
+            if (!initialized)
+                return;
+            Log.trace("TradeJdbc:destroy");
+        } catch (Exception e) {
+            Log.error("TradeJdbc:destroy", e);
+        }
+    }
+
+    /**
+     * Gets the inGlobalTxn
+     * 
+     * @return Returns a boolean
+     */
+    private boolean getInGlobalTxn() {
+        return inGlobalTxn;
+    }
+
+    /**
+     * Sets the inGlobalTxn
+     * 
+     * @param inGlobalTxn
+     *            The inGlobalTxn to set
+     */
+    private void setInGlobalTxn(boolean inGlobalTxn) {
+        this.inGlobalTxn = inGlobalTxn;
+    }
+
+    /**
+     * Get mode - returns the persistence mode (TradeConfig.JDBC)
+     * 
+     * @return TradeConfig.ModeType
+     */
+    public TradeConfig.ModeType getMode() {
+        return TradeConfig.ModeType.JDBC;
+    }
+
+}

Added: aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/resources/OSGI-INF/blueprint/blueprint.xml
URL: http://svn.apache.org/viewvc/aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/resources/OSGI-INF/blueprint/blueprint.xml?rev=1075106&view=auto
==============================================================================
--- aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/resources/OSGI-INF/blueprint/blueprint.xml (added)
+++ aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jdbc/src/main/resources/OSGI-INF/blueprint/blueprint.xml Sun Feb 27 18:28:26 2011
@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    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.
+
+-->
+<blueprint  default-activation="lazy"  
+            xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+            xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0">
+
+  <bean id="tradeServicesBeanJDBC" class="org.apache.aries.samples.ariestrader.persist.jdbc.TradeJdbc" init-method="init">
+      <!--<property name="inSession" value="true"/>-->
+  </bean>
+
+  <service id="tradeServicesJDBC" ref="tradeServicesBeanJDBC" interface="org.apache.aries.samples.ariestrader.api.TradeServices">
+      <service-properties>
+          <entry key="mode" value="JDBC"/>
+      </service-properties>
+  </service>
+
+</blueprint>
+

Added: aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jpa-am/pom.xml
URL: http://svn.apache.org/viewvc/aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jpa-am/pom.xml?rev=1075106&view=auto
==============================================================================
--- aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jpa-am/pom.xml (added)
+++ aries/tags/samples-0.1-incubating/ariestrader/modules/ariestrader-persist-jpa-am/pom.xml Sun Feb 27 18:28:26 2011
@@ -0,0 +1,83 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+    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.
+-->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.apache.aries.samples.ariestrader</groupId>
+        <artifactId>modules</artifactId>
+        <version>0.1-incubating</version>
+    </parent>
+
+    <groupId>org.apache.aries.samples.ariestrader</groupId>
+    <artifactId>org.apache.aries.samples.ariestrader.persist.jpa.am</artifactId>
+    <packaging>bundle</packaging>
+    <name>AriesTrader :: Modules - Persist JPA App Managed</name>
+    <description>AriesTrader Persist JPA App Managed Module</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.aries.samples.ariestrader</groupId>
+            <artifactId>org.apache.aries.samples.ariestrader.util</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.aries.samples.ariestrader</groupId>
+            <artifactId>org.apache.aries.samples.ariestrader.api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.aries.samples.ariestrader</groupId>
+            <artifactId>org.apache.aries.samples.ariestrader.entities</artifactId>
+            <scope>provided</scope>
+        </dependency>
+<!--
+        <dependency>
+            <groupId>org.apache.geronimo.specs</groupId>
+            <artifactId>geronimo-jpa_1.0_spec</artifactId>
+            <scope>provided</scope>
+        </dependency>
+-->
+        <dependency>
+            <groupId>org.apache.geronimo.specs</groupId>
+            <artifactId>geronimo-jpa_2.0_spec</artifactId>
+            <scope>provided</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.felix</groupId>
+                <artifactId>maven-bundle-plugin</artifactId>
+                <configuration>
+                    <instructions>
+                        <Bundle-SymbolicName>${pom.artifactId}</Bundle-SymbolicName>
+                        <Bundle-Version>${pom.version}</Bundle-Version>
+                        <Private-Package>org.apache.aries.samples.ariestrader.persist.jpa.am.*</Private-Package>
+                        <Export-Package>!org.apache.aries.samples.ariestrader.persist.jpa.am.*</Export-Package>
+                        <Import-Package>
+                            javax.persistence;version="[1.0.0,2.1.0)",
+                            *
+                        </Import-Package>
+                    </instructions>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>



Mime
View raw message