How can we upload documents using the upload widget in Bonita BPM 7.4.2 by binding it with a DB connector?

package org.xxxxrnare.connector.xxxxPutDocumentToPostgres110Impl;

import java.io.ByteArrayInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;

import org.bonitasoft.engine.api.DocumentAPI;
import org.bonitasoft.engine.api.ProcessRuntimeAPI;
import org.bonitasoft.engine.bpm.document.Document;
import org.bonitasoft.engine.bpm.document.DocumentNotFoundException;
import org.bonitasoft.engine.connector.ConnectorException;

/**
 *The connector execution will follow the steps
 * 1 - setInputParameters() --> the connector receives input parameters values
 * 2 - validateInputParameters() --> the connector can validate input parameters values
 * 3 - connect() --> the connector can establish a connection to a remote server (if necessary)
 * 4 - executeBusinessLogic() --> execute the connector
 * 5 - getOutputParameters() --> output are retrieved from connector
 * 6 - disconnect() --> the connector can close connection to remote server (if any)
 */
public class xxxxPutDocumentToPostgres110Impl extends
                AbstractxxxxPutDocumentToPostgres110Impl {

        Logger logger= Logger.getLogger("org.bonitasoft");
        String module = null;

        //inputs
        Map<String, String> dbParms = new HashMap<String, String>();
        Long docID;
       
        //outputs
        Boolean success;
        List<String> listOutput = new ArrayList<String>();

        //locals
        Boolean debug = false;

        //set basics for db
        Connection con = null;
        PreparedStatement pst = null;
        ResultSet rs = null;
        String sql2 = null;
        String dbTableDOM = null;
        String dbTableTSK = null;
        Boolean firstReturnSet = false;

        String tble = "xxxxdocuments";

        String title = null;
       
        @SuppressWarnings("unchecked")
        @Override
        protected void executeBusinessLogic() throws ConnectorException{
                //Get access to the connector input parameters
                //getDbParms();
               
                getClassName();

                dbParms = getDbParms();
                docID = getDocID();
       
                if(debug){dumpDataInputs();}
                initializeOutputs();

                //TODO execute your business logic here

                try {
                        Class.forName("org.postgresql.Driver");
                        String url = "jdbc:postgresql://"+dbParms.get("dbHost")+":"+dbParms.get("dbPort")+"/"+dbParms.get("dbDatabase");
                        if(debug){logger.severe(module+": url: "+url);}
                        con = DriverManager.getConnection(url, dbParms.get("dbUser"),dbParms.get("dbPassword"));
                        if(debug){logger.severe(module+": con: "+con);}

                        PreparedStatement ps = con.prepareStatement("INSERT INTO " + tble
                                        + " VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");

                        // document stuff
                         
                        ProcessRuntimeAPI processRuntimeAPI = apiAccessor.getProcessAPI();

                        Document d1 = apiAccessor.getProcessAPI().getDocument(docID);
                        String xxxxdocumentname = d1.getContentFileName();
                        String mimeType = d1.getContentMimeType();
                        // use fileName if title is empty
                        title = (title==null||title.isEmpty()) ? d1.getContentFileName():title;
                        final byte[] contentByte = ((DocumentAPI) processRuntimeAPI).getDocumentContent(d1.getContentStorageId());
                        final ByteArrayInputStream xxxxdocument = new ByteArrayInputStream(contentByte);
                        int xxxxdoclength = contentByte.length;

                        if(debug){logger.severe(module+"@String xxxxdocumentname "+xxxxdocumentname);}
                        if(debug){logger.severe(module+"@String mimeType "+mimeType);}
                        if(debug){logger.severe(module+"@title "+title);}
                                       
                        Calendar calendar = Calendar.getInstance();
                        Timestamp date = new java.sql.Timestamp(calendar.getTime().getTime());
                       
//                      calendar.set(Calendar.YEAR, 2015);
//                      calendar.set(Calendar.MONTH, 1);
//                      calendar.set(Calendar.DAY_OF_MONTH, 1);
//                      Date date = new Date();

                        //1 xxxxdocumentid
                        //2 xxxxyyyyydocumentname
                        //3 xxxxdocumentname
                        //4 xxxxversionmajor
                        //5 xxxxversionminor
                        //6 xxxxversionmini
                        //7 uploader
                        //8 approver
                        //9 uploaddate
                        //10 approvaldate
                        //11 xxxxstatus
                        //12 xxxxdocument
                       
                    ps.setLong(1, 0);
                        ps.setString(2, removeExtension(xxxxdocumentname.replace("_", " "))); // remove
                        ps.setString(3, xxxxdocumentname);
                        ps.setLong(4, 0);
                        ps.setLong(5, 0);
                        ps.setLong(6, 0);
                        ps.setString(7, "Uploader");
                        ps.setString(8, "Approver");
                        ps.setTimestamp(9, date);
                        ps.setTimestamp(10, date);
                        ps.setString(11, "Pending");
                        ps.setBinaryStream(12, xxxxdocument, xxxxdoclength);
                        ps.executeUpdate();

                        ps.close();
                        con.close();
                       
                } catch (ClassNotFoundException e) {
                        logger.info("After Load Class: ClassNotFoundException");
                } catch (SQLException eSQL) {
                        // TODO Auto-generated catch block
                        eSQL.printStackTrace();
                } catch (DocumentNotFoundException eDoc) {
                        // TODO Auto-generated catch block
                        eDoc.printStackTrace();
                }
       
                //WARNING : Set the output of the connector execution. If outputs are not set, connector fails
                dumpDataOutputs();
                setSuccess(success);
       
         }

        private void getClassName(){
                Class<?> enclosingClass = getClass().getEnclosingClass();
                if (enclosingClass != null) {
                        module = enclosingClass.getName();
                } else {
                        module = getClass().getName();
                }
        }

        private void dumpDataInputs(){
                if(debug){logger.info(module+": Start");
                logger.info(module+": Starting: getDbParms: "+getDbParms());
                logger.info(module+": Starting: docID: "+docID.toString());}
        }

        private void dumpDataOutputs(){
                if(debug){logger.info(module+": Ending: success: "+success);
                logger.info(module+": End");}
        }

        private void initializeOutputs(){
                //set default outputs
                success = true;
        }

        private static String removeExtension(String s) {

            String separator = System.getProperty("file.separator");
            String filename;

            // Remove the path upto the filename.
            int lastSeparatorIndex = s.lastIndexOf(separator);
            if (lastSeparatorIndex == -1) {
                filename = s;
            } else {
                filename = s.substring(lastSeparatorIndex + 1);
            }

            // Remove the extension.
            int extensionIndex = filename.lastIndexOf(".");
            if (extensionIndex == -1)
                return filename;

            return filename.substring(0, extensionIndex);
        }
       
        @Override
        public void connect() throws ConnectorException{
                //[Optional] Open a connection to remote server
       
        }

        @Override
        public void disconnect() throws ConnectorException{
                //[Optional] Close connection to remote server
       
        }

}