自定义SOAP服务的开发：阿帕奇Derby Customized SOAP Web Service Development (Java + Apache Derby + Netbeans 9.0)

public class productInfo {
    int id;
    String name;
    String brand;
    int year;
    int price;
    int stock;
    
    public void setId(int id) { this.id = id;}
    public void setName(String name) { this.name = name;}
    public void setBrand(String brand) { this.brand = brand;}
    public void setYear(int year) {this.year = year;}
    public void setPrice(int price) {this.price = price;}
    public void setStock(int stock) {this.stock = stock;}
    public int getId() {return id;}
    public String getName() {return name;}
    public String getBrand() {return brand;}
    public int getYear() {return year;}
    public int getPrice() { return price;}
    public int getStock() {return stock;}

    /**
     * Web service operation
     */
    @WebMethod(operationName = "getProductInfo")
    public productInfo getProductInfo(@WebParam(name = "query") String keyword) {
        // instance initialization
        productInfo product = new productInfo();       
        try{   
            Statement s = Main.getConn().createStatement();
            System.out.println("WS_getProductInfo(): Connection succeeded !");
            // execute Query
            ResultSet rs = 
              s.executeQuery("SELECT * FROM ROOT.PRODUCTS WHERE PRODUCT_NAME = \'"+ keyword + "\'");
            System.out.println("WS_getProductInfo(): Doing Query");
            // sets members from results
            while (rs.next()) {
                product.setId(rs.getInt("PRODUCT_ID"));
                product.setName(rs.getString("PRODUCT_NAME"));
                product.setBrand(rs.getString("BRAND_NAME"));
                product.setYear(rs.getInt("MODEL_YEAR"));
                product.setPrice(rs.getInt("LIST_PRICE"));
                product.setStock(rs.getInt("STOCK"));
            }
        }
        catch(Exception e){}
        return product;
    }

    /**
     * Web service operation
     */
    @WebMethod(operationName = "placeOrder")
    public String getPlaceOrder(@WebParam(name = "productID") int product_ID, 
                                @WebParam(name = "numberOfProduct") int number_product, 
                                @WebParam(name = "customerID") int custmer_ID) {
        productInfo product = new productInfo();
        
        int price = 0;
        int user_credit = 0;
        int number_in_stock = 0;
        
        try{   
            Statement s = Main.getConn().createStatement();
            ResultSet rs = s.executeQuery("SELECT LIST_PRICE FROM ROOT.PRODUCTS WHERE PRODUCT_ID = "+ product_ID);
            while (rs.next()) {
                price = rs.getInt("LIST_PRICE");
            }
            
            rs = s.executeQuery("SELECT STOCK FROM ROOT.PRODUCTS WHERE PRODUCT_ID = "+ product_ID);
            while (rs.next()) {
                number_in_stock = rs.getInt("STOCK");
            }
            
            rs = s.executeQuery("SELECT ACCOUNT_CREDIT FROM ROOT.ACCOUNTS WHERE CUSTOMER_ID = "+ custmer_ID);
            while (rs.next()) {
                user_credit = rs.getInt("ACCOUNT_CREDIT");
            }
                      
        }
        catch(Exception e){}
        
        if(price * number_product > user_credit 
          && number_in_stock < number_product) return "Order placement fails; Insufficient credits!";
        else{
            try {
                System.out.println("WS_getPlaceOrder(): Start to place order! ");
                Statement s2 = Main.getConn().createStatement();
                
                // update the stock number
                s2.executeUpdate("UPDATE ROOT.PRODUCTS SET STOCK = " 
                  + (number_in_stock- number_product) 
                  + " WHERE PRODUCT_ID = "+ product_ID);
                System.out.println("WS_getPlaceOrder(): Update stock finished!");
                
                // deduct the cost                 
                s2.executeUpdate("UPDATE ROOT.ACCOUNTS SET ACCOUNT_CREDIT = "+ (user_credit - price * number_product) 
                  + "WHERE CUSTOMER_ID = "+ custmer_ID);
                System.out.println("WS_getPlaceOrder(): Updated credit finished! ");
                
                // insert record in order 
                s2.executeUpdate("INSERT INTO ROOT.ORDERS VALUES (" + "10" + "," 
                  + custmer_ID + "," 
                  + product_ID + "," 
                  + number_product + ")");
                System.out.println("WS_getPlaceOrder(): Inserted new record to the order table!");
               
            } catch (Exception e) {
            }
        }
        return "WS: Successful placed the order!";
    }

