public class CompanionDbPlugin extends AbstractPlugin {
    private JdbcConnectionPool jcp = null;
    private String namespace = null;
    private Logger logger;
    private Exception exception;

    public void initialize(Hashtable props) throws InitializationException {
        // Initialize the class here with properties in the <initialize> element
        // of the workflow.
        // TODO Auto-generated method stub
        namespace = (String) props.get("poolName");
        jcp = JdbcConnectionPool.getInstance(namespace);

        logger = Logger.getLogger(CompanionDbPlugin.class);
        Connection con = null;
        try {
            con = (Connection) jcp.acquire();
        } catch (Throwable th) {
            throw new InitializationException("JdbcConnection could not be established. Check the db properties file for problems.", th);
        } finally {
            JdbcHelper.release(jcp, con, null, null);
        }
    }

    public Object process(Message m) throws PluginException
    {
        // TODO Auto-generated method stub
        //do all your work here
        GenericMessage gm = null;
        boolean success = false;
        String type = null;

        try
        {
            if (m instanceof GenericMessage)
            {
                gm = (GenericMessage) m;
            }
            else
            {
                gm = GenericMessageFactory.createGenericMessage(m);
            }
        }
        catch (Throwable th)
        {
            throw new PluginException("Unable to create GenericMessage object from message.");
        }

        try{
            type = gm.getStringProperty("type");
            if(null == type){
                return m;
            }
            type.toLowerCase();
        }
        catch(Exception e){
            exception = e;
            logger.debug(e.toString());
        }

        boolean isInsert = true;
        String transactionType;
        int loopCount = 0;

        while (!success)
        {
            Connection con = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try
            {
               con = (Connection) jcp.acquire();
                if (!isInsert)
                {
                    transactionType = "update";
                }
                else
                {
                    transactionType = "insert";
                }

                if (transactionType.equals("insert"))
                {
                    if(type.compareTo("fb_post") == 0){
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.1"));
                        ps.setString(1, gm.getStringProperty("fran_id").replace("\"",""));
                        ps.setString(2, gm.getStringProperty("ep_id").replace("\"",""));
                        ps.setString(3, gm.getStringProperty("device_id").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.2"));
                        ps.setInt(1, 103);
                        ps.setString(2,  gm.getStringProperty("post").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.3"));
                        ps.setInt(1, 104);
                        ps.setString(2, gm.getStringProperty("user_id").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.4"));
                        ps.setInt(1, 118);
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.5"));
                        ps.setInt(1, 124);
                        ps.setString(2, gm.getStringProperty("display_name").replace("\"",""));
                        ps.executeUpdate();
                        success = true;
                    }
                    else if(type.compareTo("tw_post") == 0){
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.1"));
                        ps.setString(1, gm.getStringProperty("fran_id").replace("\"",""));
                        ps.setString(2, gm.getStringProperty("ep_id").replace("\"",""));
                        ps.setString(3, gm.getStringProperty("device_id").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.2"));
                        ps.setInt(1, 105);
                        ps.setString(2,  gm.getStringProperty("post").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.3"));
                        ps.setInt(1, 106);
                        ps.setString(2, gm.getStringProperty("user_id").replace("\"",""));
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.4"));
                        ps.setInt(1, 119);
                        ps.executeUpdate();
                        ps = con.prepareStatement(jcp.getStatement("insertNewMessage.5"));
                        ps.setInt(1, 125);
                        ps.setString(2, gm.getStringProperty("display_name").replace("\"",""));
                        ps.executeUpdate();
                        success = true;
                    }
                    else if(type.compareTo("fb_like") == 0){
                        ps = con.prepareStatement(jcp.getStatement("insertMessageLike"));
                        ps.setInt(1, Integer.parseInt(gm.getStringProperty("entry_id").replace("\"","")));
                        ps.setInt(2, 118);
                        ps.setInt(3, Integer.parseInt(gm.getStringProperty("entry_id").replace("\"","")));
                        ps.setInt(4, 118);
                        ps.executeUpdate();
                        success = true;
                    }
                    else if(type.compareTo("tw_like") == 0){
                        ps = con.prepareStatement(jcp.getStatement("insertMessageLike"));
                        ps.setInt(1, Integer.parseInt(gm.getStringProperty("entry_id").replace("\"","")));
                        ps.setInt(2, 119);
                        ps.setInt(3, Integer.parseInt(gm.getStringProperty("entry_id").replace("\"","")));
                        ps.setInt(4, 119);
                        ps.executeUpdate();
                        success = true;
                    }
                    else if(type.compareTo("submit_poll") == 0){
                        ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.1"));
                        ps.setString(1, gm.getStringProperty("fran_id").replace("\"",""));
                        ps.setString(2, gm.getStringProperty("ep_id").replace("\"",""));
                        ps.setString(3, gm.getStringProperty("device_id").replace("\"",""));
                        ps.execute();
                        ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.2"));
                        ps.setString(1, gm.getStringProperty("content_id").replace("\"",""));
                        ps.execute();

                        switch (Integer.parseInt(gm.getStringProperty("response_num").replace("\"",""))){

                        case 1:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,1);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,0);
                            ps.execute();
                            break;
                        case 2:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,1);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,0);
                            ps.execute();
                            break;
                        case 3:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,1);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,0);
                            ps.execute();
                            break;
                        case 4:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,1);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,0);
                            ps.execute();
                            break;
                        case 5:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,1);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,0);
                            ps.execute();
                            break;
                        case 6:
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.3"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.4"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.5"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.6"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.7"));
                            ps.setInt(1,0);
                            ps.execute();
                            ps = con.prepareStatement(jcp.getStatement("insertPollAnswer.8"));
                            ps.setInt(1,1);
                            ps.execute();
                            break;

                        }
                        success = true;
                    }
                    else if(type.compareTo("add_bad_word") == 0){
                         ps = con.prepareStatement(jcp.getStatement("addBadWord.1"));
                         ps.execute();
                         ps = con.prepareStatement(jcp.getStatement("addBadWord.2"));
                         ps.setString(1, gm.getStringProperty("word").replace("\"","").toLowerCase());
                         ps.execute();
                         success = true;
                    }
                    else if(type.compareTo("filter_message") == 0){
                        ps = con.prepareStatement(jcp.getStatement("filterMessage"));
                        ps.setString(1, gm.getStringProperty("entry_id").replace("\"","").toLowerCase());
                        ps.execute();
                        success = true;
                    }
                    else if(type.compareTo("delete_bad_word") == 0){
                        ps = con.prepareStatement(jcp.getStatement("deleteBadword"));
                        ps.setString(1, gm.getStringProperty("word").replace("\"","").toLowerCase());
                        ps.execute();
                        success = true;
                    }

                    //dev only!!!!!!!
                    else if(type.compareTo("purge_messages") == 0){
                        ps = con.prepareStatement(jcp.getStatement("purgeMessages"));
                        ps.execute();
                        success = true;
                    }

                }
                else if (transactionType.equals("update"))
                {
                }
                if (loopCount++ > 4)
                {
                    success = true;
                }
            }
            catch (Exception e)
            {
                throw new PluginException("Exception in CompanionDbPlugin: " + e.toString());

            }
            finally
            {
                try {
                    con.commit();
                    JdbcHelper.release(jcp, con, ps, rs);
                    con = null;
                } catch (Exception e) {
                    throw new PluginException("Exception in CompanionDbPlugin: " + e.toString());
                }

            }
        }

        return m;
    }
}