crud.java

来自「Java Pattern Oriented Framework (Jt) 是为了」· Java 代码 · 共 609 行 · 第 1/2 页

        }
        
    }
    
    private void deleteObject (ActionForm form) {
        JtMessage msg = new JtMessage ();

        //JtHashTable attributes;
        //Member member = new Member ();

        
        if (form == null)
            return; // check
        
        //adapter = (JtDAOAdapter) factory.createObject (JtHibernateAdapter.JtCLASS_NAME);
        

        classInstance = factory.createObject (classname);
        if (classInstance == null) {
            handleError ("unable to create an object of class: " + classname);
            return;
        }    


        copyFormAttributes (form, classInstance);
        
        msg = new JtMessage (JtDAOAdapter.JtDELETE);   
        msg.setMsgContent(classInstance);
        
        
        factory.sendMessage (adapter, msg);
        
        // Propagate the exception
        
        if (adapter.getObjException() != null) {
            this.setObjException(adapter.getObjException());
        }  
        
        factory.sendMessage (adapter, new JtMessage (JtObject.JtREMOVE));
                
    }

    private void updateObject (ActionForm form) {
        JtMessage msg = new JtMessage ();

        //Member member = new Member ();

        
        if (form == null)
            return; // check
        
        //adapter = (JtDAOAdapter) factory.createObject (JtHibernateAdapter.JtCLASS_NAME);
        
        classInstance = factory.createObject (classname);
        if (classInstance == null) {
            handleError ("unable to create an object of class: " + classname);
            return;
        }          
        
        copyFormAttributes (form, classInstance);
        
        msg = new JtMessage (JtDAOAdapter.JtUPDATE);   
        msg.setMsgContent(classInstance);
        
        
        factory.sendMessage (adapter, msg);
        
        // Propagate the exception
        
        if (adapter.getObjException() != null) {
            this.setObjException(adapter.getObjException());
        } 
        
        factory.sendMessage (adapter, new JtMessage (JtObject.JtREMOVE));
                
    }

    private void createObject (ActionForm form) {
        JtMessage msg = new JtMessage ();

        //Member member = new Member ();

        
        if (form == null)
            return; // check
        
        //adapter = (JtDAOAdapter) factory.createObject (JtHibernateAdapter.JtCLASS_NAME);
        

        classInstance = factory.createObject (classname);
        if (classInstance == null) {
            handleError ("unable to create an object of class: " + classname);
            return;
        }    


        copyFormAttributes (form, classInstance);
        
        msg = new JtMessage (JtDAOAdapter.JtCREATE);   
        msg.setMsgContent(classInstance);
        
        
        factory.sendMessage (adapter, msg);
        
        // Propagate the exception
        
        if (adapter.getObjException() != null) {
            this.setObjException(adapter.getObjException());
        }     
        
        factory.sendMessage (adapter, new JtMessage (JtObject.JtREMOVE));
                
    }   
    
    private List executeQuery () {
        JtMessage msg = new JtMessage ();
        List result;
        
        //adapter = (JtDAOAdapter) factory.createObject (JtHibernateAdapter.JtCLASS_NAME);
        
        msg.setMsgId (JtHibernateAdapter.JtEXECUTE_QUERY);
        
        if (query == null || query.equals("")) {
            handleError ("query attribute needs to be set.");   
            return (null);
        }    
        //msg.setMsgContent("select * from roster");
        msg.setMsgContent(query);
        
        
        classInstance = factory.createObject (classname);
        if (classInstance == null) {
            handleError ("unable to create an object of class: " + classname);
            return (null);
        }           
        msg.setMsgData(classInstance);
        
        
        result = (List) factory.sendMessage (adapter, msg);
        
        // Propagate the exception
        
        if (adapter.getObjException() != null) {
            this.setObjException(adapter.getObjException());
            result = null;
        }
        
        factory.sendMessage (adapter, new JtMessage (JtObject.JtREMOVE));
        return (result);
    }
    
    private void initialize () {
        adapter = (JtDAOStrategy) factory.createObject (JtDAOStrategy.JtCLASS_NAME);
        
    }
    
    /**
     * Process object messages.
     * <ul>
     * </ul>
     * @param message message
     */

    public Object processMessage (Object message) {
        String data;
        String content;
        String attachment;
        ActionForm form = null;
        JtContext context;
        

        JtMessage e = (JtMessage) message;

        if (e == null ||  (e.getMsgId() == null))
            return (null);
        
        factory.setStopClass(JtObject.class);
        
        if (!initted) {
            initialize ();
            initted = true;
        }

/*
        if (e.getMsgId().equals(JtObject.JtACTIVATE)) {

            // pass the form information   
            data = e.getMsgData ();
            return ( getActionMappings ());
        }
*/        
        content = (String) e.getMsgContent ();
        data = (String) e.getMsgData ();
        attachment  = (String) e.getMsgAttachment ();
        context = (JtContext) e.getMsgContext();
        if (context != null)
            form = (ActionForm) context.getActionForm();  

        if (e.getMsgId().equals(CRUD.READ)) {


            return (readObject (form, content,
                    data, attachment));
            //return ( readObject ((ActionForm) data));
        }
        
        if (e.getMsgId().equals(CRUD.DELETE)) {
            
            //data = e.getMsgData ();
            
            deleteObject (form);
            return (null);
        }
        
       
        if (e.getMsgId().equals(CRUD.UPDATE)) {
            
            //data = e.getMsgData ();
            updateObject ((ActionForm) form);
            return (null);
        }
        
        if (e.getMsgId().equals(CRUD.CREATE)) {
            
            //data = e.getMsgData ();
            createObject ((ActionForm) form);
            return (null); // check
        }
        
        if (e.getMsgId().equals(CRUD.EXECUTE_QUERY)) {
            
            return ( executeQuery ());
        }
        

        return (super.processMessage(message));

    }
    /**
     * Demonstrates the messages processed by this class.
     */

    public static void main(String[] args) {

        JtFactory factory = new JtFactory ();
        CRUD crud;
        JtMessage msg;
        //List list;
        Object obj;
        MemberForm form = new MemberForm ();
        JtContext context = new JtContext ();
        
        
        msg = new JtMessage (CRUD.CREATE);
        
        
        form.setEmail("[e-mail]");
        
        crud = (CRUD) factory.createObject(CRUD.JtCLASS_NAME);
        crud.setClassname("Jt.examples.hibernate.Member");
        crud.setKey("email");
        
        
        msg = new JtMessage (CRUD.CREATE);
        
        //msg.setMsgData(form);
        
        context.setActionForm(form);
        msg.setMsgContext(context);
        
        obj = (JtObject) factory.sendMessage(crud, msg);
        
        
        form.setFirstname("name");
        msg = new JtMessage (CRUD.UPDATE);        
        //msg.setMsgData(form);
        context.setActionForm(form);
        msg.setMsgContext(context);
        //factory.sendMessage(crud, msg);
        
        msg = new JtMessage (CRUD.READ);        
        //msg.setMsgData(form);
        
        obj = (Object) factory.sendMessage(crud, msg);
        
        //factory.sendMessage(obj, new JtMessage (JtObject.JtPRINT));
        
        
        form.setEmail("[e-mail]");
        msg = new JtMessage (CRUD.DELETE);
        context.setActionForm(form);
        msg.setMsgContext(context);
        //msg.setMsgData(form);
        factory.sendMessage(crud, msg);
        
        //msg = new JtMessage (JtObject.JtACTIVATE);          
        
        //list = (List) factory.sendMessage (actionMapping, msg);
        //System.out.println ("List=" + list);


    }
}