/**
 * Returns a PO bean containing the data from the poHdr and poDtl tables of the po database.
 *
 * @param - record ID
 * @return - Person bean for the given record ID
 */

package org.aitp.competitor;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class PurchaseOrderDataAccess implements PurchaseOrderDataAccessIF {

	public PO getPO(Integer po) {

        PO p = new PO();
		ResultSet posHdr;
		ResultSet posDtl;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            Connection conn =
                DriverManager.getConnection("jdbc:mysql:///po?user=root");
            Statement stmtHdr = conn.createStatement();
            posHdr = stmtHdr.executeQuery
                ("SELECT * FROM pohdr where PONbr = " + po);
            posHdr.next();
            p.retrieveHdr(posHdr);
            Statement stmtDtl = conn.createStatement();
            posDtl = stmtDtl.executeQuery
            	("Select * FROM podtl where PONbr = " + po);
            while (posDtl.next()) {
            	p.retrieveDtl(posDtl);
            }
            conn.close();
        } catch (ClassNotFoundException cnfe) {
            System.err.println (cnfe);
        } catch (SQLException sqle) {
            System.err.println(sqle);
        } // catch
        return p;
    } // getPO


} // PurchaseOrderDataAccess