    public static void main(String args[]){
        // Round 1
        placeOrder(101, 10, 10086);

        // Round 2
        String keyword = "Macbook Pro 15";
        productInfo = getProduct(keyword);
        placeOrder(productInfo.getId(), 10, 10086);
}

@Override
public boolean handleMessage(SOAPMessageContext messageContext) {
    Boolean outboundProperty = (Boolean) messageContext.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
    if (outboundProperty) {
    //if the message is outgoing one, i.e., the request to a web service, we add account information into the header
        SOAPMessage message = messageContext.getMessage();
        try {
            SOAPEnvelope envelope = messageContext.getMessage().getSOAPPart().getEnvelope();
            SOAPHeader header=envelope.getHeader();
            if (header==null){
                header = envelope.addHeader();
            }
            // adding the username element as the child element to the header
            // when sent out the message to server
            SOAPElement usernameToken=header.addChildElement("UsernameToken","wsse", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd");
            SOAPElement username=usernameToken.addChildElement("Username","wsse");
            username.addTextNode("splashurpants");

        } catch (Exception e) {
        e.printStackTrace();
        }
    } else { //if the message is an incoming one, i.e., the response from the service, then we print out the whole message
        try {
            SOAPMessage message = messageContext.getMessage();
            System.out.println("");
    } catch (Exception ex) {
    ex.printStackTrace();
    }
    }
    return outboundProperty;
}

    @Override
    public boolean handleMessage(SOAPMessageContext messageContext) {
        // get the HashSet
        HashSet<String> table = Main.getCoordinatorSet();
        System.out.println("Server side");
        String outProperty = SOAPMessageContext.MESSAGE_OUTBOUND_PROPERTY;
        boolean outgoing = (Boolean)messageContext.get(outProperty);
        SOAPMessage msg = messageContext.getMessage();
        String username="";
        try {
            if (outgoing){
                System.err.println("");
            } 
            else{  

              // Get username @username
                SOAPHeader header = msg.getSOAPHeader();
                Iterator it = header.examineAllHeaderElements();
                while(it.hasNext()){
                    SOAPHeaderElement e=(SOAPHeaderElement) it.next();
                    NodeList nl=e.getElementsByTagName("wsse:Username");
                    for (int i=0;i<nl.getLength();i++){
                        username+=nl.item(i).getTextContent();
                    }
                }
                System.out.println("Server: Ongoing username: " + username);
                
                // get the operation name @opNameString
                SOAPEnvelope envelope = messageContext.getMessage().getSOAPPart().getEnvelope();   
                SOAPBody body = envelope.getBody();
                if (body == null){
                    System.err.println("Server: No body in message!");
                    return false;
                }
                Iterator it2 = body.getChildElements();
                String opNameString = "";
                while(it2.hasNext()){
                    SOAPBodyElement e=(SOAPBodyElement) it2.next();
                    opNameString = e.getLocalName();
                    System.out.println("Server: Ongoing operation name: " + opNameString);
                }

                //
                // Core Business Logic
                //
                // old user
                if (table.contains(username)){
                    // registered user that had called product info query
                    if (opNameString.equals("getProductInfo")){
                        System.out.println("Server: Succeeded to query the productInfo");
                    }
                    // place the order after getting the product info 
                    if (opNameString.equals("placeOrder")) {
                        System.out.println("Server: Succeeded to place the order");
                    }
                    return true;
                }
                // new user
                else{
                    // not yet invoke the getProductInfo
                    System.out.println("Server: Not yet registered");
                    if (opNameString.equals("getProductInfo")){
                        table.add(username);
                        System.out.println("Server: Registration done");
                        System.out.println("Server: Succeeded to query the productInfo");
                        return true;
                    } 
                    // new user attends to directly place the order
                    if (opNameString.equals("placeOrder")) {
                        System.out.println("Server: Failed. Attend to place order without the registeration.");
                        return false;
                    }
                }
            }
        }
        catch(SOAPException e){
            System.out.println("SOAP IO Error!!!!");
            throw new RuntimeException(e);
        }
        return false;
    }